Package com.swiftmq.impl.jms.standard.v750

Class JMSConnection

java.lang.Object
com.swiftmq.impl.jms.standard.v750.JMSConnection
All Implemented Interfaces:
VersionedJMSConnection
public class JMSConnection extends Object implements VersionedJMSConnection

  • Field Details

    • inboundReader

      protected InboundReader inboundReader

    • outboundWriter

      protected OutboundWriter outboundWriter

    • activeLogin

      protected ActiveLogin activeLogin

    • tracePrefix

      protected String tracePrefix

    • connectionId

      protected String connectionId

  • Constructor Details

    • JMSConnection

      public JMSConnection(SwiftletContext ctx, Entity connectionEntity, Connection connection)

  • Method Details

    • getClientId

      public String getClientId()

    • getRemoteHostname

      public String getRemoteHostname()

    • getUserName

      public String getUserName()

    • getInboundHandler

      public InboundHandler getInboundHandler()
      Specified by:
      getInboundHandler in interface VersionedJMSConnection

    • sendReply

      public void sendReply(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(CreateSessionRequest req, int sessionDispatchId, Entity sessionEntity)

    • process

      public void process(List<Object> events)

    • serviceRequest

      public void serviceRequest(Request request)

    • toString

      public String toString()
      Overrides:
      toString in class Object