|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.ActiveMQMessageProducerSupport
org.apache.activemq.camel.CamelMessageProducer
org.apache.activemq.camel.CamelTopicPublisher
public class CamelTopicPublisher
A JMS TopicPublisher
which sends message exchanges to a
Camel Endpoint
Field Summary |
---|
Fields inherited from class org.apache.activemq.camel.CamelMessageProducer |
---|
producer |
Fields inherited from class org.apache.activemq.ActiveMQMessageProducerSupport |
---|
defaultDeliveryMode, defaultPriority, defaultTimeToLive, disableMessageID, disableMessageTimestamp, sendTimeout, session |
Constructor Summary | |
---|---|
CamelTopicPublisher(CamelTopic destination,
org.apache.camel.Endpoint endpoint,
ActiveMQSession session)
|
Method Summary | |
---|---|
Topic |
getTopic()
Gets the topic associated with this TopicPublisher . |
void |
publish(Message message)
Publishes a message to the topic. |
void |
publish(Message message,
int deliveryMode,
int priority,
long timeToLive)
Publishes a message to the topic, specifying delivery mode, priority, and time to live. |
void |
publish(Topic topic,
Message message)
Publishes a message to a topic for an unidentified message producer. |
void |
publish(Topic topic,
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. |
Methods inherited from class org.apache.activemq.camel.CamelMessageProducer |
---|
checkClosed, close, getDestination, getEndpoint, send |
Methods inherited from class org.apache.activemq.ActiveMQMessageProducerSupport |
---|
getDeliveryMode, getDisableMessageID, getDisableMessageTimestamp, getPriority, getSendTimeout, getTimeToLive, send, send, send, setDeliveryMode, setDisableMessageID, setDisableMessageTimestamp, setPriority, setSendTimeout, setTimeToLive |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface javax.jms.MessageProducer |
---|
close, getDeliveryMode, getDestination, getDisableMessageID, getDisableMessageTimestamp, getPriority, getTimeToLive, send, send, send, send, setDeliveryMode, setDisableMessageID, setDisableMessageTimestamp, setPriority, setTimeToLive |
Constructor Detail |
---|
public CamelTopicPublisher(CamelTopic destination, org.apache.camel.Endpoint endpoint, ActiveMQSession session) throws JMSException
JMSException
Method Detail |
---|
public Topic getTopic() throws JMSException
TopicPublisher
.
getTopic
in interface TopicPublisher
JMSException
- if the JMS provider fails to get the topic for this
TopicPublisher
due to some internal error.public void publish(Message message) throws JMSException
TopicPublisher
's
default delivery mode, priority, and time to live.
publish
in interface TopicPublisher
message
- the message to publish
JMSException
- if the JMS provider fails to publish the message due to
some internal error.
MessageFormatException
- if an invalid message is specified.
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(Message message, int deliveryMode, int priority, long timeToLive) throws JMSException
publish
in interface TopicPublisher
message
- the message to publishdeliveryMode
- the delivery mode to usepriority
- the priority for this messagetimeToLive
- the message's lifetime (in milliseconds)
JMSException
- if the JMS provider fails to publish the message due to
some internal error.
MessageFormatException
- if an invalid message is specified.
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(Topic topic, Message message) throws 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 TopicPublisher
topic
- the topic to publish this message tomessage
- the message to publish
JMSException
- if the JMS provider fails to publish the message due to
some internal error.
MessageFormatException
- if an invalid message is specified.
InvalidDestinationException
- if a client uses this method with an invalid topic.MessageProducer.getDeliveryMode()
,
MessageProducer.getTimeToLive()
,
MessageProducer.getPriority()
public void publish(Topic topic, Message message, int deliveryMode, int priority, long timeToLive) throws 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 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)
JMSException
- if the JMS provider fails to publish the message due to
some internal error.
MessageFormatException
- if an invalid message is specified.
InvalidDestinationException
- if a client uses this method with an invalid topic.
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |