Package 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	Description
protected static class	InvalidationBroadcastHandler.InvalidationEvent

Field Summary

Fields

Modifier and Type	Field	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	Description
InvalidationBroadcastHandler(BroadcastService broadcastService)

Method Summary

Modifier and Type	Method	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()