org.jumpi.impl.connector.jms10
Class JmsTopicContext

java.lang.Object
  |
  +--org.jumpi.impl.connector.jms10.JmsContext
        |
        +--org.jumpi.impl.connector.jms10.JmsTopicContext

public class JmsTopicContext

extends JmsContext

A JmsTopicContext represents a JMS TopicSession, with a JMS TopicPublisher and TopicPublisher pair. The TopicPublisher and TopicSubscriber are created lazily on send and receive respectively.

Field Summary

Fields inherited from class org.jumpi.impl.connector.jms10.JmsContext

dest_, PROPERTY_JMS_CORRELATION_ID, PROPERTY_JMS_RECEIVE_TIMEOUT, PROPERTY_JMS_REPLY_DESTINATION, PROPERTY_JMS_REPLY_WANTED_FLAG, PROPERTY_JMS_TTL

Constructor Summary

JmsTopicContext(JmsDestination dest, javax.jms.TopicConnection connection)
Creates a new JmsTopicContext object.

Method Summary

void	close() Close the JmsContext, which entails closing any established JMS entities..
boolean	recv(JmsDestination dest, Envelope env) Receive an ObjectMessage from the JmsDestination provided.
boolean	send(JmsDestination dest, Envelope env) Send an ObjectMessage to the JmsDestination provided.

Methods inherited from class org.jumpi.impl.connector.jms10.JmsContext

consolidatedProperties, getCorrelationID, getDestination, getReceiveTimeout, getTTL, isReplyTo

Methods inherited from class java.lang.Object

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

Constructor Detail

JmsTopicContext

public JmsTopicContext(JmsDestination dest,
                       javax.jms.TopicConnection connection)

Creates a new JmsTopicContext object.

Parameters:

dest - the JmsDestination associated with the instance.

connection - the TopicConnection associated with the instance.

Method Detail

send

public boolean send(JmsDestination dest,
                    Envelope env)
             throws java.lang.Exception

Description copied from class: JmsContext

Send an ObjectMessage to the JmsDestination provided. Several configuration parameters are allowed from the Envelope's client properties or parameters. See JmsConnector.onSend(org.jumpi.spi.Envelope).

Specified by:

send in class JmsContext

Parameters:

dest - the JmsDestination which may contain a Temporary Destination to use, instead of the instance's default Destination.

env - the Envelope containing the message and customizing properties.

Returns:

true if the operation succeeds, otherwise false if managed failure.

Throws:

java.lang.Exception - if any error condition occurs, failing the operation.

See Also:

JmsContext.send(org.jumpi.impl.connector.jms10.JmsDestination, org.jumpi.spi.Envelope)

recv

public boolean recv(JmsDestination dest,
                    Envelope env)
             throws java.lang.Exception

Description copied from class: JmsContext

Receive an ObjectMessage from the JmsDestination provided. Receive timeout returns false. Several configuration parameters are allowed from the Envelope's client properties or parameters. See JmsConnector.onRecv(org.jumpi.spi.Envelope).

Specified by:

recv in class JmsContext

Parameters:

dest - the JmsDestination which may contain a Temporary Destination to use, instead of the instance's default Destination.

env - the Envelope to place the message and containing customizing properties.

Returns:

true if the operation succeeds, otherwise false if the receive times-out.

Throws:

java.lang.Exception - if any error condition occurs, failing the operation.

See Also:

JmsContext.send(org.jumpi.impl.connector.jms10.JmsDestination, org.jumpi.spi.Envelope)

close

public void close()

Description copied from class: JmsContext

Close the JmsContext, which entails closing any established JMS entities..

Specified by:

close in class JmsContext

See Also:

JmsContext.close()