Package | Description |
---|---|
com.pushtechnology.diffusion.client |
Client API.
|
com.pushtechnology.diffusion.client.session |
Client API : Sessions.
|
Modifier and Type | Method and Description |
---|---|
SessionFactory |
Diffusion.Implementation.getSessionFactory() |
static SessionFactory |
Diffusion.sessions()
Returns the shared session factory.
|
Modifier and Type | Method and Description |
---|---|
SessionFactory |
SessionFactory.connectionTimeout(int timeout)
Sets the connection timeout.
|
SessionFactory |
SessionFactory.credentials(Credentials credentials)
Set credentials.
|
SessionFactory |
SessionFactory.customCredentials(byte[] bytes)
Set credentials of type
Credentials.Type.CUSTOM . |
SessionFactory |
SessionFactory.errorHandler(Session.ErrorHandler errorHandler)
Nominates an error handler for a session.
|
SessionFactory |
SessionFactory.httpProxy(String host,
int port)
Set the address of the HTTP Proxy that should be used to make connections
to the server.
|
SessionFactory |
SessionFactory.httpProxy(String host,
int port,
HTTPProxyAuthentication authentication)
A variant of
httpProxy(String, int) that provides authentication
details to the HTTP proxy. |
SessionFactory |
SessionFactory.initialRetryStrategy(RetryStrategy strategy)
Sets the initial retry strategy.
|
SessionFactory |
SessionFactory.inputBufferSize(int size)
Sets the input buffer size for socket connection buffers and message
receiving buffers.
|
SessionFactory |
SessionFactory.listener(Session.Listener listener)
Nominates a listener for session events from a session.
|
SessionFactory |
SessionFactory.localSocketAddress(SocketAddress address)
Set the optional local socket address, used prior to connection.
|
SessionFactory |
SessionFactory.maximumMessageSize(int size)
Set the maximum message size.
|
SessionFactory |
SessionFactory.maximumQueueSize(int size)
Sets the maximum size of the outbound message queue for the connection.
|
SessionFactory |
SessionFactory.noCredentials()
Set credentials to
Credentials.Type.NONE . |
SessionFactory |
SessionFactory.noReconnection()
Disable reconnection.
|
SessionFactory |
SessionFactory.outputBufferSize(int size)
Sets the output buffer size for socket connection buffers and message
sending buffers.
|
SessionFactory |
SessionFactory.password(String password)
Set credentials of type
Credentials.Type.PLAIN_PASSWORD . |
SessionFactory |
SessionFactory.principal(String principal)
Sets the security principal.
|
SessionFactory |
SessionFactory.properties(Map<String,String> properties)
Sets user-defined session property values.
|
SessionFactory |
SessionFactory.property(String key,
String value)
Sets a user-defined session property value.
|
SessionFactory |
SessionFactory.reconnectionStrategy(ReconnectionStrategy strategy)
Sets the reconnection strategy.
|
SessionFactory |
SessionFactory.reconnectionTimeout(int timeout)
Sets the reconnection timeout.
|
SessionFactory |
SessionFactory.recoveryBufferSize(int size)
Set the recovery buffer size.
|
SessionFactory |
SessionFactory.requestPath(String requestPath)
Set the path used for HTTP requests.
|
SessionFactory |
SessionFactory.secureTransport(boolean secureTransport)
Set if a secure transport should be used.
|
SessionFactory |
SessionFactory.serverHost(String host)
Set the host name of the server to connect the session to.
|
SessionFactory |
SessionFactory.serverPort(int port)
Set the port of the server to connect the session to.
|
SessionFactory |
SessionFactory.sslContext(SSLContext context)
Sets the SSL Context if a secure connection is required.
|
SessionFactory |
SessionFactory.transports(SessionAttributes.Transport... transports)
Set the transports to use to connect the session to the server.
|
SessionFactory |
SessionFactory.writeTimeout(int timeout)
Sets the write timeout value for blocking writes.
|
Copyright © 2024 DiffusionData Ltd. All Rights Reserved.