com.cosylab.acs.jms

Class ACSJMSTopicPublisher

java.lang.Object

com.cosylab.acs.jms.ACSJMSProducer

com.cosylab.acs.jms.ACSJMSTopicPublisher

public class ACSJMSTopicPublisher
extends ACSJMSProducer

To avoid creating an AcsEventPublisher for each message to publish, an pool of AcsEventPublisher has been introduced by means of a HashMap. The key of the HasMap is the name of the NC. To make the publisher reusable for all the topics, the HashMap is static. The DefaultPublisherImpl instantiates an object of this class and publishes messages passing the topic i.e. it never calls the method without topic. In particular it calls: - publish(Topic,Message) for Heartbeat, Category, clients - publish(Topic topic, Message message, int deliveryMode, int priority, long timeToLive) for Sources For our point of view the two methods have the same functioning because we do not use the deliveryMode, priority and timeToLive at least for now ;-)

Author:

kzagar

See Also:

cern.cmw.mom.pubsub.impl.DefaultPublisherImpl}

Field Summary

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

containerServices, destination

Constructor Summary

Constructors

Constructor and Description
ACSJMSTopicPublisher(Topic topic, ContainerServicesBase containerServices) Constructor

Method Summary

Modifier and Type	Method and Description
void	close()
Topic	getTopic()
void	publish(Message message) Publish a message in the topic The topic is the topic whose name has been passed in the constructor.
void	publish(Message message, int deliveryMode, int priority, long timeToLive)
void	publish(Topic topic, Message message)
void	publish(Topic topic, Message message, int deliveryMode, int priority, long timeToLive)
void	send(Message message)

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

getDeliveryMode, getDestination, getDisableMessageID, getDisableMessageTimestamp, getPriority, getTimeToLive, send, send, send, setDeliveryMode, setDisableMessageID, setDisableMessageTimestamp, setPriority, setTimeToLive

Methods inherited from class java.lang.Object

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

Constructor Detail

ACSJMSTopicPublisher

public ACSJMSTopicPublisher(Topic topic,
                            ContainerServicesBase containerServices)
                     throws JMSException

Constructor

Parameters:

topic - The topic to publish messages into

containerServices - The container service

Throws:

JMSException

Method Detail

getTopic

public Topic getTopic()
               throws JMSException

Throws:

JMSException

publish

public void publish(Message message)
             throws JMSException

Publish a message in the topic The topic is the topic whose name has been passed in the constructor. However for this implementation there is no difference when the topic has been built because all the topics are in the pool. The name of the topic built in the constructor can be accessed through the topicName field.

Throws:

JMSException

See Also:

javax.jms.TopicPublisher#publish(javax.jms.Message)

publish

public void publish(Message message,
                    int deliveryMode,
                    int priority,
                    long timeToLive)
             throws JMSException

Throws:

JMSException

publish

public void publish(Topic topic,
                    Message message)
             throws JMSException

Throws:

JMSException

publish

public void publish(Topic topic,
                    Message message,
                    int deliveryMode,
                    int priority,
                    long timeToLive)
             throws JMSException

Throws:

JMSException

close

public void close()
           throws JMSException

Throws:

JMSException

send

public void send(Message message)
          throws JMSException

Throws:

JMSException