org.apache.activemq.camel
Class CamelMessageProducer
java.lang.Object
org.apache.activemq.ActiveMQMessageProducerSupport
org.apache.activemq.camel.CamelMessageProducer
- All Implemented Interfaces:
- MessageProducer, Closeable
- Direct Known Subclasses:
- CamelQueueSender, CamelTopicPublisher
public class CamelMessageProducer
- extends ActiveMQMessageProducerSupport
A JMS MessageProducer
which sends message exchanges to a
Camel Endpoint
- Version:
- $Revision: $
Field Summary |
protected org.apache.camel.Producer |
producer
|
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 |
producer
protected org.apache.camel.Producer producer
CamelMessageProducer
public CamelMessageProducer(CamelDestination destination,
org.apache.camel.Endpoint endpoint,
ActiveMQSession session)
throws JMSException
- Throws:
JMSException
getDestination
public CamelDestination getDestination()
throws JMSException
- Throws:
JMSException
getEndpoint
public org.apache.camel.Endpoint getEndpoint()
close
public void close()
throws JMSException
- Description copied from interface:
Closeable
- Closes a JMS object.
Many JMS objects are closeable such as Connections, Sessions, Consumers
and Producers.
- Throws:
JMSException
- if the JMS provider fails to close the object due to
some internal error.
send
public void send(Destination destination,
Message message,
int deliveryMode,
int priority,
long timeToLive)
throws JMSException
- Throws:
JMSException
checkClosed
protected void checkClosed()
throws IllegalStateException
- Specified by:
checkClosed
in class ActiveMQMessageProducerSupport
- Throws:
IllegalStateException
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.