Class FanoutTransport

    • Constructor Detail

      • FanoutTransport

        public FanoutTransport()
    • Method Detail

      • getMinAckCount

        public int getMinAckCount()
      • setMinAckCount

        public void setMinAckCount​(int minAckCount)
      • getInitialReconnectDelay

        public long getInitialReconnectDelay()
      • setInitialReconnectDelay

        public void setInitialReconnectDelay​(long initialReconnectDelay)
      • getMaxReconnectDelay

        public long getMaxReconnectDelay()
      • setMaxReconnectDelay

        public void setMaxReconnectDelay​(long maxReconnectDelay)
      • getReconnectDelayExponent

        public long getReconnectDelayExponent()
      • setReconnectDelayExponent

        public void setReconnectDelayExponent​(long reconnectDelayExponent)
      • getMaxReconnectAttempts

        public int getMaxReconnectAttempts()
      • setMaxReconnectAttempts

        public void setMaxReconnectAttempts​(int maxReconnectAttempts)
      • asyncRequest

        public FutureResponse asyncRequest​(Object command,
                                           ResponseCallback responseCallback)
                                    throws IOException
        Description copied from interface: Transport
        An asynchronous request response where the Receipt will be returned in the future. If responseCallback is not null, then it will be called when the response has been completed.
        Specified by:
        asyncRequest in interface Transport
        responseCallback - TODO
        the FutureResponse
      • reconnect

        public void reconnect()
      • narrow

        public <T> T narrow​(Class<T> target)
        Specified by:
        narrow in interface Transport
        the target
      • isReconnectSupported

        public boolean isReconnectSupported()
        Specified by:
        isReconnectSupported in interface Transport
        true if reconnect is supported
      • isUpdateURIsSupported

        public boolean isUpdateURIsSupported()
        Specified by:
        isUpdateURIsSupported in interface Transport
        true if updating uris is supported
      • getRemoteAddress

        public String getRemoteAddress()
        Specified by:
        getRemoteAddress in interface Transport
        the remote address for this connection
      • transportListenerOnCommand

        protected void transportListenerOnCommand​(Command command)
      • isFaultTolerant

        public boolean isFaultTolerant()
        Description copied from interface: Transport
        Indicates if the transport can handle faults
        Specified by:
        isFaultTolerant in interface Transport
        true if fault tolerant
      • isFanOutQueues

        public boolean isFanOutQueues()
      • setFanOutQueues

        public void setFanOutQueues​(boolean fanOutQueues)
      • isDisposed

        public boolean isDisposed()
        Specified by:
        isDisposed in interface Transport
        true if the transport is disposed
      • isConnected

        public boolean isConnected()
        Specified by:
        isConnected in interface Transport
        true if the transport is connected
      • getReceiveCounter

        public int getReceiveCounter()
        Description copied from interface: Transport
        Returns a counter which gets incremented as data is read from the transport. It should only be used to determine if there is progress being made in reading the next command from the transport. The value may wrap into the negative numbers.
        Specified by:
        getReceiveCounter in interface Transport
        a counter which gets incremented as data is read from the transport.
      • setPeerCertificates

        public void setPeerCertificates​(X509Certificate[] certificates)
        Description copied from interface: Transport
        Sets the certificates provided by the connected peer.
        Specified by:
        setPeerCertificates in interface Transport
        certificates - the Certificates provided by the peer.
      • getWireFormat

        public WireFormat getWireFormat()
        Description copied from interface: Transport
        Retrieves the WireFormat instance associated with this Transport instance.
        Specified by:
        getWireFormat in interface Transport
        the WireFormat in use.