Class JMSConnection
- java.lang.Object
-
- com.swiftmq.impl.jms.standard.v400.JMSConnection
-
- All Implemented Interfaces:
VersionedJMSConnection
,RequestService
public class JMSConnection extends java.lang.Object implements RequestService, VersionedJMSConnection
-
-
Field Summary
Fields Modifier and Type Field Description protected ActiveLogin
activeLogin
protected java.lang.String
connectionId
protected InboundReader
inboundReader
protected OutboundWriter
outboundWriter
protected java.lang.String
tracePrefix
-
Constructor Summary
Constructors Constructor Description JMSConnection(SwiftletContext ctx, Entity connectionEntity, Connection connection)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
void
collect(long lastCollectTime)
protected Session
createSession(CreateSessionRequest req, int sessionDispatchId, Entity sessionEntity)
InboundHandler
getInboundHandler()
boolean
isClosed()
void
sendReply(Reply reply)
void
serviceRequest(Request request)
java.lang.String
toString()
-
-
-
Field Detail
-
inboundReader
protected InboundReader inboundReader
-
outboundWriter
protected OutboundWriter outboundWriter
-
activeLogin
protected ActiveLogin activeLogin
-
tracePrefix
protected java.lang.String tracePrefix
-
connectionId
protected java.lang.String connectionId
-
-
Constructor Detail
-
JMSConnection
public JMSConnection(SwiftletContext ctx, Entity connectionEntity, Connection connection)
-
-
Method Detail
-
getInboundHandler
public InboundHandler getInboundHandler()
- Specified by:
getInboundHandler
in interfaceVersionedJMSConnection
-
sendReply
public void sendReply(Reply reply)
- Specified by:
sendReply
in interfaceVersionedJMSConnection
-
isClosed
public boolean isClosed()
-
collect
public void collect(long lastCollectTime)
- Specified by:
collect
in interfaceVersionedJMSConnection
-
close
public void close()
- Specified by:
close
in interfaceVersionedJMSConnection
-
createSession
protected Session createSession(CreateSessionRequest req, int sessionDispatchId, Entity sessionEntity)
-
serviceRequest
public void serviceRequest(Request request)
- Specified by:
serviceRequest
in interfaceRequestService
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-