public class CamelTopicPublisher extends CamelMessageProducer implements javax.jms.TopicPublisher
TopicPublisher
which sends message exchanges to a
Camel Endpoint
producer
Constructor and Description |
---|
CamelTopicPublisher(CamelTopic destination,
org.apache.camel.Endpoint endpoint,
org.apache.activemq.ActiveMQSession session) |
Modifier and Type | Method and Description |
---|---|
javax.jms.Topic |
getTopic()
Gets the topic associated with this
TopicPublisher . |
void |
publish(javax.jms.Message message)
Publishes a message to the topic.
|
void |
publish(javax.jms.Message message,
int deliveryMode,
int priority,
long timeToLive)
Publishes a message to the topic, specifying delivery mode, priority,
and time to live.
|
void |
publish(javax.jms.Topic topic,
javax.jms.Message message)
Publishes a message to a topic for an unidentified message producer.
|
void |
publish(javax.jms.Topic topic,
javax.jms.Message message,
int deliveryMode,
int priority,
long timeToLive)
Publishes a message to a topic for an unidentified message producer,
specifying delivery mode, priority and time to live.
|
checkClosed, close, getDestination, getEndpoint, send
getDeliveryMode, getDisableMessageID, getDisableMessageTimestamp, getPriority, getSendTimeout, getTimeToLive, send, send, send, setDeliveryMode, setDisableMessageID, setDisableMessageTimestamp, setPriority, setSendTimeout, setTimeToLive
public CamelTopicPublisher(CamelTopic destination, org.apache.camel.Endpoint endpoint, org.apache.activemq.ActiveMQSession session) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.Topic getTopic() throws javax.jms.JMSException
TopicPublisher
.getTopic
in interface javax.jms.TopicPublisher
javax.jms.JMSException
- if the JMS provider fails to get the topic for this
TopicPublisher
due to some internal error.public void publish(javax.jms.Message message) throws javax.jms.JMSException
TopicPublisher
's
default delivery mode, priority, and time to live.publish
in interface javax.jms.TopicPublisher
message
- the message to publishjavax.jms.JMSException
- if the JMS provider fails to publish the message due to
some internal error.javax.jms.MessageFormatException
- if an invalid message is specified.javax.jms.InvalidDestinationException
- if a client uses this method with a TopicPublisher
with an invalid topic.UnsupportedOperationException
- if a client uses this method with a TopicPublisher
that did not specify a topic at creation time.MessageProducer.getDeliveryMode()
,
MessageProducer.getTimeToLive()
,
MessageProducer.getPriority()
public void publish(javax.jms.Message message, int deliveryMode, int priority, long timeToLive) throws javax.jms.JMSException
publish
in interface javax.jms.TopicPublisher
message
- the message to publishdeliveryMode
- the delivery mode to usepriority
- the priority for this messagetimeToLive
- the message's lifetime (in milliseconds)javax.jms.JMSException
- if the JMS provider fails to publish the message due to
some internal error.javax.jms.MessageFormatException
- if an invalid message is specified.javax.jms.InvalidDestinationException
- if a client uses this method with a TopicPublisher
with an invalid topic.UnsupportedOperationException
- if a client uses this method with a TopicPublisher
that did not specify a topic at creation time.public void publish(javax.jms.Topic topic, javax.jms.Message message) throws javax.jms.JMSException
TopicPublisher
's default delivery mode,
priority, and time to live.
Typically, a message producer is assigned a topic at creation time; however, the JMS API also supports unidentified message producers, which require that the topic be supplied every time a message is published.
publish
in interface javax.jms.TopicPublisher
topic
- the topic to publish this message tomessage
- the message to publishjavax.jms.JMSException
- if the JMS provider fails to publish the message due to
some internal error.javax.jms.MessageFormatException
- if an invalid message is specified.javax.jms.InvalidDestinationException
- if a client uses this method with an invalid topic.MessageProducer.getDeliveryMode()
,
MessageProducer.getTimeToLive()
,
MessageProducer.getPriority()
public void publish(javax.jms.Topic topic, javax.jms.Message message, int deliveryMode, int priority, long timeToLive) throws javax.jms.JMSException
Typically, a message producer is assigned a topic at creation time; however, the JMS API also supports unidentified message producers, which require that the topic be supplied every time a message is published.
publish
in interface javax.jms.TopicPublisher
topic
- the topic to publish this message tomessage
- the message to publishdeliveryMode
- the delivery mode to usepriority
- the priority for this messagetimeToLive
- the message's lifetime (in milliseconds)javax.jms.JMSException
- if the JMS provider fails to publish the message due to
some internal error.javax.jms.MessageFormatException
- if an invalid message is specified.javax.jms.InvalidDestinationException
- if a client uses this method with an invalid topic.Apache Camel