com.j_spaces.jms

Class GSTopicSessionImpl

java.lang.Object

com.j_spaces.jms.GSSessionImpl

com.j_spaces.jms.GSTopicSessionImpl

All Implemented Interfaces:

Runnable, javax.jms.QueueSession, javax.jms.Session, javax.jms.TopicSession

public class GSTopicSessionImpl
extends GSSessionImpl

GigaSpaces implementation of the javax.jms.TopicSession interface. A TopicSession object provides methods for creating TopicPublisher,TopicSubscriber( and TemporaryTopic) objects. It also provides a method for deleting its client's durable subscribers.

A TopicSession is used for creating Pub/Sub specific objects. In general, use the Session object, and use TopicSession only to support existing code. Using the Session object simplifies the programming model, and allows transactions to be used across the two messaging domains.

A TopicSession cannot be used to create objects specific to the point-to-point domain. The following methods inherit from Session , but must throw an IllegalStateException if used from TopicSession:

• createBrowser
• createQueue
• createTemporaryQueue

Version:

4.0 Copyright: Copyright (c) 2004 Company: GigaSpaces Technologies,Ltd.

Author:

Gershon Diner

Field Summary

Fields inherited from class com.j_spaces.jms.GSSessionImpl

_tx, m_browsers, m_closed, m_closing, m_consumers, m_isQueue, m_producers, m_stopped, sentMessages, txLeaseTime, unackedMessages

Fields inherited from interface javax.jms.Session

AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED

Constructor Summary

Constructors

Constructor and Description
GSTopicSessionImpl(com.j_spaces.jms.GSConnectionImpl connection, boolean transacted, int acknowledgeMode) Constructs a topic session.

Method Summary

Modifier and Type	Method and Description
javax.jms.QueueBrowser	createBrowser(javax.jms.Queue arg0)
javax.jms.QueueBrowser	createBrowser(javax.jms.Queue arg0, String arg1)
javax.jms.Queue	createQueue(String arg0)
javax.jms.TemporaryQueue	createTemporaryQueue() We use the same space proxy we obtained in the session and we write another External Entry, which will have a class name of 'TempQueue'.

Methods inherited from class com.j_spaces.jms.GSSessionImpl

addBrowser, addConsumer, addProducer, close, commit, createBytesMessage, createBytesMessage, createConsumer, createConsumer, createConsumer, createDurableSubscriber, createDurableSubscriber, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createPublisher, createReceiver, createReceiver, createSender, createStreamMessage, createSubscriber, createSubscriber, createTemporaryTopic, createTextMessage, createTextMessage, createTopic, ensureTX, getAcknowledgeMode, getConn, getConsumersC, getJMSProviderName, getMessageListener, getMessagesC, getNumOfConsumedMsg, getNumOfProducedMsg, getProducersC, getRandomInt, getSessionID, getTransacted, getTransaction, isClosed, recover, removeBrower, removeConsumer, removeProducer, rollback, run, setConsumersC, setMessageListener, setMessagesC, setProducersC, setSessionID, toString, unsubscribe

Methods inherited from class java.lang.Object

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

Constructor Detail

GSTopicSessionImpl

public GSTopicSessionImpl(com.j_spaces.jms.GSConnectionImpl connection,
                          boolean transacted,
                          int acknowledgeMode)
                   throws javax.jms.JMSException

Constructs a topic session.

Parameters:

connection - The connection the session belongs to.

transacted - true for a transacted session.

acknowledgeMode - 1 (auto), 2 (client) or 3 (dups ok).

Throws:

javax.jms.JMSException - In case of an invalid acknowledge mode.

Method Detail

createQueue

public javax.jms.Queue createQueue(String arg0)
                            throws javax.jms.JMSException

Specified by:

createQueue in interface javax.jms.QueueSession

Specified by:

createQueue in interface javax.jms.Session

Overrides:

createQueue in class GSSessionImpl

Throws:

javax.jms.JMSException

See Also:

Session.createQueue(String)

createBrowser

public javax.jms.QueueBrowser createBrowser(javax.jms.Queue arg0)
                                     throws javax.jms.JMSException

Specified by:

createBrowser in interface javax.jms.QueueSession

Specified by:

createBrowser in interface javax.jms.Session

Overrides:

createBrowser in class GSSessionImpl

Throws:

javax.jms.JMSException

See Also:

Session.createBrowser(Queue)

createBrowser

public javax.jms.QueueBrowser createBrowser(javax.jms.Queue arg0,
                                            String arg1)
                                     throws javax.jms.JMSException

Specified by:

createBrowser in interface javax.jms.QueueSession

Specified by:

createBrowser in interface javax.jms.Session

Overrides:

createBrowser in class GSSessionImpl

Throws:

javax.jms.JMSException

See Also:

Session.createBrowser(Queue, String)

createTemporaryQueue

public javax.jms.TemporaryQueue createTemporaryQueue()
                                              throws javax.jms.JMSException

Description copied from class: GSSessionImpl

We use the same space proxy we obtained in the session and we write another External Entry, which will have a class name of 'TempQueue'. The only message consumers that can consume from a temporary destination are those created by the same connection that created the destination. Any message producer can send to the temporary destination. If you close the connection that a temporary destination belongs to, the destination is closed and its contents lost. You can use temporary destinations to implement a simple request/reply mechanism. If you create a temporary destination and specify it as the value of the JMSReplyTo message header field when you send a message, the consumer of the message can use the value of the JMSReplyTo field as the destination to which it sends a reply and can also reference the original request by setting the JMSCorrelationID header field of the reply message to the value of the JMSMessageID header field of the request.

Specified by:

createTemporaryQueue in interface javax.jms.QueueSession

Specified by:

createTemporaryQueue in interface javax.jms.Session

Overrides:

createTemporaryQueue in class GSSessionImpl

Throws:

javax.jms.JMSException

See Also:

Session.createTemporaryQueue()