org.nuxeo.ecm.core.jms
Class MessagePublisher

java.lang.Object
  org.nuxeo.ecm.core.jms.MessagePublisher

public class MessagePublisher
extends java.lang.Object

This object is not thread safe. Should be used only in a single thread

Author:

Bogdan Stefanescu

Constructor Summary

MessagePublisher(javax.jms.Topic topic, javax.jms.TopicConnectionFactory factory)

MessagePublisher(javax.jms.Topic topic, javax.jms.TopicConnectionFactory factory, MessageFactory messageFactory)

Method Summary

void	close()
static MessagePublisher	createPublisher(java.lang.String connectionFactory, java.lang.String topic)
static MessagePublisher	createPublisher(java.lang.String connectionFactoryName, java.lang.String topicName, MessageFactory messageFactory)
javax.jms.TopicConnection	getConnection()
MessageFactory	getMessageFactory()
javax.jms.TopicPublisher	getPublisher()
javax.jms.TopicSession	getSession()
javax.jms.Topic	getTopic()
void	publish(javax.jms.Message msg)
void	publish(java.lang.Object content)
void	setMessageFactory(MessageFactory factory)
void	setTopic(javax.jms.Topic topic)

Methods inherited from class java.lang.Object

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

Constructor Detail

MessagePublisher

public MessagePublisher(javax.jms.Topic topic,
                        javax.jms.TopicConnectionFactory factory)

MessagePublisher

public MessagePublisher(javax.jms.Topic topic,
                        javax.jms.TopicConnectionFactory factory,
                        MessageFactory messageFactory)

Method Detail

getTopic

public javax.jms.Topic getTopic()

setTopic

public void setTopic(javax.jms.Topic topic)

setMessageFactory

public void setMessageFactory(MessageFactory factory)

getMessageFactory

public MessageFactory getMessageFactory()

getConnection

public javax.jms.TopicConnection getConnection()
                                        throws javax.jms.JMSException

Throws:

javax.jms.JMSException

getSession

public javax.jms.TopicSession getSession()
                                  throws javax.jms.JMSException

Throws:

javax.jms.JMSException

getPublisher

public javax.jms.TopicPublisher getPublisher()
                                      throws javax.jms.JMSException

Throws:

javax.jms.JMSException

publish

public void publish(java.lang.Object content)
             throws javax.jms.JMSException

Throws:

javax.jms.JMSException

publish

public void publish(javax.jms.Message msg)
             throws javax.jms.JMSException

Throws:

javax.jms.JMSException

close

public void close()
           throws javax.jms.JMSException

Throws:

javax.jms.JMSException

createPublisher

public static MessagePublisher createPublisher(java.lang.String connectionFactory,
                                               java.lang.String topic)
                                        throws javax.naming.NamingException

Throws:

javax.naming.NamingException

createPublisher

public static MessagePublisher createPublisher(java.lang.String connectionFactoryName,
                                               java.lang.String topicName,
                                               MessageFactory messageFactory)
                                        throws javax.naming.NamingException

Throws:

javax.naming.NamingException