Class JmsEndpointConnection_impl

  • All Implemented Interfaces:
    org.apache.activemq.advisory.ConsumerListener

    public class JmsEndpointConnection_impl
    extends java.lang.Object
    implements org.apache.activemq.advisory.ConsumerListener
    • Field Detail

      • producerSession

        protected javax.jms.Session producerSession
      • connectionCreationTimestamp

        protected static long connectionCreationTimestamp
    • Method Detail

      • isRetryEnabled

        public boolean isRetryEnabled()
      • setRetryEnabled

        public void setRetryEnabled​(boolean retryEnabled)
      • isOpen

        public boolean isOpen()
      • abort

        public void abort()
      • close

        public void close()
                   throws java.lang.Exception
        Throws:
        java.lang.Exception
      • getEndpoint

        protected java.lang.String getEndpoint()
      • setEndpoint

        protected void setEndpoint​(java.lang.String endpoint)
      • setDelegateEndpoint

        protected void setDelegateEndpoint​(Endpoint delegateEndpoint)
      • getServerUri

        protected java.lang.String getServerUri()
      • setServerUri

        protected void setServerUri​(java.lang.String serverUri)
      • send

        public boolean send​(javax.jms.Message aMessage,
                            long msgSize,
                            boolean startTimer)
      • send

        public boolean send​(javax.jms.Message aMessage,
                            long msgSize,
                            boolean startTimer,
                            boolean failOnJMSException)
      • onConsumerEvent

        public void onConsumerEvent​(org.apache.activemq.advisory.ConsumerEvent arg0)
        Specified by:
        onConsumerEvent in interface org.apache.activemq.advisory.ConsumerListener
      • finalize

        protected void finalize()
                         throws java.lang.Throwable
        Overrides:
        finalize in class java.lang.Object
        Throws:
        java.lang.Throwable