org.apache.camel.queue
Class QueueEndpoint<E extends Exchange>

java.lang.Object
  extended by org.apache.camel.impl.DefaultEndpoint<E>
      extended by org.apache.camel.queue.QueueEndpoint<E>
All Implemented Interfaces:
Endpoint<E>, Processor<E>

public class QueueEndpoint<E extends Exchange>
extends DefaultEndpoint<E>

Represents a queue endpoint that uses a BlockingQueue object to process inbound exchanges.

Version:
$Revision: 519973 $

Field Summary
 
Fields inherited from class org.apache.camel.impl.DefaultEndpoint
activated, deactivated
 
Constructor Summary
QueueEndpoint(String uri, CamelContext container, BlockingQueue<E> queue)
           
 
Method Summary
 E createExchange()
          Create a new exchange for communicating with this endpoint
protected  void doActivate()
          Called at most once by the container to activate the endpoint
protected  void doDeactivate()
          Called at most once by the container to deactivate the endpoint
 Queue<E> getQueue()
           
 void onExchange(E exchange)
          Sends an outbound exchange to the endpoint
 void setInboundProcessor(Processor<E> processor)
           
 
Methods inherited from class org.apache.camel.impl.DefaultEndpoint
activate, convertTo, createExchange, deactivate, equals, getContext, getEndpointUri, getInboundProcessor, hashCode, toString
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 

Constructor Detail

QueueEndpoint

public QueueEndpoint(String uri,
                     CamelContext container,
                     BlockingQueue<E> queue)
Method Detail

onExchange

public void onExchange(E exchange)
Description copied from interface: Endpoint
Sends an outbound exchange to the endpoint


setInboundProcessor

public void setInboundProcessor(Processor<E> processor)
Overrides:
setInboundProcessor in class DefaultEndpoint<E extends Exchange>

createExchange

public E createExchange()
Description copied from interface: Endpoint
Create a new exchange for communicating with this endpoint


getQueue

public Queue<E> getQueue()

doActivate

protected void doActivate()
Description copied from class: DefaultEndpoint
Called at most once by the container to activate the endpoint

Overrides:
doActivate in class DefaultEndpoint<E extends Exchange>

doDeactivate

protected void doDeactivate()
Description copied from class: DefaultEndpoint
Called at most once by the container to deactivate the endpoint

Overrides:
doDeactivate in class DefaultEndpoint<E extends Exchange>


Copyright © 2007 Apache Software Foundation. All Rights Reserved.