org.apache.activemq.camel.component
Class JournalEndpoint

java.lang.Object
  extended by org.apache.camel.impl.DefaultEndpoint
      extended by 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


Constructor Summary
JournalEndpoint(String endpointUri, File directory)
           
JournalEndpoint(String uri, JournalComponent journalComponent, File directory)
           
 
Method Summary
protected  void activateConsumer(org.apache.camel.impl.DefaultConsumer consumer)
           
 org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor)
           
 org.apache.camel.Producer createProducer()
           
protected  void deactivateConsumer(org.apache.camel.impl.DefaultConsumer consumer)
           
protected  void decrementReference()
           
protected  void dispatchToConsumer()
           
 File getDirectory()
           
protected  void incrementReference()
           
 boolean isSingleton()
           
 boolean isSyncConsume()
           
 boolean isSyncProduce()
           
 void setSyncConsume(boolean syncConsume)
           
 void setSyncProduce(boolean syncProduce)
           
 
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
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 

Constructor Detail

JournalEndpoint

public JournalEndpoint(String uri,
                       JournalComponent journalComponent,
                       File directory)

JournalEndpoint

public JournalEndpoint(String endpointUri,
                       File directory)
Method Detail

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.