public class JMSQueueTransport extends AbstractJMSTransport
TransportLayer
that uses a JMS Queue.CLIENT_ID_KEY, CONNECTION_METADATA_KEY, DESTINATION_NAME_KEY
Constructor and Description |
---|
JMSQueueTransport(javax.jms.QueueConnection theConnection,
javax.jms.Queue theDestination) |
Modifier and Type | Method and Description |
---|---|
void |
doConnect()
Performs connection as described in TransportLayer.connect().
|
void |
doDisconnect()
Performs disconnection as described in TransportLayer.disconnect().
|
javax.jms.Connection |
getConnection() |
protected String |
getDestinationName() |
protected javax.jms.Message |
getMessage() |
protected javax.jms.Message |
receiveJMS() |
protected void |
sendJMS(javax.jms.Message theMessage)
Sends a message to the underlying Destination
|
doReceive, doSend, getCommonMetadata, toMessage, toTransportable
connect, disconnect, isConnected, receive, send
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
connect, disconnect, isConnected, receive, send
public JMSQueueTransport(javax.jms.QueueConnection theConnection, javax.jms.Queue theDestination)
theConnection
- theDestination
- protected String getDestinationName() throws javax.jms.JMSException
getDestinationName
in class AbstractJMSTransport
javax.jms.JMSException
AbstractJMSTransport.getDestinationName()
public javax.jms.Connection getConnection()
getConnection
in class AbstractJMSTransport
AbstractJMSTransport.getConnection()
protected javax.jms.Message getMessage() throws javax.jms.JMSException
getMessage
in class AbstractJMSTransport
javax.jms.JMSException
AbstractJMSTransport.getMessage()
protected void sendJMS(javax.jms.Message theMessage) throws javax.jms.JMSException
AbstractJMSTransport
sendJMS
in class AbstractJMSTransport
javax.jms.JMSException
ca.uhn.hl7v2.protocol.impl.AbstractJMSTransport#send(javax.jms.Message)
protected javax.jms.Message receiveJMS() throws javax.jms.JMSException
receiveJMS
in class AbstractJMSTransport
javax.jms.JMSException
AbstractTransport.receive()
public void doConnect() throws TransportException
AbstractTransport
doConnect
in class AbstractTransport
TransportException
AbstractTransport.connect()
public void doDisconnect() throws TransportException
AbstractTransport
doDisconnect
in class AbstractTransport
TransportException
AbstractTransport.doDisconnect()
Copyright © 2001–2017 University Health Network. All rights reserved.