Class StompCommonClient

    • Field Detail

      • DEFAULT_REQUEST_QUEUE

        public static final java.lang.String DEFAULT_REQUEST_QUEUE
        See Also:
        Constant Field Values
      • DEFAULT_RESPONSE_QUEUE

        public static final java.lang.String DEFAULT_RESPONSE_QUEUE
        See Also:
        Constant Field Values
      • headerBuffer

        protected java.nio.ByteBuffer headerBuffer
      • message

        protected Message message
      • connected

        protected java.util.concurrent.CountDownLatch connected
      • subscribed

        protected java.util.concurrent.CountDownLatch subscribed
      • subscriptionIds

        protected java.util.List<java.lang.String> subscriptionIds
    • Constructor Detail

      • StompCommonClient

        public StompCommonClient​(Reactor reactor,
                                 java.lang.String hostname,
                                 int port)
    • Method Detail

      • send

        public void send​(byte[] message)
      • sendNow

        public void sendNow​(byte[] message)
      • close

        public java.util.concurrent.Future<java.lang.Void> close()
        Overrides:
        close in class ReactorClient
      • emitOnMessageReceived

        protected void emitOnMessageReceived​(Message message)
      • buildNetworkResponse

        protected byte[] buildNetworkResponse​(java.lang.String reason)
        Description copied from class: ReactorClient
        Builds network issue message for specific protocol.
        Specified by:
        buildNetworkResponse in class ReactorClient
        Parameters:
        reason - why we want to build network response.
        Returns:
        byte array containing response.
      • updatePolicyWithHeartbeat

        public void updatePolicyWithHeartbeat​(java.lang.String heartbeat,
                                              boolean client)
      • sendHeartbeat

        protected void sendHeartbeat()
        Description copied from class: ReactorClient
        Client sends protocol specific heartbeat message
        Specified by:
        sendHeartbeat in class ReactorClient
      • getRequestQueue

        public java.lang.String getRequestQueue()
      • getResponseQueue

        public java.lang.String getResponseQueue()
      • getEventQueue

        public java.lang.String getEventQueue()