Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Any one maintain this project? #446

Open
linking12 opened this issue Jan 19, 2021 · 0 comments
Open

Any one maintain this project? #446

linking12 opened this issue Jan 19, 2021 · 0 comments

Comments

@linking12
Copy link

 @Override
    public ChannelFuture writeHttp(HttpObject httpObject) {
        if (httpObject instanceof HttpRequest) {
            startReadTimeoutHandler();
            HttpRequest httpRequest = (HttpRequest)httpObject;
            currentHttpRequest = httpRequest;
        }
        ChannelFuture channelFuture = super.writeHttp(httpObject);
        channelFuture.addListener(new ChannelFutureListener() {

            @Override
            public void operationComplete(ChannelFuture future) throws Exception {
                 if (!future.isSuccess()) {
                        LOG.error("Attempted to writeHttp to origin server failed, The cause is: ", future.cause());
                        timedOut();
                    }
            }
        });
        return channelFuture;
    }

when the channel is disconnected in write, can retry?

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant