org.apache.camel.component.paxlogging
Class PaxLoggingConsumer

java.lang.Object
  org.apache.camel.support.ServiceSupport
      org.apache.camel.impl.DefaultConsumer
          org.apache.camel.component.paxlogging.PaxLoggingConsumer

All Implemented Interfaces:

org.apache.camel.Consumer, org.apache.camel.RouteAware, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.StatefulService, org.apache.camel.SuspendableService, org.ops4j.pax.logging.spi.PaxAppender

public class PaxLoggingConsumer
extends org.apache.camel.impl.DefaultConsumer
implements org.ops4j.pax.logging.spi.PaxAppender

Paxlogging consumer. This camel consumer will register a paxlogging appender and will receive all logging events and send them into the route. To avoid generating new logging events from sending the message, an MDC attribute is set in the sending thread, and all log events from this thread are ignored. Camel exchanges are actually sent from a specific thread to make sure the log events are cleanly separated.

Field Summary

Fields inherited from class org.apache.camel.impl.DefaultConsumer

log

Fields inherited from class org.apache.camel.support.ServiceSupport

shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending

Constructor Summary

PaxLoggingConsumer(PaxLoggingEndpoint endpoint, org.apache.camel.Processor processor)

Method Summary

void	doAppend(org.ops4j.pax.logging.spi.PaxLoggingEvent paxLoggingEvent)
protected void	doStart()
protected void	doStop()
protected void	sendExchange(org.ops4j.pax.logging.spi.PaxLoggingEvent paxLoggingEvent)

Methods inherited from class org.apache.camel.impl.DefaultConsumer

createUoW, doneUoW, getAsyncProcessor, getEndpoint, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute, toString

Methods inherited from class org.apache.camel.support.ServiceSupport

doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.camel.Service

start, stop

Constructor Detail

PaxLoggingConsumer

public PaxLoggingConsumer(PaxLoggingEndpoint endpoint,
                          org.apache.camel.Processor processor)

Method Detail

doAppend

public void doAppend(org.ops4j.pax.logging.spi.PaxLoggingEvent paxLoggingEvent)

Specified by:

doAppend in interface org.ops4j.pax.logging.spi.PaxAppender

sendExchange

protected void sendExchange(org.ops4j.pax.logging.spi.PaxLoggingEvent paxLoggingEvent)

doStart

protected void doStart()
                throws Exception

Overrides:

doStart in class org.apache.camel.impl.DefaultConsumer

Throws:

Exception

doStop

protected void doStop()
               throws Exception

Overrides:

doStop in class org.apache.camel.impl.DefaultConsumer

Throws:

Exception