de.hybris.platform.cluster.legacy

Class LegacyBroadcastHandler

java.lang.Object

de.hybris.platform.cluster.legacy.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!

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	CFG_MAXTHREADS
static java.lang.String	CFG_MAXTHREADS_OLD
static int	IDLETHREADS
static int	KIND_CUSTOMEVENT
static int	KIND_CUSTOMEVENT_BINARY
static int	MAXTHREADS

Method Summary

Modifier and Type	Method and Description
protected java.lang.String	adjustPrefix(java.lang.String prefix)
protected void	destroy()
static LegacyBroadcastHandler	getInstance()
protected void	notifyMessageReceived(RawMessage message, byte[] data)
protected void	notifyMessageReceived(java.lang.String string)
boolean	processMessage(RawMessage message)
void	registerBinaryListener(BinaryBroadcastListener listener)
void	registerMessageListener(java.lang.String prefix, MessageBroadcastListener messageBroadcastListener)
void	sendBinaryCustomPacket(byte[] customData)
void	sendCustomPacket(java.lang.String prefix, java.lang.String msg)
void	unregisterBinaryListener(BinaryBroadcastListener listener)
void	unregisterMessageListener(java.lang.String prefix)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

CFG_MAXTHREADS_OLD

public static final java.lang.String CFG_MAXTHREADS_OLD

See Also:

Constant Field Values

CFG_MAXTHREADS

public static final java.lang.String CFG_MAXTHREADS

See Also:

Constant Field Values

MAXTHREADS

public static final int MAXTHREADS

See Also:

Constant Field Values

IDLETHREADS

public static final int IDLETHREADS

See Also:

Constant Field Values

KIND_CUSTOMEVENT_BINARY

public static final int KIND_CUSTOMEVENT_BINARY

See Also:

Constant Field Values

KIND_CUSTOMEVENT

public static final int KIND_CUSTOMEVENT

See Also:

Constant Field Values

Method Detail

getInstance

public static LegacyBroadcastHandler getInstance()

processMessage

public boolean processMessage(RawMessage message)

Specified by:

processMessage in interface BroadcastMessageListener

sendBinaryCustomPacket

public void sendBinaryCustomPacket(byte[] customData)

sendCustomPacket

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

registerBinaryListener

public void registerBinaryListener(BinaryBroadcastListener listener)

unregisterBinaryListener

public void unregisterBinaryListener(BinaryBroadcastListener listener)

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)