com.impetus.client.cassandra.service

Class CassandraRetryService

java.lang.Object

com.impetus.kundera.service.policy.RetryService

com.impetus.client.cassandra.service.CassandraRetryService

public class CassandraRetryService
extends RetryService

Cassandra retry service, retries for downed cassandra server with a fix delay, and add it to hostspool map when it up.

Author:

Kuldeep.Mishra

Field Summary

Fields inherited from class com.impetus.kundera.service.policy.RetryService

executor, retryDelayInSeconds, sf

Constructor Summary

Constructors

Constructor and Description
CassandraRetryService(HostConfiguration configuration, ClientFactory clientFactory)

Method Summary

Methods

Modifier and Type	Method and Description
void	add(CassandraHost cassandraHost)
void	shutdown()
protected boolean	verifyConnection(Host host)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CassandraRetryService

public CassandraRetryService(HostConfiguration configuration,
                     ClientFactory clientFactory)

Method Detail

verifyConnection

protected boolean verifyConnection(Host host)

Specified by:

verifyConnection in class RetryService

add

public void add(CassandraHost cassandraHost)

shutdown

public void shutdown()

Specified by:

shutdown in class RetryService