Package org.mases.datadistributionmanager

Class CommonConfiguration

java.lang.Object

org.mases.datadistributionmanager.BaseConfiguration

org.mases.datadistributionmanager.GlobalConfiguration

org.mases.datadistributionmanager.CommonConfiguration

All Implemented Interfaces:

IConfiguration

Direct Known Subclasses:

KafkaConfiguration, MastershipConfiguration, OpenDDSConfiguration

public abstract class CommonConfiguration
extends GlobalConfiguration

The common configuration class

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	ChannelSeekTimeoutKey
static java.lang.String	CommitSyncKey
static java.lang.String	CommitTimeoutKey
static java.lang.String	ConsumerTimeoutKey
static java.lang.String	CreateChannelTimeoutKey
static java.lang.String	EventSyncKey
static java.lang.String	InitialOffsetKey
static java.lang.String	KeepAliveTimeoutKey
static java.lang.String	ProducerTimeoutKey
static java.lang.String	ReceiveTimeoutKey

Fields inherited from class org.mases.datadistributionmanager.GlobalConfiguration

GlobalLogLevelKey, MastershipLibraryKey, MaxMessageSizeKey, ProtocolKey, ProtocolLibraryKey, ServerLostTimeoutKey

Constructor Summary

Constructors

Constructor	Description
CommonConfiguration(java.lang.String protocol, java.lang.String protolib)	Initialize a new instance of CommonConfiguration
CommonConfiguration(IConfiguration originalConf)	Duplicates a configuration

Method Summary

Modifier and Type	Method	Description
java.lang.Integer	getChannelSeekTimeout()	The timeout on seek channel
boolean	getCommitSync()	True to commit message in sync
java.lang.Integer	getCommitTimeout()	The timeout on channel message commit
java.lang.Integer	getConsumerTimeout()	The timeout on channel message consume
java.lang.Integer	getCreateChannelTimeout()	The timeout on create channel
boolean	getEventSync()	True to emit message receive events in sync
java.lang.Long	getInitialOffset()	The initial offset of the channel
java.lang.Integer	getKeepAliveTimeout()	The timeout on channel keep alive
java.lang.Integer	getProducerTimeout()	The timeout on channel message produce
java.lang.Integer	getReceiveTimeout()	The timeout on channel receive
void	setChannelSeekTimeout(java.lang.Integer timeout)	The timeout on seek channel
void	setCommitSync(java.lang.Boolean value)	True to commit message in sync
void	setCommitTimeout(java.lang.Integer timeout)	The timeout on channel message commit
void	setConsumerTimeout(java.lang.Integer timeout)	The timeout on channel message consume
void	setCreateChannelTimeout(java.lang.Integer timeout)	The timeout on create channel
void	setEventSync(java.lang.Boolean value)	True to emit message receive events in sync
void	setInitialOffset(java.lang.Long offset)	The initial offset of the channel
void	setKeepAliveTimeout(java.lang.Integer timeout)	The timeout on channel keep alive
void	setProducerTimeout(java.lang.Integer timeout)	The timeout on channel message produce
void	setReceiveTimeout(java.lang.Integer timeout)	The timeout on channel receive

Methods inherited from class org.mases.datadistributionmanager.GlobalConfiguration

getGlobalLogLevel, getMastershipLibrary, getMaxMessageSize, getProtocol, getProtocolLibrary, getServerLostTimeout, setGlobalLogLevel, setMastershipLibrary, setMaxMessageSize, setProtocol, setProtocolLibrary, setServerLostTimeout

Methods inherited from class org.mases.datadistributionmanager.BaseConfiguration

getConfiguration

Methods inherited from class java.lang.Object

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

Field Detail

CreateChannelTimeoutKey

public static final java.lang.String CreateChannelTimeoutKey

See Also:

Constant Field Values

ChannelSeekTimeoutKey

public static final java.lang.String ChannelSeekTimeoutKey

See Also:

Constant Field Values

ReceiveTimeoutKey

public static final java.lang.String ReceiveTimeoutKey

See Also:

Constant Field Values

KeepAliveTimeoutKey

public static final java.lang.String KeepAliveTimeoutKey

See Also:

Constant Field Values

ConsumerTimeoutKey

public static final java.lang.String ConsumerTimeoutKey

See Also:

Constant Field Values

ProducerTimeoutKey

public static final java.lang.String ProducerTimeoutKey

See Also:

Constant Field Values

CommitTimeoutKey

public static final java.lang.String CommitTimeoutKey

See Also:

Constant Field Values

CommitSyncKey

public static final java.lang.String CommitSyncKey

See Also:

Constant Field Values

EventSyncKey

public static final java.lang.String EventSyncKey

See Also:

Constant Field Values

InitialOffsetKey

public static final java.lang.String InitialOffsetKey

See Also:

Constant Field Values

Constructor Detail

CommonConfiguration

public CommonConfiguration(java.lang.String protocol,
                           java.lang.String protolib)

Initialize a new instance of CommonConfiguration

Parameters:

protocol - The protocol to use

protolib - The protocol library to use

CommonConfiguration

public CommonConfiguration(IConfiguration originalConf)

Duplicates a configuration

Parameters:

originalConf - IConfiguration to duplicate

Method Detail

getCreateChannelTimeout

public java.lang.Integer getCreateChannelTimeout()

The timeout on create channel

Returns:

The create channel timeout in ms

setCreateChannelTimeout

public void setCreateChannelTimeout(java.lang.Integer timeout)

The timeout on create channel

Parameters:

timeout - The create channel timeout in ms

getChannelSeekTimeout

public java.lang.Integer getChannelSeekTimeout()

The timeout on seek channel

Returns:

The seek timeout in ms

setChannelSeekTimeout

public void setChannelSeekTimeout(java.lang.Integer timeout)

The timeout on seek channel

Parameters:

timeout - The seek timeout in ms

getReceiveTimeout

public java.lang.Integer getReceiveTimeout()

The timeout on channel receive

Returns:

The receive timeout in ms

setReceiveTimeout

public void setReceiveTimeout(java.lang.Integer timeout)

The timeout on channel receive

Parameters:

timeout - The receive timeout

getKeepAliveTimeout

public java.lang.Integer getKeepAliveTimeout()

The timeout on channel keep alive

Returns:

The keep-alive timeout in ms

setKeepAliveTimeout

public void setKeepAliveTimeout(java.lang.Integer timeout)

The timeout on channel keep alive

Parameters:

timeout - The keep-alive timeout in ms

getConsumerTimeout

public java.lang.Integer getConsumerTimeout()

The timeout on channel message consume

Returns:

The consumer timeout in ms

setConsumerTimeout

public void setConsumerTimeout(java.lang.Integer timeout)

The timeout on channel message consume

Parameters:

timeout - The consumer timeout in ms

getProducerTimeout

public java.lang.Integer getProducerTimeout()

The timeout on channel message produce

Returns:

The producer timeout in ms

setProducerTimeout

public void setProducerTimeout(java.lang.Integer timeout)

The timeout on channel message produce

Parameters:

timeout - The producer timeout in ms

getCommitTimeout

public java.lang.Integer getCommitTimeout()

The timeout on channel message commit

Returns:

The commit timeout in ms

setCommitTimeout

public void setCommitTimeout(java.lang.Integer timeout)

The timeout on channel message commit

Parameters:

timeout - The commit timeout in ms

getCommitSync

public boolean getCommitSync()

True to commit message in sync

Returns:

True to commit message in sync

setCommitSync

public void setCommitSync(java.lang.Boolean value)

True to commit message in sync

Parameters:

value - True to commit message in sync

getEventSync

public boolean getEventSync()

True to emit message receive events in sync

Returns:

True to emit message receive events in sync

setEventSync

public void setEventSync(java.lang.Boolean value)

True to emit message receive events in sync

Parameters:

value - True to emit message receive events in sync

getInitialOffset

public java.lang.Long getInitialOffset()

The initial offset of the channel

Returns:

The initial offset of the channel

setInitialOffset

public void setInitialOffset(java.lang.Long offset)

The initial offset of the channel

Parameters:

offset - The initial offset of the channel