progress.message.jclient.mp
Interface QueueSession

All Superinterfaces:

QueueSession, java.lang.Runnable, Session

public interface QueueSession
extends Session, QueueSession

Title: SonicMQ Adaptive Pacing (Managed Client Queue Session)

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

For specific details regarding the behavior 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

QueueReceiver	createReceiver(Queue queue) Creates a Managed Client Queue Receiver that supports Managed Client functionality.
QueueReceiver	createReceiver(Queue queue, java.lang.String messageSelector) Creates a Managed Client Queue Receiver that supports Managed Client functionality.
QueueSender	createSender(Queue queue) Creates a Managed Client Queue Sender 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.QueueSession

createBrowser, createBrowser, createQueue, createTemporaryQueue

Methods inherited from interface javax.jms.Session

commit, createBytesMessage, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createStreamMessage, createTextMessage, createTextMessage, getMessageListener, getTransacted, recover, rollback, run, setMessageListener

Method Detail

createReceiver

QueueReceiver createReceiver(Queue queue)
                             throws JMSException

Creates a Managed Client Queue Receiver 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:

createReceiver in interface QueueSession

Parameters:

queue - A Destination of type Queue.

Returns:

An instance of a Queue Receiver.

Throws:

JMSException - If anything goes wrong. Some exceptions may be wrapped as Managed Client.

createReceiver

QueueReceiver createReceiver(Queue queue,
                             java.lang.String messageSelector)
                             throws JMSException

Creates a Managed Client Queue Receiver that supports Managed Client functionality. Allows the creation of a selector on the given Queue. If Adaptive Pacing is enabled the method performs the necessary checks to ensure Session constraints are not violated.

Specified by:

createReceiver in interface QueueSession

Parameters:

queue - A Destination of type Queue.

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.

Returns:

An instance of a Queue Receiver.

Throws:

JMSException - If anything goes wrong. Some exceptions may be wrapped as Managed Client.

createSender

QueueSender createSender(Queue queue)
                         throws JMSException

Creates a Managed Client Queue Sender 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:

createSender in interface QueueSession

Parameters:

queue - A Destination of type Queue.

Returns:

An instance of a Queue Sender.

Throws:

JMSException - If anything goes wrong. Some exceptions may be wrapped as Managed Client.