jrun.jms.core.client
Class JmsQueueSession

jrun.jms.core.client.JmsQueueSession

public class JmsQueueSession

.

Version:

$Revision: 1.19 $ $Date: 2001/10/12 07:55:31 $

Author:

Jim Alateras

Method Summary

protected void	addBrowser(jrun.jms.core.client.JmsQueueBrowser browser) Register the queue browser with the server.
protected void	addReceiver(JmsQueueReceiver receiver) Add the specified receiver to the list of managed receivers.
protected void	addSender(JmsQueueSender sender) Add the specified sender to the list of managed senders.
void	close() Closes all queue browsers and other consumers attached to this session
javax.jms.QueueBrowser	createBrowser(javax.jms.Queue queue)
javax.jms.QueueBrowser	createBrowser(javax.jms.Queue queue, java.lang.String messageSelector)
javax.jms.Queue	createQueue(java.lang.String queueName)
javax.jms.QueueReceiver	createReceiver(javax.jms.Queue queue)
javax.jms.QueueReceiver	createReceiver(javax.jms.Queue queue, java.lang.String messageSelector)
javax.jms.QueueSender	createSender(javax.jms.Queue queue)
javax.jms.TemporaryQueue	createTemporaryQueue()
protected void	removeBrowser(jrun.jms.core.client.JmsQueueBrowser browser) De-register the queue browser from the server.
protected void	removeReceiver(JmsQueueReceiver receiver) Remove the specified receiver to the list of managed receivers.
protected void	removeSender(JmsQueueSender sender) Remove the specified sender to the list of managed senders.

Method Detail

createQueue

public javax.jms.Queue createQueue(java.lang.String queueName)
                            throws javax.jms.JMSException

createReceiver

public javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue)
                                       throws javax.jms.JMSException

createReceiver

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

createSender

public javax.jms.QueueSender createSender(javax.jms.Queue queue)
                                   throws javax.jms.JMSException

createBrowser

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

createBrowser

public javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue,
                                            java.lang.String messageSelector)
                                     throws javax.jms.JMSException

createTemporaryQueue

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

close

public void close()
           throws javax.jms.JMSException

Closes all queue browsers and other consumers attached to this session

Throws:

JMSException -

addReceiver

protected void addReceiver(JmsQueueReceiver receiver)
                    throws javax.jms.JMSException

Add the specified receiver to the list of managed receivers. It does not check for duplicates. It also registers the end point with the server.

If the queue is a temporary destination then it also checks that it is owned by the session's connection before proceeding. If it owned by some other connection then a JMSException is thrown.

Parameters:

receiver - receiver to add

Throws:

JMSException -

addSender

protected void addSender(JmsQueueSender sender)
                  throws javax.jms.JMSException

Add the specified sender to the list of managed senders. It does not check for duplicates. It also registers the end point with the server.

Parameters:

receiver - receiver to add

addBrowser

protected void addBrowser(jrun.jms.core.client.JmsQueueBrowser browser)
                   throws javax.jms.JMSException

Register the queue browser with the server.

Parameters:

browser - queue browser to register

removeReceiver

protected void removeReceiver(JmsQueueReceiver receiver)
                       throws javax.jms.JMSException

Remove the specified receiver to the list of managed receivers. If it does exist then fail silently.

This method will not clean up the server side reciever until the session is closed.

Parameters:

receiver - receiver to remove

removeSender

protected void removeSender(JmsQueueSender sender)
                     throws javax.jms.JMSException

Remove the specified sender to the list of managed senders. If it does exist then fail silently.

Parameters:

receiver - receiver to add

removeBrowser

protected void removeBrowser(jrun.jms.core.client.JmsQueueBrowser browser)
                      throws javax.jms.JMSException

De-register the queue browser from the server.

Parameters:

browser - queue browser to de-register