org.apache.activemq.camel.component
Class JournalEndpoint
java.lang.Object
org.apache.camel.impl.DefaultEndpoint
org.apache.activemq.camel.component.JournalEndpoint
- All Implemented Interfaces:
- org.apache.camel.CamelContextAware, org.apache.camel.Endpoint, org.apache.camel.IsSingleton, org.apache.camel.Service, org.apache.camel.spi.HasId
public class JournalEndpoint
- extends org.apache.camel.impl.DefaultEndpoint
Methods inherited from class org.apache.camel.impl.DefaultEndpoint |
configureProperties, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, equals, getCamelContext, getComponent, getEndpointKey, getEndpointUri, getExchangePattern, getExchangeType, getId, hashCode, isLenientProperties, isSynchronous, sanitizeUri, setCamelContext, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setSynchronous, start, stop, toString |
JournalEndpoint
public JournalEndpoint(String uri,
JournalComponent journalComponent,
File directory)
JournalEndpoint
public JournalEndpoint(String endpointUri,
File directory)
isSingleton
public boolean isSingleton()
getDirectory
public File getDirectory()
createConsumer
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor)
throws Exception
- Throws:
Exception
decrementReference
protected void decrementReference()
throws IOException
- Throws:
IOException
incrementReference
protected void incrementReference()
throws IOException
- Throws:
IOException
deactivateConsumer
protected void deactivateConsumer(org.apache.camel.impl.DefaultConsumer consumer)
throws IOException
- Throws:
IOException
activateConsumer
protected void activateConsumer(org.apache.camel.impl.DefaultConsumer consumer)
throws IOException
- Throws:
IOException
dispatchToConsumer
protected void dispatchToConsumer()
createProducer
public org.apache.camel.Producer createProducer()
throws Exception
- Throws:
Exception
isSyncConsume
public boolean isSyncConsume()
setSyncConsume
public void setSyncConsume(boolean syncConsume)
isSyncProduce
public boolean isSyncProduce()
setSyncProduce
public void setSyncProduce(boolean syncProduce)
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.