org.apache.camel.component.jms
Class JmsEndpoint

java.lang.Object
  extended by org.apache.camel.impl.DefaultEndpoint<JmsExchange>
      extended by org.apache.camel.component.jms.JmsEndpoint
All Implemented Interfaces:
org.apache.camel.Endpoint<JmsExchange>

public class JmsEndpoint
extends org.apache.camel.impl.DefaultEndpoint<JmsExchange>

A JMS Endpoint

Version:
$Revision:520964 $

Constructor Summary
JmsEndpoint(String uri, JmsComponent component, String destination, boolean pubSubDomain, JmsConfiguration configuration)
           
 
Method Summary
 JmsConsumer createConsumer(org.apache.camel.Processor processor)
           
 JmsConsumer createConsumer(org.apache.camel.Processor processor, org.springframework.jms.listener.AbstractMessageListenerContainer listenerContainer)
          Creates a consumer using the given processor and listener container
 JmsExchange createExchange()
           
 JmsExchange createExchange(Message message)
           
protected  org.springframework.jms.core.JmsOperations createJmsOperations()
           
 org.apache.camel.PollingConsumer<JmsExchange> createPollingConsumer()
           
 JmsProducer createProducer()
           
 JmsProducer createProducer(org.springframework.jms.core.JmsOperations template)
          Creates a producer using the given template
 JmsBinding getBinding()
           
 JmsConfiguration getConfiguration()
           
 String getDestination()
           
 String getSelector()
           
 boolean isSingleton()
           
 void setBinding(JmsBinding binding)
          Sets the binding used to convert from a Camel message to and from a JMS message
 void setSelector(String selector)
          Sets the JMS selector to use
 
Methods inherited from class org.apache.camel.impl.DefaultEndpoint
convertTo, createExchange, createExecutorService, equals, getComponent, getContext, getEndpointUri, getExchangeType, getExecutorService, hashCode, setExecutorService, toExchangeType, toString
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 

Constructor Detail

JmsEndpoint

public JmsEndpoint(String uri,
                   JmsComponent component,
                   String destination,
                   boolean pubSubDomain,
                   JmsConfiguration configuration)
Method Detail

createProducer

public JmsProducer createProducer()
                           throws Exception
Throws:
Exception

createProducer

public JmsProducer createProducer(org.springframework.jms.core.JmsOperations template)
                           throws Exception
Creates a producer using the given template

Throws:
Exception

createConsumer

public JmsConsumer createConsumer(org.apache.camel.Processor processor)
                           throws Exception
Throws:
Exception

createConsumer

public JmsConsumer createConsumer(org.apache.camel.Processor processor,
                                  org.springframework.jms.listener.AbstractMessageListenerContainer listenerContainer)
                           throws Exception
Creates a consumer using the given processor and listener container

Parameters:
processor - the processor to use to process the messages
listenerContainer - the listener container
Returns:
a newly created consumer
Throws:
Exception - if the consumer cannot be created

createPollingConsumer

public org.apache.camel.PollingConsumer<JmsExchange> createPollingConsumer()
                                                                    throws Exception
Specified by:
createPollingConsumer in interface org.apache.camel.Endpoint<JmsExchange>
Overrides:
createPollingConsumer in class org.apache.camel.impl.DefaultEndpoint<JmsExchange>
Throws:
Exception

createExchange

public JmsExchange createExchange()

createExchange

public JmsExchange createExchange(Message message)

getBinding

public JmsBinding getBinding()

setBinding

public void setBinding(JmsBinding binding)
Sets the binding used to convert from a Camel message to and from a JMS message

Parameters:
binding - the binding to use

getDestination

public String getDestination()

getConfiguration

public JmsConfiguration getConfiguration()

getSelector

public String getSelector()

setSelector

public void setSelector(String selector)
Sets the JMS selector to use


isSingleton

public boolean isSingleton()

createJmsOperations

protected org.springframework.jms.core.JmsOperations createJmsOperations()


Copyright © 2007 Apache Software Foundation. All Rights Reserved.