Class BrowseEndpoint
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.support.DefaultEndpoint
-
- org.apache.camel.component.browse.BrowseEndpoint
-
- All Implemented Interfaces:
AutoCloseable
,org.apache.camel.CamelContextAware
,org.apache.camel.Endpoint
,org.apache.camel.IsSingleton
,org.apache.camel.Service
,org.apache.camel.ShutdownableService
,org.apache.camel.spi.BrowsableEndpoint
,org.apache.camel.spi.HasId
,org.apache.camel.StatefulService
,org.apache.camel.SuspendableService
@UriEndpoint(firstVersion="1.3.0", scheme="browse", title="Browse", syntax="browse:name", category={CORE,MONITORING}) public class BrowseEndpoint extends org.apache.camel.support.DefaultEndpoint implements org.apache.camel.spi.BrowsableEndpoint
Inspect the messages received on endpoints supportingBrowsableEndpoint
. This can be useful for testing, visualisation tools or debugging. The exchanges sent to the endpoint are all available to be browsed.
-
-
Constructor Summary
Constructors Constructor Description BrowseEndpoint()
BrowseEndpoint(String uri, org.apache.camel.Component component)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.camel.Consumer
createConsumer(org.apache.camel.Processor processor)
protected List<org.apache.camel.Exchange>
createExchangeList()
org.apache.camel.Producer
createProducer()
protected void
doInit()
protected void
doStop()
List<org.apache.camel.Exchange>
getExchanges()
String
getName()
protected void
onExchange(org.apache.camel.Exchange exchange)
Invoked on a message exchange being sent by a producervoid
setName(String name)
-
Methods inherited from class org.apache.camel.support.DefaultEndpoint
configureConsumer, configureExchange, configurePollingConsumer, configureProperties, createAsyncProducer, createEndpointUri, createExchange, createExchange, createPollingConsumer, doStart, equals, getCamelContext, getComponent, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isAutowiredEnabled, isBridgeErrorHandler, isLazyStartProducer, isLenientProperties, isPollingConsumerBlockWhenFull, isPollingConsumerCopy, isSingleton, setAutowiredEnabled, setBridgeErrorHandler, setCamelContext, setComponent, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setLazyStartProducer, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerCopy, setPollingConsumerQueueSize, setProperties, toString
-
Methods inherited from class org.apache.camel.support.service.BaseService
build, doBuild, doFail, doLifecycleChange, doResume, doShutdown, doSuspend, fail, getStatus, init, isBuild, isInit, isNew, isRunAllowed, isShutdown, isStarted, isStarting, isStartingOrStarted, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.apache.camel.Endpoint
configureExchange, configureProperties, createAsyncProducer, createExchange, createExchange, createPollingConsumer, getCamelContext, getEndpointBaseUri, getEndpointKey, getEndpointUri, isLenientProperties, isSingletonProducer, setCamelContext
-
-
-
-
Constructor Detail
-
BrowseEndpoint
public BrowseEndpoint()
-
BrowseEndpoint
public BrowseEndpoint(String uri, org.apache.camel.Component component)
-
-
Method Detail
-
getExchanges
public List<org.apache.camel.Exchange> getExchanges()
- Specified by:
getExchanges
in interfaceorg.apache.camel.spi.BrowsableEndpoint
-
createProducer
public org.apache.camel.Producer createProducer() throws Exception
- Specified by:
createProducer
in interfaceorg.apache.camel.Endpoint
- Throws:
Exception
-
createConsumer
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
- Specified by:
createConsumer
in interfaceorg.apache.camel.Endpoint
- Throws:
Exception
-
getName
public String getName()
-
setName
public void setName(String name)
-
createExchangeList
protected List<org.apache.camel.Exchange> createExchangeList()
-
onExchange
protected void onExchange(org.apache.camel.Exchange exchange) throws Exception
Invoked on a message exchange being sent by a producer- Parameters:
exchange
- the exchange- Throws:
Exception
- is thrown if failed to process the exchange
-
doInit
protected void doInit() throws Exception
- Overrides:
doInit
in classorg.apache.camel.support.DefaultEndpoint
- Throws:
Exception
-
-