Commit16550ec

Stephane Landelle

committed

Add new onRetry callback method forAsyncHttpClient#435

1 parent1fa45b4 commit16550ecCopy full SHA for 16550ec

File tree

+11

-1

lines changed

+11

-1

lines changed

Lines changed: 5 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -19,7 +19,6 @@`
`19`	`19`	`*`
`20`	`20`	`* More additional hooks might come, such as:`
`21`	`21`	`* <ul>`
`22`		`- * <li>onRetry()</li>`
`23`	`22`	`* <li>onConnected()</li>`
`24`	`23`	`* <li>onConnectionClosed()</li>`
`25`	`24`	`* <li>onBytesSent(long numberOfBytes)</li>`
`@@ -35,4 +34,9 @@ public interface AsyncHandlerExtensions {`
`35`	`34`	`* Currently only supported by the Netty provider.`
`36`	`35`	`*/`
`37`	`36`	`voidonRequestSent();`
	`37`	`+`
	`38`	`+/**`
	`39`	`+ * Notify the callback every time a request is being retried.`
	`40`	`+ */`
	`41`	`+voidonRetry();`
`38`	`42`	`}`

Lines changed: 6 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -1297,6 +1297,9 @@ private FilterContext handleIoException(FilterContext fc, NettyResponseFuture<?>`
`1297`	`1297`	`}`
`1298`	`1298`
`1299`	`1299`	`privatevoidreplayRequest(finalNettyResponseFuture<?>future,FilterContextfc,HttpResponseresponse,ChannelHandlerContextctx)throwsIOException {`
	`1300`	`+if (future.getAsyncHandler()instanceofAsyncHandlerExtensions) {`
	`1301`	`+AsyncHandlerExtensions.class.cast(future.getAsyncHandler()).onRetry();`
	`1302`	`+ }`
`1300`	`1303`	`finalRequestnewRequest =fc.getRequest();`
`1301`	`1304`	`future.setAsyncHandler(fc.getAsyncHandler());`
`1302`	`1305`	`future.setState(NettyResponseFuture.STATE.NEW);`
`@@ -1430,6 +1433,9 @@ protected boolean remotelyClosed(Channel channel, NettyResponseFuture<?> future)`
`1430`	`1433`	`future.setState(NettyResponseFuture.STATE.RECONNECTED);`
`1431`	`1434`
`1432`	`1435`	`log.debug("Trying to recover request {}\n",future.getNettyRequest());`
	`1436`	`+if (future.getAsyncHandler()instanceofAsyncHandlerExtensions) {`
	`1437`	`+AsyncHandlerExtensions.class.cast(future.getAsyncHandler()).onRetry();`
	`1438`	`+ }`
`1433`	`1439`
`1434`	`1440`	`try {`
`1435`	`1441`	`nextRequest(future.getRequest(),future);`

Comments

(0)