Package com.apama.engine

Class EngineConnection

    • Constructor Summary

      Constructors 
      Constructor Description
      EngineConnection​(java.lang.String host, int port, boolean disconnectSlow, ConnectMode connectMode, java.lang.String... channels)  
      EngineConnection​(java.lang.String host, int port, java.lang.String... channels)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      java.lang.String[] getChannels()
      Get the channels associated with this connection.
      ConnectMode getConnectMode()
      Get the connection mode associated with this connection.
      boolean getDisconnectSlow()
      Get the value of disconnectSlow flag associated with this connection.
      java.lang.String getHost()
      Get the host associated with this connection.
      int getPort()
      Get the port associated with this connection.
      java.lang.String toString()
      A string representation for diagnostics; may change in a future release.

      • Methods inherited from class java.lang.Object

        equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

    • Constructor Detail

      • EngineConnection

        public EngineConnection​(java.lang.String host,
                        int port,
                        java.lang.String... channels)
        Parameters:
        host - The remote host to connect to
        port - The remote port to connect to
        channels - The array of channels to connect to. May include the empty String to indicate the default channel. Must be non-null, and contain no null elements.

      • EngineConnection

        public EngineConnection​(java.lang.String host,
                        int port,
                        boolean disconnectSlow,
                        ConnectMode connectMode,
                        java.lang.String... channels)
        Parameters:
        host - The remote host to connect to
        port - The remote port to connect to
        disconnectSlow - Whether we should be disconnected if we don't keep up.
        connectMode - The connection mode to use. Set to LEGACY for single connection, all events delivered to the default channel. Set to PARALLEL for connection per channel and channel values passed through.
        channels - The array of channels to connect to. May include the empty String to indicate the default channel. Must be non-null, and contain no null elements.

    • Method Detail

      • getChannels

        public java.lang.String[] getChannels()
        Get the channels associated with this connection.
        Returns:
        The list of channels that the downstream component should listen to.

      • getHost

        public java.lang.String getHost()
        Get the host associated with this connection.
        Returns:
        The host of the upstream (even-sending) component

      • getPort

        public int getPort()
        Get the port associated with this connection.
        Returns:
        The port of the upstream (even-sending) component

      • getConnectMode

        public ConnectMode getConnectMode()
        Get the connection mode associated with this connection.
        Returns:
        The connection mode associated with this connection.

      • getDisconnectSlow

        public boolean getDisconnectSlow()
        Get the value of disconnectSlow flag associated with this connection.
        Returns:
        returns true if we should be disconnected if this connection is slow.

      • toString

        public java.lang.String toString()
        A string representation for diagnostics; may change in a future release.
        Overrides:
        toString in class java.lang.Object
        See Also:
        Object.toString()