Package de.hybris.platform.cluster.legacy

Class LegacyBroadcastHandler

  • All Implemented Interfaces:
    BroadcastMessageListener
    public class LegacyBroadcastHandler
extends java.lang.Object
implements 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!

    • Method Detail

      • sendBinaryCustomPacket

        public void sendBinaryCustomPacket​(byte[] customData)

      • sendCustomPacket

        public void sendCustomPacket​(java.lang.String prefix,
                             java.lang.String msg)

      • unregisterMessageListener

        public void unregisterMessageListener​(java.lang.String prefix)

      • registerMessageListener

        public void registerMessageListener​(java.lang.String prefix,
                                    MessageBroadcastListener messageBroadcastListener)

      • adjustPrefix

        protected java.lang.String adjustPrefix​(java.lang.String prefix)

      • destroy

        protected void destroy()

      • notifyMessageReceived

        protected void notifyMessageReceived​(RawMessage message,
                                     byte[] data)

      • notifyMessageReceived

        protected void notifyMessageReceived​(java.lang.String string)