|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Objectorg.apache.camel.impl.DefaultEndpoint
org.apache.camel.component.seda.SedaEndpoint
public class SedaEndpoint
An implementation of the Queue components for
asynchronous SEDA exchanges on a BlockingQueue within a CamelContext
| Constructor Summary | |
|---|---|
SedaEndpoint()
|
|
SedaEndpoint(String endpointUri,
BlockingQueue<Exchange> queue)
|
|
SedaEndpoint(String endpointUri,
BlockingQueue<Exchange> queue,
int concurrentConsumers)
|
|
SedaEndpoint(String endpointUri,
Component component,
BlockingQueue<Exchange> queue)
|
|
SedaEndpoint(String endpointUri,
Component component,
BlockingQueue<Exchange> queue,
int concurrentConsumers)
|
|
| Method Summary | |
|---|---|
Consumer |
createConsumer(Processor processor)
Creates a new Event Driven Consumer which consumes messages from the endpoint using the given processor |
Producer |
createProducer()
Creates a new producer which is used send messages into the endpoint |
int |
getConcurrentConsumers()
|
Set<SedaConsumer> |
getConsumers()
Returns the current active consumers on this endpoint |
List<Exchange> |
getExchanges()
Returns the current pending exchanges |
Set<SedaProducer> |
getProducers()
Returns the current active producers on this endpoint |
BlockingQueue<Exchange> |
getQueue()
|
int |
getSize()
|
long |
getTimeout()
|
WaitForTaskToComplete |
getWaitForTaskToComplete()
|
boolean |
isSingleton()
Wheter this class supports being singleton or not. |
void |
setConcurrentConsumers(int concurrentConsumers)
|
void |
setQueue(BlockingQueue<Exchange> queue)
|
void |
setSize(int size)
|
void |
setTimeout(long timeout)
|
void |
setWaitForTaskToComplete(WaitForTaskToComplete waitForTaskToComplete)
|
| Methods inherited from class java.lang.Object |
|---|
clone, finalize, getClass, notify, notifyAll, wait, wait, wait |
| Methods inherited from interface org.apache.camel.Endpoint |
|---|
configureProperties, createExchange, createExchange, createExchange, createPollingConsumer, getCamelContext, getEndpointKey, getEndpointUri, isLenientProperties, setCamelContext |
| Constructor Detail |
|---|
public SedaEndpoint()
public SedaEndpoint(String endpointUri,
Component component,
BlockingQueue<Exchange> queue)
public SedaEndpoint(String endpointUri,
Component component,
BlockingQueue<Exchange> queue,
int concurrentConsumers)
public SedaEndpoint(String endpointUri,
BlockingQueue<Exchange> queue)
public SedaEndpoint(String endpointUri,
BlockingQueue<Exchange> queue,
int concurrentConsumers)
| Method Detail |
|---|
public Producer createProducer()
throws Exception
Endpoint
createProducer in interface EndpointException - can be thrown
public Consumer createConsumer(Processor processor)
throws Exception
Endpoint
createConsumer in interface Endpointprocessor - the given processor
Exception - can be thrownpublic BlockingQueue<Exchange> getQueue()
public void setQueue(BlockingQueue<Exchange> queue)
public int getSize()
public void setSize(int size)
public void setConcurrentConsumers(int concurrentConsumers)
public int getConcurrentConsumers()
public WaitForTaskToComplete getWaitForTaskToComplete()
public void setWaitForTaskToComplete(WaitForTaskToComplete waitForTaskToComplete)
public long getTimeout()
public void setTimeout(long timeout)
public boolean isSingleton()
IsSingleton
isSingleton in interface IsSingletonpublic List<Exchange> getExchanges()
getExchanges in interface BrowsableEndpointpublic Set<SedaConsumer> getConsumers()
public Set<SedaProducer> getProducers()
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||