com.cosylab.acs.jms

Class ACSJMSTopicSubscriber

java.lang.Object

com.cosylab.acs.jms.ACSJMSConsumer

com.cosylab.acs.jms.ACSJMSTopicSubscriber

All Implemented Interfaces:

AcsEventSubscriber.Callback<ACSJMSMessageEntity>

public class ACSJMSTopicSubscriber
extends ACSJMSConsumer
implements AcsEventSubscriber.Callback<ACSJMSMessageEntity>

Author:

kzagar

Field Summary

Fields inherited from class com.cosylab.acs.jms.ACSJMSConsumer

destination

Constructor Summary

Constructors

Constructor and Description
ACSJMSTopicSubscriber(Topic topic, ContainerServicesBase containerServices, java.lang.String selector)

Method Summary

Modifier and Type	Method and Description
void	close()
java.lang.Class<ACSJMSMessageEntity>	getEventType() This method is needed for adding event-specific subscriptions and for the type-safety of this API (based on java generics), and should be implemented like
boolean	getNoLocal()
Topic	getTopic()
void	receive(ACSJMSMessageEntity eventData, EventDescription eventDescrip) The NC subscriber callback method.

Methods inherited from class com.cosylab.acs.jms.ACSJMSConsumer

getMessageListener, getMessageSelector, receive, receive, receive, receiveNoWait, setMessageListener, setMessageSelector

Methods inherited from class java.lang.Object

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

Constructor Detail

ACSJMSTopicSubscriber

public ACSJMSTopicSubscriber(Topic topic,
                             ContainerServicesBase containerServices,
                             java.lang.String selector)
                      throws JMSException

Parameters:

destination -

containerServices -

selector -

Throws:

AcsJException

JMSException

Method Detail

getTopic

public Topic getTopic()
               throws JMSException

Throws:

JMSException

getNoLocal

public boolean getNoLocal()
                   throws JMSException

Throws:

JMSException

receive

public void receive(ACSJMSMessageEntity eventData,
                    EventDescription eventDescrip)

The NC subscriber callback method.

Specified by:

receive in interface AcsEventSubscriber.Callback<ACSJMSMessageEntity>

Parameters:

eventData - The event data, e.g. an IDL-defined struct.

eventDescrip - Event meta data.

getEventType

public java.lang.Class<ACSJMSMessageEntity> getEventType()

Description copied from interface: AcsEventSubscriber.Callback

This method is needed for adding event-specific subscriptions and for the type-safety of this API (based on java generics), and should be implemented like

 public Class<MyEvent> getEventType() {
     return MyEvent.class;
 }
 

Specified by:

getEventType in interface AcsEventSubscriber.Callback<ACSJMSMessageEntity>

close

public void close()
           throws JMSException

Overrides:

close in class ACSJMSConsumer

Throws:

JMSException