com.ibm.broker.config.proxy

Class IIBCommandSocket

  • java.lang.Object
    • com.ibm.broker.config.proxy.IIBCommandSocket


  • @WebSocket
    public class IIBCommandSocket
    extends java.lang.Object
    • Constructor Summary

      Constructors 
      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) 
    • Constructor Detail

      • IIBCommandSocket

        public IIBCommandSocket(java.util.concurrent.LinkedBlockingQueue<byte[]> responseMessageQueue,
                                java.net.URI echoUri,
                                java.lang.String CMPSessionId)
                         throws java.lang.Exception
        Throws:
        java.lang.Exception
      • IIBCommandSocket

        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
        Throws:
        java.lang.Exception
    • Method Detail

      • isClosed

        public boolean isClosed()
      • setClosed

        public void setClosed(boolean closed)
      • onClose

        @OnWebSocketClose
        public void onClose(org.eclipse.jetty.websocket.api.Session session,
                                              int closeCode,
                                              java.lang.String closeReason)
      • onConnect

        @OnWebSocketConnect
        public void onConnect(org.eclipse.jetty.websocket.api.Session session)
      • onMessage

        @OnWebSocketMessage
        public void onMessage(java.lang.String msg)
      • onMessage

        @OnWebSocketMessage
        public void onMessage(byte[] buf,
                                                  int offset,
                                                  int length)
      • onError

        @OnWebSocketError
        public void onError(java.lang.Throwable cause)
      • close

        public void close()
      • waitForConnectOrError

        public boolean waitForConnectOrError(int timeout)
                                      throws java.lang.InterruptedException
        Throws:
        java.lang.InterruptedException
      • waitForClose

        public boolean waitForClose()
                             throws java.lang.InterruptedException
        Throws:
        java.lang.InterruptedException
      • getCloseCode

        public int getCloseCode()
      • getCloseCause

        public java.lang.Throwable getCloseCause()