public Promise<T> getNettyPromise() {
return promise;
}
public void handleRetry(Throwable cause) {
try {
<BUG>this.retryPolicy.retry(connectionState, retryHandler, new ConnectionFailHandler() {

@Override public void catchException(IOException exception) {
handleRetry(exception);
}
});</BUG>
} catch (RetryPolicy.RetryCancelled retryCancelled) {

public Promise<T> getNettyPromise() {
return promise;
}
public void handleRetry(Throwable cause) {
try {
this.retryPolicy.retry(connectionState, retryHandler, connectionFailHandler);
} catch (RetryPolicy.RetryCancelled retryCancelled) {
