Package com.swiftmq.impl.jms.standard.v630

Class JMSConnection

java.lang.Object
com.swiftmq.impl.jms.standard.v630.JMSConnection
All Implemented Interfaces:
VersionedJMSConnection, com.swiftmq.tools.requestreply.RequestService
public class JMSConnection extends Object implements com.swiftmq.tools.requestreply.RequestService, VersionedJMSConnection

  • Field Details

    • inboundReader

      protected InboundReader inboundReader

    • outboundWriter

      protected OutboundWriter outboundWriter

    • activeLogin

      protected com.swiftmq.swiftlet.auth.ActiveLogin activeLogin

    • tracePrefix

      protected String tracePrefix

    • connectionId

      protected String connectionId

  • Constructor Details

    • JMSConnection

      public JMSConnection(SwiftletContext ctx, com.swiftmq.mgmt.Entity connectionEntity, com.swiftmq.swiftlet.net.Connection connection)

  • Method Details

    • getInboundHandler

      public com.swiftmq.swiftlet.net.InboundHandler getInboundHandler()
      Specified by:
      getInboundHandler in interface VersionedJMSConnection

    • sendReply

      public void sendReply(com.swiftmq.tools.requestreply.Reply reply)
      Specified by:
      sendReply in interface VersionedJMSConnection

    • collect

      public void collect(long lastCollectTime)
      Specified by:
      collect in interface VersionedJMSConnection

    • isClosed

      public boolean isClosed()

    • close

      public void close()
      Specified by:
      close in interface VersionedJMSConnection

    • createSession

      protected Session createSession(com.swiftmq.jms.smqp.v630.CreateSessionRequest req, int sessionDispatchId, com.swiftmq.mgmt.Entity sessionEntity)

    • serviceRequest

      public void serviceRequest(com.swiftmq.tools.requestreply.Request request)
      Specified by:
      serviceRequest in interface com.swiftmq.tools.requestreply.RequestService

    • toString

      public String toString()
      Overrides:
      toString in class Object