ca.uhn.hl7v2.protocol.impl
Class JMSTopicAdapter

java.lang.Object
  ca.uhn.hl7v2.protocol.impl.JMSTopicAdapter

All Implemented Interfaces:

JMSDestination

public class JMSTopicAdapter
extends Object
implements JMSDestination

An implementation of JMSDestination that uses an underlying Topic.

Version:

$Revision: 1.1 $ updated on $Date: 2007-02-19 02:24:26 $ by $Author: jamesagnew $

Author:

Bryan Tripp

Constructor Summary

JMSTopicAdapter(javax.jms.TopicConnection theConnection, javax.jms.Topic theDestination)

JMSTopicAdapter(javax.jms.TopicConnection theConnection, javax.jms.Topic theDestination, String theMessageSelector)

Method Summary

void	connect() Creates a new session, sender/publisher, and receiver/subscriber.
javax.jms.TextMessage	createMessage()
void	disconnect() Closes the JMS session.
javax.jms.Connection	getConnection()
String	getName()
boolean	isConnected()
javax.jms.Message	receive()
void	send(javax.jms.Message theMessage) Sends the given message to the JMS destination.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JMSTopicAdapter

public JMSTopicAdapter(javax.jms.TopicConnection theConnection,
                       javax.jms.Topic theDestination)

Parameters:

theConnection - the connection over which messages are written and read

theDestination - the destination to/from which messages are written/read

JMSTopicAdapter

public JMSTopicAdapter(javax.jms.TopicConnection theConnection,
                       javax.jms.Topic theDestination,
                       String theMessageSelector)

Parameters:

theConnection - the connection over which messages are written and read

theDestination - the destination to/from which messages are written/read

theMessageSelector - a JMS message selector which restricts the inbound messages that are received (see JMS docs)

Method Detail

getName

public String getName()
               throws javax.jms.JMSException

Specified by:

getName in interface JMSDestination

Returns:

the name of the Queue or Topic

Throws:

javax.jms.JMSException

See Also:

JMSDestination.getName()

createMessage

public javax.jms.TextMessage createMessage()
                                    throws javax.jms.JMSException

Specified by:

createMessage in interface JMSDestination

Returns:

a new JMS Message object.

Throws:

javax.jms.JMSException

See Also:

JMSDestination.createMessage()

connect

public void connect()
             throws javax.jms.JMSException

Description copied from interface: JMSDestination

Creates a new session, sender/publisher, and receiver/subscriber.

Specified by:

connect in interface JMSDestination

Throws:

javax.jms.JMSException

See Also:

JMSDestination.connect()

disconnect

public void disconnect()
                throws javax.jms.JMSException

Description copied from interface: JMSDestination

Closes the JMS session.

Specified by:

disconnect in interface JMSDestination

Throws:

javax.jms.JMSException

See Also:

JMSDestination.disconnect()

isConnected

public boolean isConnected()

Specified by:

isConnected in interface JMSDestination

Returns:

true if connected.

See Also:

JMSDestination.isConnected()

send

public void send(javax.jms.Message theMessage)
          throws javax.jms.JMSException

Description copied from interface: JMSDestination

Sends the given message to the JMS destination.

Specified by:

send in interface JMSDestination

Parameters:

theMessage - message to send

Throws:

javax.jms.JMSException

See Also:

JMSDestination.send(javax.jms.Message)

receive

public javax.jms.Message receive()
                          throws javax.jms.JMSException

Specified by:

receive in interface JMSDestination

Returns:

a message received from the JMS destination.

Throws:

javax.jms.JMSException

See Also:

JMSDestination.receive()

getConnection

public javax.jms.Connection getConnection()

Specified by:

getConnection in interface JMSDestination

Returns:

the JMS Connection underlying this destination

See Also:

JMSDestination.getConnection()