org.apache.hedwig.client.conf

Class ClientConfiguration

java.lang.Object

org.apache.hedwig.conf.AbstractConfiguration

org.apache.hedwig.client.conf.ClientConfiguration

public class ClientConfiguration
extends org.apache.hedwig.conf.AbstractConfiguration

Field Summary

Fields

Modifier and Type	Field and Description
protected static String	AUTO_SEND_CONSUME_MESSAGE_ENABLED
protected static String	CONSUMED_MESSAGES_BUFFER_SIZE
protected static String	DEFAULT_SERVER_HOST
protected static String	MAX_MESSAGE_SIZE
protected static String	MAX_OUTSTANDING_MESSAGES
protected static String	MAX_SERVER_REDIRECTS
protected static String	MESSAGE_CONSUME_RETRY_WAIT_TIME
protected HedwigSocketAddress	myDefaultServerAddress
protected static String	SERVER_ACK_RESPONSE_TIMEOUT
protected static String	SSL_ENABLED
protected static String	SUBSCRIBE_RECONNECT_RETRY_WAIT_TIME
protected static String	SUBSCRIPTION_CHANNEL_SHARING_ENABLED
protected static String	SUBSCRIPTION_MESSAGE_BOUND
protected static String	TIMEOUT_THREAD_RUN_INTERVAL

Fields inherited from class org.apache.hedwig.conf.AbstractConfiguration

conf

Constructor Summary

Constructors

Constructor and Description
ClientConfiguration()

Method Summary

Modifier and Type	Method and Description
int	getConsumedMessagesBufferSize()
protected HedwigSocketAddress	getDefaultServerHedwigSocketAddress()
InetSocketAddress	getDefaultServerHost()
int	getMaximumMessageSize()
int	getMaximumOutstandingMessages()
int	getMaximumServerRedirects()
long	getMessageConsumeRetryWaitTime()
long	getServerAckResponseTimeout()
long	getSubscribeReconnectRetryWaitTime()
int	getSubscriptionMessageBound() The maximum number of messages the hub will queue for subscriptions created using this configuration.
long	getTimeoutThreadRunInterval()
boolean	isAutoSendConsumeMessageEnabled()
boolean	isSSLEnabled()
boolean	isSubscriptionChannelSharingEnabled() This parameter is a boolean flag indicating if multiplexing subscription channels.
void	validate()

Methods inherited from class org.apache.hedwig.conf.AbstractConfiguration

addConf, getConf, loadConf

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_SERVER_HOST

protected static final String DEFAULT_SERVER_HOST

See Also:

Constant Field Values

MAX_MESSAGE_SIZE

protected static final String MAX_MESSAGE_SIZE

See Also:

Constant Field Values

MAX_SERVER_REDIRECTS

protected static final String MAX_SERVER_REDIRECTS

See Also:

Constant Field Values

AUTO_SEND_CONSUME_MESSAGE_ENABLED

protected static final String AUTO_SEND_CONSUME_MESSAGE_ENABLED

See Also:

Constant Field Values

CONSUMED_MESSAGES_BUFFER_SIZE

protected static final String CONSUMED_MESSAGES_BUFFER_SIZE

See Also:

Constant Field Values

MESSAGE_CONSUME_RETRY_WAIT_TIME

protected static final String MESSAGE_CONSUME_RETRY_WAIT_TIME

See Also:

Constant Field Values

SUBSCRIBE_RECONNECT_RETRY_WAIT_TIME

protected static final String SUBSCRIBE_RECONNECT_RETRY_WAIT_TIME

See Also:

Constant Field Values

MAX_OUTSTANDING_MESSAGES

protected static final String MAX_OUTSTANDING_MESSAGES

See Also:

Constant Field Values

SERVER_ACK_RESPONSE_TIMEOUT

protected static final String SERVER_ACK_RESPONSE_TIMEOUT

See Also:

Constant Field Values

TIMEOUT_THREAD_RUN_INTERVAL

protected static final String TIMEOUT_THREAD_RUN_INTERVAL

See Also:

Constant Field Values

SSL_ENABLED

protected static final String SSL_ENABLED

See Also:

Constant Field Values

SUBSCRIPTION_MESSAGE_BOUND

protected static final String SUBSCRIPTION_MESSAGE_BOUND

See Also:

Constant Field Values

SUBSCRIPTION_CHANNEL_SHARING_ENABLED

protected static final String SUBSCRIPTION_CHANNEL_SHARING_ENABLED

See Also:

Constant Field Values

myDefaultServerAddress

protected HedwigSocketAddress myDefaultServerAddress

Constructor Detail

ClientConfiguration

public ClientConfiguration()

Method Detail

getDefaultServerHedwigSocketAddress

protected HedwigSocketAddress getDefaultServerHedwigSocketAddress()

getDefaultServerHost

public InetSocketAddress getDefaultServerHost()

getMaximumMessageSize

public int getMaximumMessageSize()

getMaximumServerRedirects

public int getMaximumServerRedirects()

isAutoSendConsumeMessageEnabled

public boolean isAutoSendConsumeMessageEnabled()

getConsumedMessagesBufferSize

public int getConsumedMessagesBufferSize()

getMessageConsumeRetryWaitTime

public long getMessageConsumeRetryWaitTime()

getSubscribeReconnectRetryWaitTime

public long getSubscribeReconnectRetryWaitTime()

getMaximumOutstandingMessages

public int getMaximumOutstandingMessages()

getServerAckResponseTimeout

public long getServerAckResponseTimeout()

getTimeoutThreadRunInterval

public long getTimeoutThreadRunInterval()

isSSLEnabled

public boolean isSSLEnabled()

isSubscriptionChannelSharingEnabled

public boolean isSubscriptionChannelSharingEnabled()

This parameter is a boolean flag indicating if multiplexing subscription channels.

getSubscriptionMessageBound

public int getSubscriptionMessageBound()

The maximum number of messages the hub will queue for subscriptions created using this configuration. The hub will always queue the most recent messages. If there are enough publishes to the topic to hit the bound, then the oldest messages are dropped from the queue. A bound of 0 disabled the bound completely. This is the default.

validate

public void validate()
              throws org.apache.commons.configuration.ConfigurationException

Throws:

org.apache.commons.configuration.ConfigurationException