org.apache.camel.processor.idempotent.hazelcast
Class HazelcastIdempotentRepository

java.lang.Object
  org.apache.camel.support.ServiceSupport
      org.apache.camel.processor.idempotent.hazelcast.HazelcastIdempotentRepository

All Implemented Interfaces:

org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.IdempotentRepository<String>, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

public class HazelcastIdempotentRepository
extends org.apache.camel.support.ServiceSupport
implements org.apache.camel.spi.IdempotentRepository<String>

Field Summary

Fields inherited from class org.apache.camel.support.ServiceSupport

shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending

Constructor Summary

HazelcastIdempotentRepository(com.hazelcast.core.HazelcastInstance hazelcastInstance)

HazelcastIdempotentRepository(com.hazelcast.core.HazelcastInstance hazelcastInstance, String repositoryName)

Method Summary

boolean	add(String key)
boolean	confirm(String key)
boolean	contains(String key)
protected void	doStart()
protected void	doStop()
String	getRepositoryName()
boolean	remove(String key)

Methods inherited from class org.apache.camel.support.ServiceSupport

doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, 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

HazelcastIdempotentRepository

public HazelcastIdempotentRepository(com.hazelcast.core.HazelcastInstance hazelcastInstance)

HazelcastIdempotentRepository

public HazelcastIdempotentRepository(com.hazelcast.core.HazelcastInstance hazelcastInstance,
                                     String repositoryName)

Method Detail

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

add

public boolean add(String key)

Specified by:

add in interface org.apache.camel.spi.IdempotentRepository<String>

confirm

public boolean confirm(String key)

Specified by:

confirm in interface org.apache.camel.spi.IdempotentRepository<String>

contains

public boolean contains(String key)

Specified by:

contains in interface org.apache.camel.spi.IdempotentRepository<String>

remove

public boolean remove(String key)

Specified by:

remove in interface org.apache.camel.spi.IdempotentRepository<String>

getRepositoryName

public String getRepositoryName()