Class LegacyBroadcastHandler
java.lang.Object
de.hybris.platform.cluster.legacy.LegacyBroadcastHandler
- All Implemented Interfaces:
BroadcastMessageListener
Replacement for pre-4.1 UDP listeners.
Send like this:
byte[] data = ... LegacyBroadcastHandler.getInstance().sendBinaryCustomPacket( data ); String prefix = "FOO"; String message = ... LegacyBroadcastHandler.getInstance().sendCustomPacket( prefix, message );
Get data like this:
LegacyBroadcastHandler.getInstance().registerBinaryListener(new BinaryBroadcastListener()
{
public void processPacket(byte[] message)
{
// process data here
}
});
// or
LegacyBroadcastHandler.getInstance().registerMessageListener(new MessageBroadcastListener()
{
public void processPacket(String message)
{
// process data here
}
});
Please note that this is a non-tenant singleton. This means that it will send and receive messages without tenant information attached. Therefore calling code and listeners must take care of attaching and checking tenant information!
-
Field Summary
Fields -
Method Summary
Modifier and TypeMethodDescriptionprotected StringadjustPrefix(String prefix) protected voiddestroy()static LegacyBroadcastHandlerprotected voidnotifyMessageReceived(RawMessage message, byte[] data) protected voidnotifyMessageReceived(String string) booleanprocessMessage(RawMessage message) voidvoidregisterMessageListener(String prefix, MessageBroadcastListener messageBroadcastListener) voidsendBinaryCustomPacket(byte[] customData) voidsendCustomPacket(String prefix, String msg) voidvoidunregisterMessageListener(String prefix)
-
Field Details
-
CFG_MAXTHREADS_OLD
- See Also:
-
CFG_MAXTHREADS
- See Also:
-
MAXTHREADS
public static final int MAXTHREADS- See Also:
-
IDLETHREADS
public static final int IDLETHREADS- See Also:
-
KIND_CUSTOMEVENT_BINARY
public static final int KIND_CUSTOMEVENT_BINARY- See Also:
-
KIND_CUSTOMEVENT
public static final int KIND_CUSTOMEVENT- See Also:
-
-
Method Details
-
getInstance
-
processMessage
- Specified by:
processMessagein interfaceBroadcastMessageListener
-
sendBinaryCustomPacket
public void sendBinaryCustomPacket(byte[] customData) -
sendCustomPacket
-
registerBinaryListener
-
unregisterBinaryListener
-
unregisterMessageListener
-
registerMessageListener
public void registerMessageListener(String prefix, MessageBroadcastListener messageBroadcastListener) -
adjustPrefix
-
destroy
protected void destroy() -
notifyMessageReceived
-
notifyMessageReceived
-