org.apache.camel.component.snmp
Class SnmpOIDPoller

java.lang.Object
  extended by org.apache.camel.support.ServiceSupport
      extended by org.apache.camel.impl.DefaultConsumer
          extended by org.apache.camel.impl.ScheduledPollConsumer
              extended by org.apache.camel.component.snmp.SnmpOIDPoller
All Implemented Interfaces:
Runnable, EventListener, org.apache.camel.Consumer, org.apache.camel.PollingConsumerPollingStrategy, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.StatefulService, org.apache.camel.SuspendableService, org.snmp4j.event.ResponseListener

public class SnmpOIDPoller
extends org.apache.camel.impl.ScheduledPollConsumer
implements org.snmp4j.event.ResponseListener


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
SnmpOIDPoller(SnmpEndpoint endpoint, org.apache.camel.Processor processor)
           
 
Method Summary
protected  void doStart()
           
protected  void doStop()
           
 org.snmp4j.CommunityTarget getTarget()
           
 void onResponse(org.snmp4j.event.ResponseEvent event)
           
protected  int poll()
           
 void processPDU(org.snmp4j.PDU pdu)
          processes the pdu message
 void setTarget(org.snmp4j.CommunityTarget target)
           
 
Methods inherited from class org.apache.camel.impl.ScheduledPollConsumer
afterPoll, beforePoll, doShutdown, doSuspend, getDelay, getInitialDelay, getPollStrategy, getRunLoggingLevel, getScheduledExecutorService, getTimeUnit, isPollAllowed, isPolling, isSendEmptyMessageWhenIdle, isStartScheduler, isUseFixedDelay, onInit, processEmptyMessage, run, setDelay, setInitialDelay, setPollStrategy, setRunLoggingLevel, setScheduledExecutorService, setSendEmptyMessageWhenIdle, setStartScheduler, setTimeUnit, setUseFixedDelay, startScheduler
 
Methods inherited from class org.apache.camel.impl.DefaultConsumer
getAsyncProcessor, getEndpoint, getExceptionHandler, getProcessor, handleException, handleException, setExceptionHandler, toString
 
Methods inherited from class org.apache.camel.support.ServiceSupport
doResume, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, 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.SuspendableService
isSuspended, resume, suspend
 
Methods inherited from interface org.apache.camel.Service
start, stop
 

Constructor Detail

SnmpOIDPoller

public SnmpOIDPoller(SnmpEndpoint endpoint,
                     org.apache.camel.Processor processor)
Method Detail

doStart

protected void doStart()
                throws Exception
Overrides:
doStart in class org.apache.camel.impl.ScheduledPollConsumer
Throws:
Exception

doStop

protected void doStop()
               throws Exception
Overrides:
doStop in class org.apache.camel.impl.ScheduledPollConsumer
Throws:
Exception

poll

protected int poll()
            throws Exception
Specified by:
poll in class org.apache.camel.impl.ScheduledPollConsumer
Throws:
Exception

onResponse

public void onResponse(org.snmp4j.event.ResponseEvent event)
Specified by:
onResponse in interface org.snmp4j.event.ResponseListener

processPDU

public void processPDU(org.snmp4j.PDU pdu)
processes the pdu message

Parameters:
pdu - the pdu

getTarget

public org.snmp4j.CommunityTarget getTarget()
Returns:
Returns the target.

setTarget

public void setTarget(org.snmp4j.CommunityTarget target)
Parameters:
target - The target to set.


Apache CAMEL