Package deltix.util.vsocket

Class VSDispatcher

  • All Implemented Interfaces:
    deltix.util.lang.Disposable, java.io.Closeable, java.lang.AutoCloseable
    public final class VSDispatcher
extends java.lang.Object
implements deltix.util.lang.Disposable

    • Constructor Detail

      • VSDispatcher

        public VSDispatcher​(java.lang.String clientId,
                    boolean isClient,
                    ContextContainer contextContainer)
        Constructs a dispatcher instance for the specified client.

    • Method Detail

      • getThroughput

        public long getThroughput()
        Return current peak throughput (bytes per second)
        Returns:
        number of bytes per second

      • getAverageThroughput

        public double getAverageThroughput()
        Return average throughput (bytes per second)
        Returns:
        number of bytes per second

      • getReconnectInterval

        public int getReconnectInterval()

      • getApplicationID

        public java.lang.String getApplicationID()

      • setApplicationID

        public void setApplicationID​(java.lang.String applicationID)

      • setLingerInterval

        public void setLingerInterval​(int reconnectInterval)

      • getClientId

        public java.lang.String getClientId()

      • getCreationDate

        public java.util.Date getCreationDate()

      • getNumTransportChannels

        public int getNumTransportChannels()

      • hasTransportChannels

        public boolean hasTransportChannels()

      • hasAvailableTransport

        public boolean hasAvailableTransport()

      • addTransportChannel

        public void addTransportChannel​(VSocket socket)
                         throws java.io.IOException
        Throws:
        java.io.IOException

      • setConnectionListener

        public void setConnectionListener​(VSConnectionListener connectionListener)

      • setStateListener

        public void setStateListener​(deltix.util.vsocket.ConnectionStateListener stateListener)

      • closeTransport

        public void closeTransport()
                    throws java.io.IOException,
                           java.lang.InterruptedException
        Throws:
        java.io.IOException
        java.lang.InterruptedException

      • checkIn

        public void checkIn​(deltix.util.vsocket.VSTransportChannel tc)

      • close

        public void close​(boolean wait)

      • close

        public void close()
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface java.io.Closeable
        Specified by:
        close in interface deltix.util.lang.Disposable

      • getVirtualChannels

        public VSChannel[] getVirtualChannels()

      • getRemoteAddress

        public java.lang.String getRemoteAddress()

      • addDisposableListener

        public void addDisposableListener​(deltix.util.lang.DisposableListener listener)

      • removeDisposableListener

        public void removeDisposableListener​(deltix.util.lang.DisposableListener listener)

      • getQuickExecutor

        public deltix.util.concurrent.QuickExecutor getQuickExecutor()

      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object