org.neociclo.accord.odetteftp.camel
Class OdetteConsumer

java.lang.Object
  extended by org.apache.camel.impl.ServiceSupport
      extended by org.apache.camel.impl.DefaultConsumer
          extended by org.apache.camel.impl.ScheduledPollConsumer
              extended by org.neociclo.accord.odetteftp.camel.OdetteConsumer
All Implemented Interfaces:
Runnable, org.apache.camel.Consumer, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.SuspendableService

public class OdetteConsumer
extends org.apache.camel.impl.ScheduledPollConsumer

The Odette FTP Poll Consumer will connect to an Odette server and consume incoming files or delivery notifications. If the Odette FTP Producer associated to the same endpoint receives files or notifications to be sent, they will during the same session

Author:
bruno

Field Summary
 
Fields inherited from class org.apache.camel.impl.DefaultConsumer
log
 
Constructor Summary
OdetteConsumer(OdetteEndpoint endpoint, org.apache.camel.Processor processor, OdetteOperations operations)
           
 
Method Summary
protected  void poll()
           
 void processOdetteMessage(DeliveryNotification notif)
           
 void processOdetteMessage(VirtualFile incomingVirtualFile)
           Consumes data from the Odette server
 
Methods inherited from class org.apache.camel.impl.ScheduledPollConsumer
doStart, doStop, getDelay, getInitialDelay, getPollStrategy, getTimeUnit, isPollAllowed, isSuspended, isUseFixedDelay, resume, run, setDelay, setInitialDelay, setPollStrategy, setTimeUnit, setUseFixedDelay, suspend
 
Methods inherited from class org.apache.camel.impl.DefaultConsumer
getAsyncProcessor, getEndpoint, getExceptionHandler, getProcessor, handleException, setExceptionHandler, toString
 
Methods inherited from class org.apache.camel.impl.ServiceSupport
addChildService, doShutdown, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, removeChildService, shutdown, start, stop
 
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

OdetteConsumer

public OdetteConsumer(OdetteEndpoint endpoint,
                      org.apache.camel.Processor processor,
                      OdetteOperations operations)
Method Detail

processOdetteMessage

public void processOdetteMessage(VirtualFile incomingVirtualFile)

Consumes data from the Odette server

Parameters:
incomingVirtualFile -
om -

poll

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

processOdetteMessage

public void processOdetteMessage(DeliveryNotification notif)


ACCORD