psdi.iface.jms

Class JMSQueueBrowser

java.lang.Object

psdi.iface.jms.JMSClient

psdi.iface.jms.JMSQueueBrowser

public class JMSQueueBrowser
extends JMSClient

This class is used for browsing the Queue.

Author:

Anamitra

Field Summary

Fields inherited from class psdi.iface.jms.JMSClient

JMS_LOGGER, NO_TX, QUEUE, SESSION_TX, TOPIC

Constructor Summary

Constructors

Constructor and Description
JMSQueueBrowser(java.lang.String destinationName, java.lang.String selector, javax.jms.Session session, java.util.Properties env)
JMSQueueBrowser(java.lang.String destinationName, java.lang.String conFactoryName, java.lang.String selector, java.util.Properties env)
JMSQueueBrowser(java.lang.String destinationName, java.lang.String conFactoryName, java.lang.String selector, java.util.Properties env, java.lang.String providerUserName, java.lang.String providerPassword)

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Releses all resources that is cached by the client like JMS Session and Connection.
JMSClient	createClientInSession() Creates another JMSClient of the same type in this clients Session.
JMSClient	createClientInSession(java.lang.String destinationName, java.util.Properties env) Creates another JMSClient of the same type in this clients Session.
java.util.List<JMSData>	getAllMessages()
java.util.List<JMSData>	getMessages(int n)
boolean	isMessageInQueue()
void	waitTillMessageInQueue(long sleepFrequency) This call blocks for MAX_ITERATIONS*sleepFrequency for the message in the Queue.

Methods inherited from class psdi.iface.jms.JMSClient

commitTx, getDestinationName, getEnvironment, getProviderPassword, getProviderUserName, getSession, isValid, rollbackTx

Methods inherited from class java.lang.Object

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

Constructor Detail

JMSQueueBrowser

public JMSQueueBrowser(java.lang.String destinationName,
               java.lang.String conFactoryName,
               java.lang.String selector,
               java.util.Properties env)
                throws MXException

Parameters:

destinationName - the JNDI name of the Destination.

conFactoryName - the JNDI name of the ConnectionFactory.

selector - The message selector for the MessageConsumer.

env - The env properties to create an InitialContext.

Throws:

MXException

JMSQueueBrowser

public JMSQueueBrowser(java.lang.String destinationName,
               java.lang.String conFactoryName,
               java.lang.String selector,
               java.util.Properties env,
               java.lang.String providerUserName,
               java.lang.String providerPassword)
                throws MXException

Parameters:

destinationName - the JNDI name of the Destination.

conFactoryName - the JNDI name of the ConnectionFactory.

selector - The message selector for the MessageConsumer.

env - The env properties to create an InitialContext.

providerUserName - The provider connection user.

providerPassword - The provider connection password.

Throws:

MXException

JMSQueueBrowser

public JMSQueueBrowser(java.lang.String destinationName,
               java.lang.String selector,
               javax.jms.Session session,
               java.util.Properties env)
                throws MXException

Parameters:

destinationName - the JNDI name of the Destination.

selector - The message selector for the MessageConsumer.

session - the JMS session from which the client should be created.

env - The env properties to create an InitialContext.

Throws:

MXException

Method Detail

close

public void close()

Description copied from class: JMSClient

Releses all resources that is cached by the client like JMS Session and Connection. If the Session is owned by another client then this operation will not close that Session (and Connection). Calling this method on the originating client (which created the Session and Connection) will close these resources.

Overrides:

close in class JMSClient

waitTillMessageInQueue

public void waitTillMessageInQueue(long sleepFrequency)

This call blocks for MAX_ITERATIONS*sleepFrequency for the message in the Queue.

Parameters:

sleepFrequency - the check frequesncy in millis.

isMessageInQueue

public boolean isMessageInQueue()

Returns:

true if the message is in the Queue and false otherwise.

getAllMessages

public java.util.List<JMSData> getAllMessages()

Returns:

List of all the messages that match the selction criterion as per the selector.

getMessages

public java.util.List<JMSData> getMessages(int n)

createClientInSession

public JMSClient createClientInSession()
                                throws MXException

Description copied from class: JMSClient

Creates another JMSClient of the same type in this clients Session. This is used for making the this client and the newly created client to work off the same Session and hence be in the same JMS transaction context.

Specified by:

createClientInSession in class JMSClient

Returns:

the newly created JMSClient instance.

Throws:

MXException

createClientInSession

public JMSClient createClientInSession(java.lang.String destinationName,
                              java.util.Properties env)
                                throws MXException

Description copied from class: JMSClient

Creates another JMSClient of the same type in this clients Session. This is used for making the this client and the newly created client to work off the same Session and hence be in the same JMS transaction context.

Specified by:

createClientInSession in class JMSClient

Returns:

the newly created JMSClient instance.

Throws:

MXException