public class HBaseIdempotentRepository extends org.apache.camel.support.ServiceSupport implements org.apache.camel.spi.IdempotentRepository<Object>
Constructor and Description |
---|
HBaseIdempotentRepository(org.apache.hadoop.conf.Configuration configuration,
String tableName,
String family,
String qualifier) |
Modifier and Type | Method and Description |
---|---|
boolean |
add(Object o) |
void |
clear() |
boolean |
confirm(Object o) |
boolean |
contains(Object o) |
protected void |
doStart() |
protected void |
doStop() |
boolean |
remove(Object o) |
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
public HBaseIdempotentRepository(org.apache.hadoop.conf.Configuration configuration, String tableName, String family, String qualifier) throws IOException
IOException
public boolean add(Object o)
add
in interface org.apache.camel.spi.IdempotentRepository<Object>
public boolean contains(Object o)
contains
in interface org.apache.camel.spi.IdempotentRepository<Object>
public boolean remove(Object o)
remove
in interface org.apache.camel.spi.IdempotentRepository<Object>
public boolean confirm(Object o)
confirm
in interface org.apache.camel.spi.IdempotentRepository<Object>
public void clear()
clear
in interface org.apache.camel.spi.IdempotentRepository<Object>
protected void doStart() throws Exception
doStart
in class org.apache.camel.support.ServiceSupport
Exception
Apache Camel