public class WebSocketSender
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected static java.lang.String |
copyright
IBM Copyright
|
Constructor and Description |
---|
WebSocketSender(java.lang.String ip,
int port,
java.lang.String userName,
java.lang.String password,
boolean localConnection,
boolean useSSL,
java.lang.String brokerName,
int maxRetries,
int retryWaitMillis,
java.util.Map<java.lang.String,java.lang.String> jettySSLSettings) |
Modifier and Type | Method and Description |
---|---|
void |
disconnect()
Gives the Sender the opportunity to close down cleanly.
|
protected void |
finalize() |
java.util.concurrent.LinkedBlockingQueue<byte[]> |
getMessageQueue() |
void |
send(byte[] data)
Sends the supplied data to the broker 'immediately'.
|
void |
send(byte[] data,
boolean replyRequired)
Sends the supplied data to the broker 'immediately'.
|
protected static final java.lang.String copyright
public WebSocketSender(java.lang.String ip, int port, java.lang.String userName, java.lang.String password, boolean localConnection, boolean useSSL, java.lang.String brokerName, int maxRetries, int retryWaitMillis, java.util.Map<java.lang.String,java.lang.String> jettySSLSettings) throws ConfigManagerProxyLoggedException
public java.util.concurrent.LinkedBlockingQueue<byte[]> getMessageQueue()
public void disconnect()
public void send(byte[] data) throws ConfigManagerProxyLoggedException
data
- the data to be sent to the broker.ConfigManagerProxyLoggedException
- if the data could
not be sent for whatever reason.public void send(byte[] data, boolean replyRequired) throws ConfigManagerProxyLoggedException
data
- the data to be sent to the broker.replyRequired
- true if and only if a reply to the message
is required.ConfigManagerProxyLoggedException
- if the data could not
be sent for whatever reason.protected void finalize() throws java.lang.Throwable
finalize
in class java.lang.Object
java.lang.Throwable