Class MllpConsumer
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.support.DefaultConsumer
-
- org.openehealth.ipf.platform.camel.ihe.mllp.core.MllpConsumer
-
- All Implemented Interfaces:
AutoCloseable
,org.apache.camel.Consumer
,org.apache.camel.EndpointAware
,org.apache.camel.RouteAware
,org.apache.camel.Service
,org.apache.camel.ShutdownableService
,org.apache.camel.spi.RouteIdAware
,org.apache.camel.StatefulService
,org.apache.camel.SuspendableService
public class MllpConsumer extends org.apache.camel.support.DefaultConsumer
MllpConsumer wraps a MinaConsumer for having a hook to shutdown some Mina resources when the consumer is closing
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.camel.spi.UnitOfWork
createUoW(org.apache.camel.Exchange exchange)
void
doneUoW(org.apache.camel.Exchange exchange)
protected void
doStop()
org.apache.mina.core.service.IoAcceptor
getAcceptor()
org.apache.camel.AsyncProcessor
getAsyncProcessor()
org.apache.camel.component.mina.MinaEndpoint
getEndpoint()
org.apache.camel.spi.ExceptionHandler
getExceptionHandler()
org.apache.camel.Processor
getProcessor()
org.apache.camel.Route
getRoute()
org.apache.camel.ServiceStatus
getStatus()
boolean
isRunAllowed()
boolean
isStarted()
boolean
isStarting()
boolean
isStopped()
boolean
isStopping()
boolean
isStoppingOrStopped()
boolean
isSuspended()
boolean
isSuspending()
boolean
isSuspendingOrSuspended()
void
resume()
void
setAcceptor(org.apache.mina.core.service.IoAcceptor acceptor)
void
setExceptionHandler(org.apache.camel.spi.ExceptionHandler exceptionHandler)
void
setRoute(org.apache.camel.Route route)
void
shutdown()
void
start()
void
stop()
void
suspend()
-
Methods inherited from class org.apache.camel.support.DefaultConsumer
doInit, doStart, getRouteId, handleException, handleException, setRouteId, toString
-
Methods inherited from class org.apache.camel.support.service.BaseService
build, doBuild, doFail, doLifecycleChange, doResume, doShutdown, doSuspend, fail, init, isBuild, isInit, isNew, isShutdown, isStartingOrStarted
-
-
-
-
Method Detail
-
start
public void start()
- Specified by:
start
in interfaceorg.apache.camel.Service
- Overrides:
start
in classorg.apache.camel.support.service.BaseService
-
getProcessor
public org.apache.camel.Processor getProcessor()
- Specified by:
getProcessor
in interfaceorg.apache.camel.Consumer
- Overrides:
getProcessor
in classorg.apache.camel.support.DefaultConsumer
-
getAsyncProcessor
public org.apache.camel.AsyncProcessor getAsyncProcessor()
- Overrides:
getAsyncProcessor
in classorg.apache.camel.support.DefaultConsumer
-
isSuspendingOrSuspended
public boolean isSuspendingOrSuspended()
- Overrides:
isSuspendingOrSuspended
in classorg.apache.camel.support.service.BaseService
-
getAcceptor
public org.apache.mina.core.service.IoAcceptor getAcceptor()
-
isSuspending
public boolean isSuspending()
- Specified by:
isSuspending
in interfaceorg.apache.camel.StatefulService
- Overrides:
isSuspending
in classorg.apache.camel.support.service.BaseService
-
isStoppingOrStopped
public boolean isStoppingOrStopped()
- Overrides:
isStoppingOrStopped
in classorg.apache.camel.support.service.BaseService
-
isStopping
public boolean isStopping()
- Specified by:
isStopping
in interfaceorg.apache.camel.StatefulService
- Overrides:
isStopping
in classorg.apache.camel.support.service.BaseService
-
getRoute
public org.apache.camel.Route getRoute()
- Specified by:
getRoute
in interfaceorg.apache.camel.RouteAware
- Overrides:
getRoute
in classorg.apache.camel.support.DefaultConsumer
-
setRoute
public void setRoute(org.apache.camel.Route route)
- Specified by:
setRoute
in interfaceorg.apache.camel.RouteAware
- Overrides:
setRoute
in classorg.apache.camel.support.DefaultConsumer
-
setExceptionHandler
public void setExceptionHandler(org.apache.camel.spi.ExceptionHandler exceptionHandler)
- Overrides:
setExceptionHandler
in classorg.apache.camel.support.DefaultConsumer
-
isStopped
public boolean isStopped()
- Specified by:
isStopped
in interfaceorg.apache.camel.StatefulService
- Overrides:
isStopped
in classorg.apache.camel.support.service.BaseService
-
isStarting
public boolean isStarting()
- Specified by:
isStarting
in interfaceorg.apache.camel.StatefulService
- Overrides:
isStarting
in classorg.apache.camel.support.service.BaseService
-
isRunAllowed
public boolean isRunAllowed()
- Specified by:
isRunAllowed
in interfaceorg.apache.camel.StatefulService
- Overrides:
isRunAllowed
in classorg.apache.camel.support.service.BaseService
-
setAcceptor
public void setAcceptor(org.apache.mina.core.service.IoAcceptor acceptor)
-
shutdown
public void shutdown()
- Specified by:
shutdown
in interfaceorg.apache.camel.ShutdownableService
- Overrides:
shutdown
in classorg.apache.camel.support.service.BaseService
-
createUoW
public org.apache.camel.spi.UnitOfWork createUoW(org.apache.camel.Exchange exchange) throws Exception
- Overrides:
createUoW
in classorg.apache.camel.support.DefaultConsumer
- Throws:
Exception
-
getStatus
public org.apache.camel.ServiceStatus getStatus()
- Specified by:
getStatus
in interfaceorg.apache.camel.StatefulService
- Overrides:
getStatus
in classorg.apache.camel.support.service.BaseService
-
resume
public void resume()
- Specified by:
resume
in interfaceorg.apache.camel.SuspendableService
- Overrides:
resume
in classorg.apache.camel.support.service.BaseService
-
getExceptionHandler
public org.apache.camel.spi.ExceptionHandler getExceptionHandler()
- Overrides:
getExceptionHandler
in classorg.apache.camel.support.DefaultConsumer
-
isSuspended
public boolean isSuspended()
- Specified by:
isSuspended
in interfaceorg.apache.camel.SuspendableService
- Overrides:
isSuspended
in classorg.apache.camel.support.service.BaseService
-
isStarted
public boolean isStarted()
- Specified by:
isStarted
in interfaceorg.apache.camel.StatefulService
- Overrides:
isStarted
in classorg.apache.camel.support.service.BaseService
-
getEndpoint
public org.apache.camel.component.mina.MinaEndpoint getEndpoint()
- Specified by:
getEndpoint
in interfaceorg.apache.camel.EndpointAware
- Overrides:
getEndpoint
in classorg.apache.camel.support.DefaultConsumer
-
doneUoW
public void doneUoW(org.apache.camel.Exchange exchange)
- Overrides:
doneUoW
in classorg.apache.camel.support.DefaultConsumer
-
suspend
public void suspend()
- Specified by:
suspend
in interfaceorg.apache.camel.SuspendableService
- Overrides:
suspend
in classorg.apache.camel.support.service.BaseService
-
stop
public void stop()
- Specified by:
stop
in interfaceorg.apache.camel.Service
- Overrides:
stop
in classorg.apache.camel.support.service.BaseService
-
-