SonicMQ API

progress.message.jclient.mp
Interface TopicSession

All Superinterfaces:
java.lang.Runnable, Session, TopicSession

public interface TopicSession
extends Session, TopicSession

Title: SonicMQ Adaptive Pacing (Managed Client Topic Session)

Description: A Managed Client Topic Session allows users to take advantage of extended client features at the session level.

For specific details regarding the behaviour of Managed Client session objects please see progress.message.jclient.mp.Session documentation.

Copyright: Copyright (c) 2006

Company: Progress Software

Version:
2.2
Author:
Dmitry Lelchuk

Field Summary
 
Fields inherited from interface progress.message.jclient.Session
SINGLE_MESSAGE_ACKNOWLEDGE
 
Fields inherited from interface javax.jms.Session
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED
 
Fields inherited from interface progress.message.jclient.Session
SINGLE_MESSAGE_ACKNOWLEDGE
 
Fields inherited from interface javax.jms.Session
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED
 
Fields inherited from interface javax.jms.Session
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED
 
Method Summary
 TopicPublisher createPublisher(Topic topic)
          Creates a Managed Client Topic Publisher that supports Managed Client functionality.
 TopicSubscriber createSubscriber(Topic topic)
          Creates a Managed Client Topic Subscriber that supports Managed Client functionality.
 TopicSubscriber createSubscriber(Topic topic, java.lang.String messageSelector, boolean noLocal)
          Creates a Managed Client Topic Subscriber that supports Managed Client functionality.
 
Methods inherited from interface progress.message.jclient.mp.Session
close, createConsumer, createConsumer, createConsumer, createDurableSubscriber, createDurableSubscriber, createDurableSubscriber, createDurableSubscriber, createProducer, getAdaptivePacing, getAdaptivePacingBatchSize, getAdaptivePacingTimer, getSessionID, setAdaptivePacingBatchSize, setAdaptivePacingTimer
 
Methods inherited from interface progress.message.jclient.Session
commit, commit, createBrowser, createBrowser, createMultipartMessage, createMultiTopic, createQueue, createTemporaryQueue, createTemporaryQueue, createTemporaryTopic, createTopic, createXMLMessage, createXMLMessage, createXMLMessage, getAcknowledgeMode, getDurableMessageOrder, getFlowToDisk, getSessionName, getSplitMultiTopicDelivery, getTxnBatchSize, setAckBatchingEnabled, setDurableMessageOrder, setFlowControlDisabled, setFlowToDisk, setSplitMultiTopicDelivery, setTxnBatchSize, unsubscribe
 
Methods inherited from interface javax.jms.Session
commit, createBytesMessage, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createStreamMessage, createTextMessage, createTextMessage, getMessageListener, getTransacted, recover, rollback, run, setMessageListener
 
Methods inherited from interface progress.message.jclient.Session
commit, commit, createBrowser, createBrowser, createMultipartMessage, createMultiTopic, createQueue, createTemporaryQueue, createTemporaryQueue, createTemporaryTopic, createTopic, createXMLMessage, createXMLMessage, createXMLMessage, getAcknowledgeMode, getDurableMessageOrder, getFlowToDisk, getSessionName, getSplitMultiTopicDelivery, getTxnBatchSize, setAckBatchingEnabled, setDurableMessageOrder, setFlowControlDisabled, setFlowToDisk, setSplitMultiTopicDelivery, setTxnBatchSize, unsubscribe
 
Methods inherited from interface javax.jms.Session
commit, createBytesMessage, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createStreamMessage, createTextMessage, createTextMessage, getMessageListener, getTransacted, recover, rollback, run, setMessageListener
 
Methods inherited from interface javax.jms.TopicSession
createTemporaryTopic, createTopic, unsubscribe
 
Methods inherited from interface javax.jms.Session
commit, createBytesMessage, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createStreamMessage, createTextMessage, createTextMessage, getMessageListener, getTransacted, recover, rollback, run, setMessageListener
 

Method Detail

createSubscriber

TopicSubscriber createSubscriber(Topic topic)
                                 throws JMSException
Creates a Managed Client Topic Subscriber that supports Managed Client functionality. If Adaptive Pacing is enabled the method performs the necessary checks to ensure Session constraints are not violated.

Specified by:
createSubscriber in interface TopicSession
Parameters:
topic - A Destination of type Topic.
Returns:
An instance of a Topic Subscriber.
Throws:
JMSException - If anything goes wrong. Some exceptions may be wrapped as Managed Client.

createSubscriber

TopicSubscriber createSubscriber(Topic topic,
                                 java.lang.String messageSelector,
                                 boolean noLocal)
                                 throws JMSException
Creates a Managed Client Topic Subscriber that supports Managed Client functionality. Allows the creation of a selector on the given Topic. If Adaptive Pacing is enabled the method performs the necessary checks to ensure Session constraints are not violated.

Specified by:
createSubscriber in interface TopicSession
Parameters:
topic - A Destination of type Topic.
messageSelector - Only messages with properties matching the message selector expression are delivered. A value of null or an empty string indicates that there is no message selector for the message consumer.
noLocal - If set, inhibits the delivery of messages published by its own connection.
Returns:
An instance of a Topic Subscriber.
Throws:
JMSException - If anything goes wrong. Some exceptions may be wrapped as Managed Client.

createPublisher

TopicPublisher createPublisher(Topic topic)
                               throws JMSException
Creates a Managed Client Topic Publisher that supports Managed Client functionality. If adaptive Pacing is enabled the method performs the necessary checks to ensure Session constraints are not violated.

Specified by:
createPublisher in interface TopicSession
Parameters:
topic - A Destination of the type Topic.
Returns:
A Managed Topic Publisher.
Throws:
JMSException - If something goes wrong.

SonicMQ API

Copyright © 1999-2012 Progress Software Corporation. All Rights Reserved.
HTML formatted on 13-March-2012.