org.apache.camel.component.hbase.processor.idempotent
Class HBaseIdempotentRepository

java.lang.Object
  extended by org.apache.camel.support.ServiceSupport
      extended by org.apache.camel.component.hbase.processor.idempotent.HBaseIdempotentRepository
All Implemented Interfaces:
org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.IdempotentRepository<Object>, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

public class HBaseIdempotentRepository
extends org.apache.camel.support.ServiceSupport
implements org.apache.camel.spi.IdempotentRepository<Object>


Field Summary
 
Fields inherited from class org.apache.camel.support.ServiceSupport
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending
 
Constructor Summary
HBaseIdempotentRepository(org.apache.hadoop.conf.Configuration configuration, String tableName, String family, String qualifier)
           
 
Method Summary
 boolean add(Object o)
           
 boolean confirm(Object o)
           
 boolean contains(Object o)
           
protected  void doStart()
           
protected  void doStop()
           
 boolean remove(Object o)
           
 
Methods inherited from class org.apache.camel.support.ServiceSupport
doResume, doShutdown, doSuspend, 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, toString, wait, wait, wait
 
Methods inherited from interface org.apache.camel.Service
start, stop
 

Constructor Detail

HBaseIdempotentRepository

public HBaseIdempotentRepository(org.apache.hadoop.conf.Configuration configuration,
                                 String tableName,
                                 String family,
                                 String qualifier)
                          throws IOException
Throws:
IOException
Method Detail

add

public boolean add(Object o)
Specified by:
add in interface org.apache.camel.spi.IdempotentRepository<Object>

contains

public boolean contains(Object o)
Specified by:
contains in interface org.apache.camel.spi.IdempotentRepository<Object>

remove

public boolean remove(Object o)
Specified by:
remove in interface org.apache.camel.spi.IdempotentRepository<Object>

confirm

public boolean confirm(Object o)
Specified by:
confirm in interface org.apache.camel.spi.IdempotentRepository<Object>

doStart

protected void doStart()
                throws Exception
Specified by:
doStart in class org.apache.camel.support.ServiceSupport
Throws:
Exception

doStop

protected void doStop()
               throws Exception
Specified by:
doStop in class org.apache.camel.support.ServiceSupport
Throws:
Exception


Apache CAMEL