public interface SessionAttributes
This encapsulates the basic attributes of a Session
. These attributes
may be set (unless default values are sufficient) on the
SessionFactory
used to create sessions.
Modifier and Type | Interface and Description |
---|---|
static class |
SessionAttributes.Transport
The transports available to Java clients.
|
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_CONNECTION_TIMEOUT
The default connection timeout = 2 seconds.
|
static int |
DEFAULT_INPUT_BUFFER_SIZE
The default size of socket and message input buffers in bytes.
|
static int |
DEFAULT_MAXIMUM_MESSAGE_SIZE
The default maximum message size in bytes.
|
static int |
DEFAULT_MAXIMUM_QUEUE_SIZE
The default maximum outbound queue size in messages.
|
static int |
DEFAULT_OUTPUT_BUFFER_SIZE
The default size of socket and message output buffers in bytes.
|
static int |
DEFAULT_RECONNECTION_TIMEOUT
The default reconnection timeout = 60 seconds.
|
static int |
DEFAULT_RECOVERY_BUFFER_SIZE
The default recovery buffer size in messages.
|
static String |
DEFAULT_REQUEST_PATH
The default request path.
|
static int |
DEFAULT_WRITE_TIMEOUT
The default write timeout for blocking writes = 2 seconds.
|
static int |
MAXIMUM_MESSAGE_SIZE_MIN
The minimum value that the maximum message size can be set to in bytes.
|
Modifier and Type | Method and Description |
---|---|
int |
getConnectionTimeout()
Returns the connection timeout value.
|
HTTPProxyAuthentication |
getHttpProxyAuth()
Returns the proxy authenticator used to route a connection to the server
via an HTTP proxy.
|
String |
getHttpProxyHost()
Returns the proxy host name used to route a connection to the server via
an HTTP proxy.
|
int |
getHttpProxyPort()
Returns the proxy port used to route a connection to the server via an
HTTP proxy.
|
RetryStrategy |
getInitialRetryStrategy()
Returns the initial retry strategy.
|
int |
getInputBufferSize()
Returns the input buffer size for socket connection buffers and message
receiving buffers.
|
SocketAddress |
getLocalSocketAddress()
Returns the local socket address.
|
int |
getMaximumMessageSize()
Returns the maximum message size that will be accepted by this session.
|
int |
getMaximumQueueSize()
Returns the maximum size of the outbound message queue for the
connection.
|
int |
getOutputBufferSize()
Returns the output buffer size for socket connection buffers and message
sending buffers.
|
ReconnectionStrategy |
getReconnectionStrategy()
Returns the reconnection strategy.
|
int |
getReconnectionTimeout()
Returns the reconnection timeout.
|
int |
getRecoveryBufferSize()
Returns the maximum number of sent messages that can be recovered on
reconnection.
|
List<SessionAttributes.Transport> |
getRequestedTransports()
Returns the transports the session will use to connect to the server.
|
String |
getRequestPath()
Returns the path used for any HTTP requests made by the session.
|
String |
getServerHost()
Returns the host name or IP of the server the session will connect to.
|
int |
getServerPort()
Returns the port of the server the session will connect to.
|
String |
getServerURL()
Returns the URL used to create the session.
|
SSLContext |
getSslContext()
Returns the SSL context for secure connections.
|
int |
getWriteTimeout()
Returns the write timeout value.
|
boolean |
isTransportSecure()
Indicates whether the session will use transport layer security to
connect to Diffusion.
|
static final int DEFAULT_CONNECTION_TIMEOUT
static final int DEFAULT_RECONNECTION_TIMEOUT
static final int DEFAULT_WRITE_TIMEOUT
static final int DEFAULT_MAXIMUM_MESSAGE_SIZE
Integer.MAX_VALUE
, so the message size is effectively
unlimited.static final int MAXIMUM_MESSAGE_SIZE_MIN
static final int DEFAULT_INPUT_BUFFER_SIZE
static final int DEFAULT_OUTPUT_BUFFER_SIZE
static final int DEFAULT_RECOVERY_BUFFER_SIZE
static final int DEFAULT_MAXIMUM_QUEUE_SIZE
static final String DEFAULT_REQUEST_PATH
String getServerURL()
int getConnectionTimeout()
#connectionTimeout(int)
int getInputBufferSize()
SessionFactory.inputBufferSize(int)
int getOutputBufferSize()
SessionFactory.outputBufferSize(int)
int getWriteTimeout()
SessionFactory.writeTimeout(int)
RetryStrategy getInitialRetryStrategy()
SessionFactory.initialRetryStrategy(RetryStrategy)
ReconnectionStrategy getReconnectionStrategy()
SessionFactory.reconnectionStrategy(ReconnectionStrategy)
int getReconnectionTimeout()
SessionFactory.reconnectionTimeout(int)
SocketAddress getLocalSocketAddress()
SessionFactory.localSocketAddress(SocketAddress)
SSLContext getSslContext()
SessionFactory.sslContext(SSLContext)
int getMaximumMessageSize()
SessionFactory.maximumMessageSize(int)
String getHttpProxyHost()
SessionFactory.httpProxy(String, int)
int getHttpProxyPort()
SessionFactory.httpProxy(String, int)
HTTPProxyAuthentication getHttpProxyAuth()
SessionFactory.httpProxy(String, int, HTTPProxyAuthentication)
String getServerHost()
SessionFactory.serverHost(String)
int getServerPort()
SessionFactory.serverPort(int)
List<SessionAttributes.Transport> getRequestedTransports()
SessionFactory.transports(com.pushtechnology.diffusion.client.session.SessionAttributes.Transport...)
boolean isTransportSecure()
SessionFactory.secureTransport(boolean)
String getRequestPath()
SessionFactory.requestPath(String)
int getRecoveryBufferSize()
SessionFactory.recoveryBufferSize(int)
int getMaximumQueueSize()
SessionFactory.maximumQueueSize(int)
Copyright © 2024 DiffusionData Ltd. All Rights Reserved.