public class ClientConfiguration
extends org.apache.hedwig.conf.AbstractConfiguration
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 |
Constructor and Description |
---|
ClientConfiguration() |
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() |
protected static final String DEFAULT_SERVER_HOST
protected static final String MAX_MESSAGE_SIZE
protected static final String MAX_SERVER_REDIRECTS
protected static final String AUTO_SEND_CONSUME_MESSAGE_ENABLED
protected static final String CONSUMED_MESSAGES_BUFFER_SIZE
protected static final String MESSAGE_CONSUME_RETRY_WAIT_TIME
protected static final String SUBSCRIBE_RECONNECT_RETRY_WAIT_TIME
protected static final String MAX_OUTSTANDING_MESSAGES
protected static final String SERVER_ACK_RESPONSE_TIMEOUT
protected static final String TIMEOUT_THREAD_RUN_INTERVAL
protected static final String SSL_ENABLED
protected static final String SUBSCRIPTION_MESSAGE_BOUND
protected static final String SUBSCRIPTION_CHANNEL_SHARING_ENABLED
protected HedwigSocketAddress myDefaultServerAddress
protected HedwigSocketAddress getDefaultServerHedwigSocketAddress()
public InetSocketAddress getDefaultServerHost()
public int getMaximumMessageSize()
public int getMaximumServerRedirects()
public boolean isAutoSendConsumeMessageEnabled()
public int getConsumedMessagesBufferSize()
public long getMessageConsumeRetryWaitTime()
public long getSubscribeReconnectRetryWaitTime()
public int getMaximumOutstandingMessages()
public long getServerAckResponseTimeout()
public long getTimeoutThreadRunInterval()
public boolean isSSLEnabled()
public boolean isSubscriptionChannelSharingEnabled()
public int getSubscriptionMessageBound()
public void validate() throws org.apache.commons.configuration.ConfigurationException
org.apache.commons.configuration.ConfigurationException
Copyright © 2011-2014 The Apache Software Foundation. All Rights Reserved.