001
014
015 package com.liferay.portal.kernel.nio.intraband.messaging;
016
017 import com.liferay.portal.kernel.io.Deserializer;
018 import com.liferay.portal.kernel.messaging.Message;
019 import com.liferay.portal.kernel.messaging.MessageBusUtil;
020 import com.liferay.portal.kernel.nio.intraband.BaseAsyncDatagramReceiveHandler;
021 import com.liferay.portal.kernel.nio.intraband.Datagram;
022 import com.liferay.portal.kernel.nio.intraband.RegistrationReference;
023
024
027 public class MessageDatagramReceiveHandler
028 extends BaseAsyncDatagramReceiveHandler {
029
030 @Override
031 protected void doReceive(
032 RegistrationReference registrationReference, Datagram datagram)
033 throws Exception {
034
035 Deserializer deserializer = new Deserializer(
036 datagram.getDataByteBuffer());
037
038 Message message = deserializer.readObject();
039
040 MessageBusUtil.sendMessage(message.getDestinationName(), message);
041 }
042
043 }