Package de.hybris.platform.cluster

Class DefaultBroadcastServiceConfiguration

java.lang.Object

de.hybris.platform.cluster.DefaultBroadcastServiceConfiguration

All Implemented Interfaces:

BroadcastServiceConfiguration

public class DefaultBroadcastServiceConfiguration
extends Object
implements BroadcastServiceConfiguration

Default configuration to be used for DefaultBroadcastService.

Field Summary

Fields

Modifier and Type	Field	Description
static String	CFG_MESSAGE_KEYCACHE_SIZE
static String	CFG_METHOD_PREFIX
static String	CFG_METHODS
static String	CFG_SENDER_THREADS_DISABLE
static String	CFG_SENDER_THREADS_KEEPALIVE
static String	CFG_SENDER_THREADS_MAX
static String	CFG_SENDER_THREADS_MAXWAIT
static String	CFG_SENDER_THREADS_MIN
static String	CFG_SENDER_THREADS_QUEUE_FAIRNESS
static String	CFG_SENDER_THREADS_QUEUESIZE
static String	CFG_SENDER_THREADS_WAITDELAY
static String	CFG_START_PING_ON_TENANT_STARTUP
static String	DEFAULT_METHODS
static final int	MESSAGE_QUEUE_SIZE	The default asynchronous message sending queue size.
static final int	MESSAGE_QUEUE_WAIT_TIME	The time to wait before trying to put message into sender queue again.
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.
static final int	MESSAGE_THREADS_KEEPALIVE	The default time before a unused message thread is removed.
static final int	MESSAGE_THREADS_MAX	The default max amount of message sending threads to create.
static final int	MESSAGE_THREADS_MIN	The default min amount of message sending threads to keep active.

Constructor Summary

Constructors

Constructor	Description
DefaultBroadcastServiceConfiguration()

Method Summary

Modifier and Type	Method	Description
boolean	enableAsynchonousSending()
boolean	enableClusterMode()
long	getClusterIslandID()
int	getConfiguredNodeID()
long	getDynamicNodeID()
int	getMessageKeyCacheSize()
long	getMessageSendingMaxWait()
boolean	getMessageSendingQueueFairness()
int	getMessageSendingQueueSize()
int	getMessageSendingWaitDelay()
Map<String,Class>	getMethods()
int	getSenderMaxThreads()
int	getSenderMinThreads()
int	getSenderThreadsKeepAlive()
protected Map<String,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(Map<String,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 Details

CFG_METHODS

public static String CFG_METHODS

CFG_METHOD_PREFIX

public static String CFG_METHOD_PREFIX

CFG_SENDER_THREADS_MIN

public static String CFG_SENDER_THREADS_MIN

CFG_SENDER_THREADS_MAX

public static String CFG_SENDER_THREADS_MAX

CFG_SENDER_THREADS_KEEPALIVE

public static String CFG_SENDER_THREADS_KEEPALIVE

CFG_SENDER_THREADS_QUEUESIZE

public static String CFG_SENDER_THREADS_QUEUESIZE

CFG_SENDER_THREADS_QUEUE_FAIRNESS

public static String CFG_SENDER_THREADS_QUEUE_FAIRNESS

CFG_SENDER_THREADS_MAXWAIT

public static String CFG_SENDER_THREADS_MAXWAIT

CFG_SENDER_THREADS_WAITDELAY

public static String CFG_SENDER_THREADS_WAITDELAY

CFG_SENDER_THREADS_DISABLE

public static String CFG_SENDER_THREADS_DISABLE

CFG_START_PING_ON_TENANT_STARTUP

public static String CFG_START_PING_ON_TENANT_STARTUP

CFG_MESSAGE_KEYCACHE_SIZE

public static String CFG_MESSAGE_KEYCACHE_SIZE

DEFAULT_METHODS

public static 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 Details

DefaultBroadcastServiceConfiguration

public DefaultBroadcastServiceConfiguration()

Method Details

loadMethods

protected Map<String,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 Map<String,Class> getMethods()

Specified by:

getMethods in interface BroadcastServiceConfiguration

setMethods

public void setMethods(Map<String,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