Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- class MyRetryPolicy(maxRetries: Int) extends RetryPolicy {
- override def onReadTimeout(statement: Statement,
- cl: ConsistencyLevel,
- requiredResponses: Int,
- receivedResponses: Int,
- dataRetrieved: Boolean,
- nbRetry: Int): RetryDecision = {
- if (nbRetry < maxRetries) RetryDecision.retry(cl) else RetryDecision.rethrow()
- }
- override def onUnavailable(statement: Statement,
- cl: ConsistencyLevel,
- requiredReplica: Int,
- aliveReplica: Int,
- nbRetry: Int): RetryDecision = {
- if (nbRetry < maxRetries) RetryDecision.retry(cl) else RetryDecision.rethrow()
- }
- override def onWriteTimeout(statement: Statement,
- cl: ConsistencyLevel,
- writeType: WriteType,
- requiredAcks: Int,
- receivedAcks: Int,
- nbRetry: Int): RetryDecision = {
- if (nbRetry < maxRetries) RetryDecision.retry(cl) else RetryDecision.rethrow()
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement