Interface InputChannel

    • Method Detail

      • getSessionAckMode

        int getSessionAckMode()
      • getServerUri

        java.lang.String getServerUri()
      • setServerUri

        void setServerUri​(java.lang.String aServerUri)
      • getInputQueueName

        java.lang.String getInputQueueName()
      • isStopped

        boolean isStopped()
      • getConcurrentConsumerCount

        int getConcurrentConsumerCount()
      • destroyListener

        void destroyListener​(java.lang.String anEndpointName,
                             java.lang.String aDelegateKey)
      • createListener

        void createListener​(java.lang.String aDelegateKey,
                            Endpoint endpointToUpdate)
                     throws java.lang.Exception
        Throws:
        java.lang.Exception
      • isFailed

        boolean isFailed​(java.lang.String aDelegateKey)
      • isListenerForDestination

        boolean isListenerForDestination​(java.lang.String anEndpointName)
      • removeDelegateFromFailedList

        void removeDelegateFromFailedList​(java.lang.String aDelegateKey)
      • setTerminating

        void setTerminating()
      • terminate

        void terminate()