@WebSocket
public class IIBCommandSocket
extends java.lang.Object
Constructor and Description |
---|
IIBCommandSocket(java.util.concurrent.LinkedBlockingQueue<byte[]> responseMessageQueue,
java.net.URI echoUri,
java.lang.String CMPSessionId) |
IIBCommandSocket(java.util.concurrent.LinkedBlockingQueue<byte[]> responseMessageQueue,
java.net.URI echoUri,
java.lang.String CMPSessionId,
java.util.Map<java.lang.String,java.lang.String> sslSettings) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
java.lang.Throwable |
getCloseCause() |
int |
getCloseCode() |
boolean |
isClosed() |
void |
onClose(org.eclipse.jetty.websocket.api.Session session,
int closeCode,
java.lang.String closeReason) |
void |
onConnect(org.eclipse.jetty.websocket.api.Session session) |
void |
onError(java.lang.Throwable cause) |
void |
onMessage(byte[] buf,
int offset,
int length) |
void |
onMessage(java.lang.String msg) |
void |
send(byte[] data) |
void |
setClosed(boolean closed) |
boolean |
waitForClose() |
boolean |
waitForConnectOrError(int timeout) |
public IIBCommandSocket(java.util.concurrent.LinkedBlockingQueue<byte[]> responseMessageQueue, java.net.URI echoUri, java.lang.String CMPSessionId) throws java.lang.Exception
java.lang.Exception
public IIBCommandSocket(java.util.concurrent.LinkedBlockingQueue<byte[]> responseMessageQueue, java.net.URI echoUri, java.lang.String CMPSessionId, java.util.Map<java.lang.String,java.lang.String> sslSettings) throws java.lang.Exception
java.lang.Exception
public boolean isClosed()
public void setClosed(boolean closed)
@OnWebSocketClose public void onClose(org.eclipse.jetty.websocket.api.Session session, int closeCode, java.lang.String closeReason)
@OnWebSocketConnect public void onConnect(org.eclipse.jetty.websocket.api.Session session)
@OnWebSocketMessage public void onMessage(java.lang.String msg)
@OnWebSocketMessage public void onMessage(byte[] buf, int offset, int length)
@OnWebSocketError public void onError(java.lang.Throwable cause)
public void send(byte[] data) throws java.io.IOException, ConfigManagerProxyLoggedException
java.io.IOException
ConfigManagerProxyLoggedException
public void close()
public boolean waitForConnectOrError(int timeout) throws java.lang.InterruptedException
java.lang.InterruptedException
public boolean waitForClose() throws java.lang.InterruptedException
java.lang.InterruptedException
public int getCloseCode()
public java.lang.Throwable getCloseCause()