org.apache.camel.jms
Class JmsEndpoint

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

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

Version:
$Revision: 520404 $

Field Summary
 
Fields inherited from class org.apache.camel.impl.DefaultEndpoint
activated, deactivated
 
Constructor Summary
JmsEndpoint(String endpointUri, org.apache.camel.CamelContext container, String destination, org.springframework.jms.core.JmsOperations template, org.springframework.jms.listener.AbstractMessageListenerContainer listenerContainer)
           
 
Method Summary
 JmsExchange createExchange()
           
 JmsExchange createExchange(Message message)
           
protected  void doActivate()
           
protected  void doDeactivate()
           
 org.springframework.jms.core.JmsOperations getTemplate()
           
 void onExchange(JmsExchange exchange)
           
 void onMessage(Message message)
           
 void send(org.apache.camel.Exchange exchange)
           
 
Methods inherited from class org.apache.camel.impl.DefaultEndpoint
activate, convertTo, createExchange, deactivate, equals, getContext, getEndpointUri, getInboundProcessor, hashCode, setInboundProcessor, toString
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 

Constructor Detail

JmsEndpoint

public JmsEndpoint(String endpointUri,
                   org.apache.camel.CamelContext container,
                   String destination,
                   org.springframework.jms.core.JmsOperations template,
                   org.springframework.jms.listener.AbstractMessageListenerContainer listenerContainer)
Method Detail

onMessage

public void onMessage(Message message)
Specified by:
onMessage in interface MessageListener

send

public void send(org.apache.camel.Exchange exchange)

onExchange

public void onExchange(JmsExchange exchange)
Specified by:
onExchange in interface org.apache.camel.Endpoint<JmsExchange>
Specified by:
onExchange in interface org.apache.camel.Processor<JmsExchange>

getTemplate

public org.springframework.jms.core.JmsOperations getTemplate()

createExchange

public JmsExchange createExchange()
Specified by:
createExchange in interface org.apache.camel.Endpoint<JmsExchange>

createExchange

public JmsExchange createExchange(Message message)

doActivate

protected void doActivate()
Overrides:
doActivate in class org.apache.camel.impl.DefaultEndpoint<JmsExchange>

doDeactivate

protected void doDeactivate()
Overrides:
doDeactivate in class org.apache.camel.impl.DefaultEndpoint<JmsExchange>


Copyright © 2007 Apache Software Foundation. All Rights Reserved.