org.apache.camel.jms
Class CamelMessageProducer

java.lang.Object
  extended by org.apache.activemq.ActiveMQMessageProducerSupport
      extended by org.apache.camel.jms.CamelMessageProducer
All Implemented Interfaces:
MessageProducer, org.apache.activemq.Closeable
Direct Known Subclasses:
CamelQueueSender, CamelTopicPublisher

public class CamelMessageProducer
extends org.apache.activemq.ActiveMQMessageProducerSupport

A JMS MessageProducer which sends message exchanges to a Camel Endpoint

Version:
$Revision: $

Field Summary
protected  org.apache.camel.Producer producer
           
 
Fields inherited from class org.apache.activemq.ActiveMQMessageProducerSupport
defaultDeliveryMode, defaultPriority, defaultTimeToLive, disableMessageID, disableMessageTimestamp, session
 
Constructor Summary
CamelMessageProducer(CamelDestination destination, org.apache.camel.Endpoint endpoint, org.apache.activemq.ActiveMQSession session)
           
 
Method Summary
protected  void checkClosed()
           
 void close()
           
 CamelDestination getDestination()
           
 org.apache.camel.Endpoint getEndpoint()
           
 void send(Destination destination, Message message, int deliveryMode, int priority, long timeToLive)
           
 
Methods inherited from class org.apache.activemq.ActiveMQMessageProducerSupport
getDeliveryMode, 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
 

Field Detail

producer

protected org.apache.camel.Producer producer
Constructor Detail

CamelMessageProducer

public CamelMessageProducer(CamelDestination destination,
                            org.apache.camel.Endpoint endpoint,
                            org.apache.activemq.ActiveMQSession session)
                     throws JMSException
Throws:
JMSException
Method Detail

getDestination

public CamelDestination getDestination()
                                throws JMSException
Throws:
JMSException

getEndpoint

public org.apache.camel.Endpoint getEndpoint()

close

public void close()
           throws JMSException
Throws:
JMSException

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 org.apache.activemq.ActiveMQMessageProducerSupport
Throws:
IllegalStateException


Copyright © 2007 Apache Software Foundation. All Rights Reserved.