Public Member Functions | Protected Attributes

com.cosylab.acs.jms.ACSJMSConsumer Class Reference

Inheritance diagram for com.cosylab.acs.jms.ACSJMSConsumer:
com.cosylab.acs.jms.ACSJMSTopicSubscriber

List of all members.

Public Member Functions

 ACSJMSConsumer (Destination destination, ContainerServicesBase contServices, String selector) throws JMSException
String getMessageSelector () throws JMSException
void setMessageSelector (String selectorString)
MessageListener getMessageListener () throws JMSException
void setMessageListener (MessageListener listener) throws JMSException
Message receive () throws JMSException
Message receive (long timeout) throws JMSException
Message receiveNoWait () throws JMSException
void close () throws JMSException
void receive (ACSJMSMessageEntity message)

Protected Attributes

Destination destination

Detailed Description

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

Constructor & Destructor Documentation

com.cosylab.acs.jms.ACSJMSConsumer.ACSJMSConsumer ( Destination  destination,
ContainerServicesBase  contServices,
String  selector 
) throws JMSException

The constructor of the consumer

Parameters:
destination 
contServices The Container services
selector The message selector (can be empty or null)

References com.cosylab.acs.jms.ACSJMSConsumer.destination.

Member Function Documentation

void com.cosylab.acs.jms.ACSJMSConsumer.close (  )  throws JMSException
MessageListener com.cosylab.acs.jms.ACSJMSConsumer.getMessageListener (  )  throws JMSException
String com.cosylab.acs.jms.ACSJMSConsumer.getMessageSelector (  )  throws JMSException

References com.cosylab.acs.jms.ACSJMSMessageSelector.getSelectorString().

void com.cosylab.acs.jms.ACSJMSConsumer.receive ( ACSJMSMessageEntity  message  ) 

References com.cosylab.acs.jms.ACSJMSMessageSelector.match().

Message com.cosylab.acs.jms.ACSJMSConsumer.receive (  )  throws JMSException
Message com.cosylab.acs.jms.ACSJMSConsumer.receive ( long  timeout  )  throws JMSException
Message com.cosylab.acs.jms.ACSJMSConsumer.receiveNoWait (  )  throws JMSException
void com.cosylab.acs.jms.ACSJMSConsumer.setMessageListener ( MessageListener  listener  )  throws JMSException
void com.cosylab.acs.jms.ACSJMSConsumer.setMessageSelector ( String  selectorString  ) 

Set a new SQL92 selector string for the consumer

Parameters:
selectorString 

References com.cosylab.acs.jms.ACSJMSMessageSelector.setSelectorString().

Member Data Documentation

Destination com.cosylab.acs.jms.ACSJMSConsumer.destination [protected]

Referenced by com.cosylab.acs.jms.ACSJMSConsumer.ACSJMSConsumer(), and com.cosylab.acs.jms.ACSJMSTopicSubscriber.getTopic().

The documentation for this class was generated from the following file:
 All Classes Namespaces Files Functions Variables Enumerations Properties
Generated on Thu Jan 12 2012 23:15:32 for ACS-10.0 Java API by  doxygen 1.7.0