org.apache.camel.component.hbase
Class HBaseConsumer

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.impl.ScheduledBatchPollingConsumer
                  extended by org.apache.camel.component.hbase.HBaseConsumer
All Implemented Interfaces:
Runnable, org.apache.camel.BatchConsumer, org.apache.camel.Consumer, org.apache.camel.PollingConsumerPollingStrategy, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.ShutdownAware, org.apache.camel.spi.ShutdownPrepared, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

public class HBaseConsumer
extends org.apache.camel.impl.ScheduledBatchPollingConsumer

The HBase consumer.


Field Summary
 
Fields inherited from class org.apache.camel.impl.ScheduledBatchPollingConsumer
maxMessagesPerPoll, pendingExchanges, shutdownRunningTask
 
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
HBaseConsumer(HBaseEndpoint endpoint, org.apache.camel.Processor processor, org.apache.hadoop.hbase.client.HTablePool tablePool, String tableName)
           
 
Method Summary
 HBaseRow getRowModel()
           
protected  int poll()
           
 int processBatch(Queue<Object> exchanges)
           
 void setRowModel(HBaseRow rowModel)
           
 
Methods inherited from class org.apache.camel.impl.ScheduledBatchPollingConsumer
deferShutdown, getMaxMessagesPerPoll, getPendingExchangesSize, isBatchAllowed, prepareShutdown, processEmptyMessage, setMaxMessagesPerPoll
 
Methods inherited from class org.apache.camel.impl.ScheduledPollConsumer
afterPoll, beforePoll, doShutdown, doStart, doStop, doSuspend, getDelay, getInitialDelay, getPollStrategy, getRunLoggingLevel, getScheduledExecutorService, getTimeUnit, isPollAllowed, isPolling, isSendEmptyMessageWhenIdle, isStartScheduler, isUseFixedDelay, onInit, 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.Consumer
getEndpoint
 
Methods inherited from interface org.apache.camel.Service
start, stop
 
Methods inherited from interface org.apache.camel.SuspendableService
isSuspended, resume, suspend
 

Constructor Detail

HBaseConsumer

public HBaseConsumer(HBaseEndpoint endpoint,
                     org.apache.camel.Processor processor,
                     org.apache.hadoop.hbase.client.HTablePool tablePool,
                     String tableName)
Method Detail

poll

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

processBatch

public int processBatch(Queue<Object> exchanges)
                 throws Exception
Throws:
Exception

getRowModel

public HBaseRow getRowModel()

setRowModel

public void setRowModel(HBaseRow rowModel)


Apache CAMEL