de.hybris.platform.cluster

Class DefaultBroadcastServiceConfiguration

java.lang.Object

de.hybris.platform.cluster.DefaultBroadcastServiceConfiguration

All Implemented Interfaces:

BroadcastServiceConfiguration

public class DefaultBroadcastServiceConfiguration
extends java.lang.Object
implements BroadcastServiceConfiguration

Default configuration to be used for DefaultBroadcastService.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	CFG_MESSAGE_KEYCACHE_SIZE
static java.lang.String	CFG_METHOD_PREFIX
static java.lang.String	CFG_METHODS
static java.lang.String	CFG_SENDER_THREADS_DISABLE
static java.lang.String	CFG_SENDER_THREADS_KEEPALIVE
static java.lang.String	CFG_SENDER_THREADS_MAX
static java.lang.String	CFG_SENDER_THREADS_MAXWAIT
static java.lang.String	CFG_SENDER_THREADS_MIN
static java.lang.String	CFG_SENDER_THREADS_QUEUE_FAIRNESS
static java.lang.String	CFG_SENDER_THREADS_QUEUESIZE
static java.lang.String	CFG_SENDER_THREADS_WAITDELAY
static java.lang.String	CFG_START_PING_ON_TENANT_STARTUP
static java.lang.String	DEFAULT_METHODS
static int	MESSAGE_QUEUE_SIZE The default asynchronous message sending queue size.
static int	MESSAGE_QUEUE_WAIT_TIME The time to wait before trying to put message into sender queue again.
static long	MESSAGE_SENDING_TIMEOUT the time a thread will try to place his message into message sending queue before we raise a exception.
static int	MESSAGE_THREADS_KEEPALIVE The default time before a unused message thread is removed.
static int	MESSAGE_THREADS_MAX The default max amount of message sending threads to create.
static int	MESSAGE_THREADS_MIN The default min amount of message sending threads to keep active.

Constructor Summary

Constructors

Constructor and Description
DefaultBroadcastServiceConfiguration()

Method Summary

Modifier and Type	Method and Description
boolean	enableAsynchonousSending()
boolean	enableClusterMode()
long	getClusterIslandID()
int	getConfiguredNodeID()
long	getDynamicNodeID()
int	getMessageKeyCacheSize()
long	getMessageSendingMaxWait()
boolean	getMessageSendingQueueFairness()
int	getMessageSendingQueueSize()
int	getMessageSendingWaitDelay()
java.util.Map<java.lang.String,java.lang.Class>	getMethods()
int	getSenderMaxThreads()
int	getSenderMinThreads()
int	getSenderThreadsKeepAlive()
protected java.util.Map<java.lang.String,java.lang.Class>	loadMethods(ConfigIntf cfg)
void	setAsynchonousSending(boolean enabled)
void	setClusterIslandID(long id)
void	setClusterMode(boolean enabled)
void	setConfiguredNodeID(int id)
void	setDynamicNodeID(long id)
void	setMessageKeyCacheSize(int size)
void	setMessageSendingMaxWait(long milliseconds)
void	setMessageSendingQueueFairness(boolean fair)
void	setMessageSendingQueueSize(int size)
void	setMessageSendingWaitDelay(int milliseconds)
void	setMethods(java.util.Map<java.lang.String,java.lang.Class> methodClassMap)
void	setSenderMaxThreads(int maxThreads)
void	setSenderMinThreads(int minThreads)
void	setSenderThreadsKeepAlive(int milliseconds)
boolean	startPingOnTenantStartup()

Methods inherited from class java.lang.Object

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

Field Detail

CFG_METHODS

public static java.lang.String CFG_METHODS

CFG_METHOD_PREFIX

public static java.lang.String CFG_METHOD_PREFIX

CFG_SENDER_THREADS_MIN

public static java.lang.String CFG_SENDER_THREADS_MIN

CFG_SENDER_THREADS_MAX

public static java.lang.String CFG_SENDER_THREADS_MAX

CFG_SENDER_THREADS_KEEPALIVE

public static java.lang.String CFG_SENDER_THREADS_KEEPALIVE

CFG_SENDER_THREADS_QUEUESIZE

public static java.lang.String CFG_SENDER_THREADS_QUEUESIZE

CFG_SENDER_THREADS_QUEUE_FAIRNESS

public static java.lang.String CFG_SENDER_THREADS_QUEUE_FAIRNESS

CFG_SENDER_THREADS_MAXWAIT

public static java.lang.String CFG_SENDER_THREADS_MAXWAIT

CFG_SENDER_THREADS_WAITDELAY

public static java.lang.String CFG_SENDER_THREADS_WAITDELAY

CFG_SENDER_THREADS_DISABLE

public static java.lang.String CFG_SENDER_THREADS_DISABLE

CFG_START_PING_ON_TENANT_STARTUP

public static java.lang.String CFG_START_PING_ON_TENANT_STARTUP

CFG_MESSAGE_KEYCACHE_SIZE

public static java.lang.String CFG_MESSAGE_KEYCACHE_SIZE

DEFAULT_METHODS

public static java.lang.String DEFAULT_METHODS

MESSAGE_SENDING_TIMEOUT

public static final long MESSAGE_SENDING_TIMEOUT

the time a thread will try to place his message into message sending queue before we raise a exception. (seconds)

See Also:

Constant Field Values

MESSAGE_QUEUE_WAIT_TIME

public static final int MESSAGE_QUEUE_WAIT_TIME

The time to wait before trying to put message into sender queue again. (milliseconds)

See Also:

Constant Field Values

MESSAGE_QUEUE_SIZE

public static final int MESSAGE_QUEUE_SIZE

The default asynchronous message sending queue size.

See Also:

Constant Field Values

MESSAGE_THREADS_MIN

public static final int MESSAGE_THREADS_MIN

The default min amount of message sending threads to keep active.

See Also:

Constant Field Values

MESSAGE_THREADS_MAX

public static final int MESSAGE_THREADS_MAX

The default max amount of message sending threads to create.

See Also:

Constant Field Values

MESSAGE_THREADS_KEEPALIVE

public static final int MESSAGE_THREADS_KEEPALIVE

The default time before a unused message thread is removed. (seconds)

See Also:

Constant Field Values

Constructor Detail

DefaultBroadcastServiceConfiguration

public DefaultBroadcastServiceConfiguration()

Method Detail

loadMethods

protected java.util.Map<java.lang.String,java.lang.Class> loadMethods(ConfigIntf cfg)

enableAsynchonousSending

public boolean enableAsynchonousSending()

Specified by:

enableAsynchonousSending in interface BroadcastServiceConfiguration

setAsynchonousSending

public void setAsynchonousSending(boolean enabled)

enableClusterMode

public boolean enableClusterMode()

Specified by:

enableClusterMode in interface BroadcastServiceConfiguration

setClusterMode

public void setClusterMode(boolean enabled)

getConfiguredNodeID

public int getConfiguredNodeID()

Specified by:

getConfiguredNodeID in interface BroadcastServiceConfiguration

setConfiguredNodeID

public void setConfiguredNodeID(int id)

getClusterIslandID

public long getClusterIslandID()

Specified by:

getClusterIslandID in interface BroadcastServiceConfiguration

setClusterIslandID

public void setClusterIslandID(long id)

getDynamicNodeID

public long getDynamicNodeID()

Specified by:

getDynamicNodeID in interface BroadcastServiceConfiguration

setDynamicNodeID

public void setDynamicNodeID(long id)

getMessageKeyCacheSize

public int getMessageKeyCacheSize()

Specified by:

getMessageKeyCacheSize in interface BroadcastServiceConfiguration

setMessageKeyCacheSize

public void setMessageKeyCacheSize(int size)

getMessageSendingMaxWait

public long getMessageSendingMaxWait()

Specified by:

getMessageSendingMaxWait in interface BroadcastServiceConfiguration

setMessageSendingMaxWait

public void setMessageSendingMaxWait(long milliseconds)

getMessageSendingQueueSize

public int getMessageSendingQueueSize()

Specified by:

getMessageSendingQueueSize in interface BroadcastServiceConfiguration

setMessageSendingQueueSize

public void setMessageSendingQueueSize(int size)

getMessageSendingQueueFairness

public boolean getMessageSendingQueueFairness()

Specified by:

getMessageSendingQueueFairness in interface BroadcastServiceConfiguration

setMessageSendingQueueFairness

public void setMessageSendingQueueFairness(boolean fair)

getMessageSendingWaitDelay

public int getMessageSendingWaitDelay()

Specified by:

getMessageSendingWaitDelay in interface BroadcastServiceConfiguration

setMessageSendingWaitDelay

public void setMessageSendingWaitDelay(int milliseconds)

getMethods

public java.util.Map<java.lang.String,java.lang.Class> getMethods()

Specified by:

getMethods in interface BroadcastServiceConfiguration

setMethods

public void setMethods(java.util.Map<java.lang.String,java.lang.Class> methodClassMap)

getSenderMaxThreads

public int getSenderMaxThreads()

Specified by:

getSenderMaxThreads in interface BroadcastServiceConfiguration

setSenderMaxThreads

public void setSenderMaxThreads(int maxThreads)

getSenderMinThreads

public int getSenderMinThreads()

Specified by:

getSenderMinThreads in interface BroadcastServiceConfiguration

setSenderMinThreads

public void setSenderMinThreads(int minThreads)

getSenderThreadsKeepAlive

public int getSenderThreadsKeepAlive()

Specified by:

getSenderThreadsKeepAlive in interface BroadcastServiceConfiguration

setSenderThreadsKeepAlive

public void setSenderThreadsKeepAlive(int milliseconds)

startPingOnTenantStartup

public boolean startPingOnTenantStartup()

Specified by:

startPingOnTenantStartup in interface BroadcastServiceConfiguration