com.cosylab.acs.jms

Class ACSJMSConsumer

java.lang.Object

com.cosylab.acs.jms.ACSJMSConsumer

Direct Known Subclasses:

ACSJMSTopicSubscriber

public abstract class ACSJMSConsumer
extends java.lang.Object

This class supports only the listener mechanism. The overloaded receive methods and receiveNoWait are not implemented and throw an UnsupportedOperationException. Having both methods (receive and callback) in place causes an out of memory if the queue of message is not flushed on disk. To avoid memory neverending memory consumption I have preferred to remove the implementations of the calls leaving only the callback (given that at the present this is the only one used)

Author:

kzagar

Field Summary

Fields

Modifier and Type	Field and Description
protected Destination	destination

Constructor Summary

Constructors

Constructor and Description
ACSJMSConsumer(Destination destination, ContainerServicesBase contServices, java.lang.String selector) The constructor of the consumer

Method Summary

Modifier and Type	Method and Description
void	close()
MessageListener	getMessageListener()
java.lang.String	getMessageSelector()
Message	receive()
void	receive(ACSJMSMessageEntity message)
Message	receive(long timeout)
Message	receiveNoWait()
void	setMessageListener(MessageListener listener)
void	setMessageSelector(java.lang.String selectorString) Set a new SQL92 selector string for the consumer

Methods inherited from class java.lang.Object

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

Field Detail

destination

protected Destination destination

Constructor Detail

ACSJMSConsumer

public ACSJMSConsumer(Destination destination,
                      ContainerServicesBase contServices,
                      java.lang.String selector)
               throws JMSException

The constructor of the consumer

Parameters:

destination -

contServices - The Container services

selector - The message selector (can be empty or null)

Throws:

JMSException

Method Detail

getMessageSelector

public java.lang.String getMessageSelector()
                                    throws JMSException

Throws:

JMSException

setMessageSelector

public void setMessageSelector(java.lang.String selectorString)

Set a new SQL92 selector string for the consumer

Parameters:

selectorString -

getMessageListener

public MessageListener getMessageListener()
                                   throws JMSException

Throws:

JMSException

setMessageListener

public void setMessageListener(MessageListener listener)
                        throws JMSException

Throws:

JMSException

receive

public Message receive()
                throws JMSException

Throws:

JMSException

receive

public Message receive(long timeout)
                throws JMSException

Throws:

JMSException

receiveNoWait

public Message receiveNoWait()
                      throws JMSException

Throws:

JMSException

close

public void close()
           throws JMSException

Throws:

JMSException

receive

public void receive(ACSJMSMessageEntity message)