com.ibm.broker.config.proxy

Class WebSocketSender

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


  • public class WebSocketSender
    extends java.lang.Object
    • Constructor Summary

      Constructors 
      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) 
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method and Description
      void disconnect()
      Gives the Sender the opportunity to close down cleanly.
      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'.
      • Methods inherited from class java.lang.Object

        equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • WebSocketSender

        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
        Throws:
        ConfigManagerProxyLoggedException
    • Method Detail

      • getMessageQueue

        public java.util.concurrent.LinkedBlockingQueue<byte[]> getMessageQueue()
      • disconnect

        public void disconnect()
        Gives the Sender the opportunity to close down cleanly.
      • send

        public void send(byte[] data)
                  throws ConfigManagerProxyLoggedException
        Sends the supplied data to the broker 'immediately'. This may involve (re)initialising the implementor's connection to the broker.
        Parameters:
        data - the data to be sent to the broker.
        Throws:
        ConfigManagerProxyLoggedException - if the data could not be sent for whatever reason.
      • send

        public void send(byte[] data,
                         boolean replyRequired)
                  throws ConfigManagerProxyLoggedException
        Sends the supplied data to the broker 'immediately'. This may involve (re)initialising the implementor's connection to the broker.
        Parameters:
        data - the data to be sent to the broker.
        replyRequired - true if and only if a reply to the message is required.
        Throws:
        ConfigManagerProxyLoggedException - if the data could not be sent for whatever reason.