de.hybris.platform.cluster

Class InvalidationBroadcastHandler

java.lang.Object

de.hybris.platform.cluster.InvalidationBroadcastHandler

All Implemented Interfaces:

BroadcastMessageListener

public class InvalidationBroadcastHandler
extends java.lang.Object
implements BroadcastMessageListener

Sends and receives invalidation messages to and from a hybris platform cluster.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	InvalidationBroadcastHandler.InvalidationEvent

Field Summary

Fields

Modifier and Type	Field and Description
java.util.regex.Pattern	invalidationEventRegExpPattern
static java.lang.String	INVTYPE_DELIMITER
static java.lang.String	KEY_DELIMITER
static java.lang.String	KEY_ELEMENT_DELIMITER
static int	KIND_INVALIDATION
static java.lang.String	NR_DELIMITER
static java.lang.String	TOPIC_DELIMITER

Constructor Summary

Constructors

Constructor and Description
InvalidationBroadcastHandler(BroadcastService broadcastService)

Method Summary

Modifier and Type	Method and Description
void	destroy()
static InvalidationBroadcastHandler	getInstance()
protected java.util.regex.Pattern	getInvalidationEventPattern()
protected java.lang.String	objectToString(java.lang.Object object)
protected void	processInvalidation(InvalidationBroadcastHandler.InvalidationEvent event, RawMessage message)
boolean	processMessage(RawMessage message)
void	sendMessage(Tenant tenant, java.lang.Object[] topic, java.lang.Object[] key, int invalidationType)
protected java.lang.Object	stringToObject(java.lang.String string)
protected byte[]	toBinaryMessage(Tenant tenant, java.lang.Object[] topic, java.lang.Object[] key, int invalidationType, long number)

Methods inherited from class java.lang.Object

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

Field Detail

TOPIC_DELIMITER

public static final java.lang.String TOPIC_DELIMITER

See Also:

Constant Field Values

KEY_DELIMITER

public static final java.lang.String KEY_DELIMITER

See Also:

Constant Field Values

INVTYPE_DELIMITER

public static final java.lang.String INVTYPE_DELIMITER

See Also:

Constant Field Values

NR_DELIMITER

public static final java.lang.String NR_DELIMITER

See Also:

Constant Field Values

KEY_ELEMENT_DELIMITER

public static final java.lang.String KEY_ELEMENT_DELIMITER

See Also:

Constant Field Values

invalidationEventRegExpPattern

public java.util.regex.Pattern invalidationEventRegExpPattern

KIND_INVALIDATION

public static final int KIND_INVALIDATION

See Also:

Constant Field Values

Constructor Detail

InvalidationBroadcastHandler

public InvalidationBroadcastHandler(BroadcastService broadcastService)

Method Detail

getInstance

public static InvalidationBroadcastHandler getInstance()

sendMessage

public void sendMessage(Tenant tenant,
                        java.lang.Object[] topic,
                        java.lang.Object[] key,
                        int invalidationType)

processMessage

public boolean processMessage(RawMessage message)

Specified by:

processMessage in interface BroadcastMessageListener

processInvalidation

protected void processInvalidation(InvalidationBroadcastHandler.InvalidationEvent event,
                                   RawMessage message)

toBinaryMessage

protected byte[] toBinaryMessage(Tenant tenant,
                                 java.lang.Object[] topic,
                                 java.lang.Object[] key,
                                 int invalidationType,
                                 long number)

getInvalidationEventPattern

protected java.util.regex.Pattern getInvalidationEventPattern()

stringToObject

protected java.lang.Object stringToObject(java.lang.String string)

objectToString

protected java.lang.String objectToString(java.lang.Object object)

destroy

public void destroy()