Interface NetworkConnection

    • Method Detail

      • connect

        void connect​(int priority,
                     NetworkConnection.ConnectionListener listener)
        Connect this connection's transport, i.e. establish the network connection. If this connection is already established (from an incoming connection for example), then this provides a mechanism to register the connection listener, in which case connectSuccess() will be called immediately.
        Parameters:
        listener - notified on connect success or failure
      • close

        void close​(java.lang.String reason)
        Close and shutdown this connection.
      • startMessageProcessing

        void startMessageProcessing()
        Begin processing incoming and outgoing message queues.
        Parameters:
        upload_group - upload rate limit group to use
        download_group - download rate limit group to use
      • enableEnhancedMessageProcessing

        void enableEnhancedMessageProcessing​(boolean enable,
                                             int partition_id)
        Upgrade the connection to high-speed transfer processing.
        Parameters:
        enable - true for high-speed processing, false for normal processing
      • detachTransport

        Transport detachTransport()
        Decouples the transport from this network connection so it can be reused
        Returns:
        null if detach failed
      • getTransport

        Transport getTransport()
        Get the connection's data transport interface.
        Returns:
        the transport - MAY BE NULL if not yet fully connected
      • isConnected

        boolean isConnected()
      • setUserData

        java.lang.Object setUserData​(java.lang.Object key,
                                     java.lang.Object value)
      • getUserData

        java.lang.Object getUserData​(java.lang.Object key)