org.waarp.openr66.protocol.http.rest.client

Class HttpRestR66ClientResponseHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.channel.SimpleChannelInboundHandler<io.netty.handler.codec.http.HttpObject>

org.waarp.openr66.protocol.http.rest.client.HttpRestR66ClientResponseHandler

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler

public abstract class HttpRestR66ClientResponseHandler
extends io.netty.channel.SimpleChannelInboundHandler<io.netty.handler.codec.http.HttpObject>

Rest client response handler.

Note: by default, no connection are closed except in case of error or if in HTTP 1.0 or explicitly to be closed.

Nested Class Summary

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field and Description
protected com.fasterxml.jackson.databind.JsonNode	jsonObject

Constructor Summary

Constructors

Constructor and Description
HttpRestR66ClientResponseHandler()

Method Summary

Modifier and Type	Method and Description
protected abstract boolean	action(io.netty.channel.Channel channel, RestArgument ra, HttpRestAbstractR66Handler.ACTIONS_TYPE act) Method calls when a action REST command is raised as answer
protected void	actionFromResponse(io.netty.channel.Channel channel) Setting the RestArgument to the RestFuture and validating RestFuture.
protected void	addContent(io.netty.handler.codec.http.FullHttpResponse response)
protected abstract boolean	afterDbDelete(io.netty.channel.Channel channel, RestArgument ra) Method calls when a REST Delete command is raised as answer
protected abstract boolean	afterDbGet(io.netty.channel.Channel channel, RestArgument ra) Method calls when a REST Get command is raised as answer
protected abstract boolean	afterDbGetMultiple(io.netty.channel.Channel channel, RestArgument ra) Method calls when a REST GetMultiple command is raised as answer
protected abstract boolean	afterDbOptions(io.netty.channel.Channel channel, RestArgument ra) Method calls when a REST Options command is raised as answer
protected abstract boolean	afterDbPost(io.netty.channel.Channel channel, RestArgument ra) Method calls when a REST Post command is raised as answer
protected abstract boolean	afterDbPut(io.netty.channel.Channel channel, RestArgument ra) Method calls when a REST Put command is raised as answer
protected abstract boolean	afterError(io.netty.channel.Channel channel, RestArgument ra) Method calls when a REST command is in error
protected void	channelRead0(io.netty.channel.ChannelHandlerContext ctx, io.netty.handler.codec.http.HttpObject msg)
protected boolean	delete(io.netty.channel.Channel channel, RestArgument ra)
void	exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause)
protected boolean	get(io.netty.channel.Channel channel, RestArgument ra)
protected boolean	options(io.netty.channel.Channel channel, RestArgument ra)
protected boolean	post(io.netty.channel.Channel channel, RestArgument ra)
protected boolean	put(io.netty.channel.Channel channel, RestArgument ra)

Methods inherited from class io.netty.channel.SimpleChannelInboundHandler

acceptInboundMessage, channelRead

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, handlerAdded, handlerRemoved, isSharable

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.netty.channel.ChannelHandler

handlerAdded, handlerRemoved

Field Detail

jsonObject

protected com.fasterxml.jackson.databind.JsonNode jsonObject

Constructor Detail

HttpRestR66ClientResponseHandler

public HttpRestR66ClientResponseHandler()

Method Detail

addContent

protected void addContent(io.netty.handler.codec.http.FullHttpResponse response)
                   throws HttpIncorrectRequestException

Throws:

HttpIncorrectRequestException

actionFromResponse

protected void actionFromResponse(io.netty.channel.Channel channel)
                           throws HttpInvalidAuthenticationException

Setting the RestArgument to the RestFuture and validating RestFuture.

Parameters:

channel -

Throws:

HttpInvalidAuthenticationException

action

protected abstract boolean action(io.netty.channel.Channel channel,
                                  RestArgument ra,
                                  HttpRestAbstractR66Handler.ACTIONS_TYPE act)
                           throws HttpInvalidAuthenticationException

Method calls when a action REST command is raised as answer

Parameters:

channel -

ra -

act -

Returns:

if validation is done (or suppose to be)

Throws:

HttpInvalidAuthenticationException

afterDbGet

protected abstract boolean afterDbGet(io.netty.channel.Channel channel,
                                      RestArgument ra)
                               throws HttpInvalidAuthenticationException

Method calls when a REST Get command is raised as answer

Parameters:

channel -

ra -

Returns:

if validation is done (or suppose to be)

Throws:

HttpInvalidAuthenticationException

afterDbPost

protected abstract boolean afterDbPost(io.netty.channel.Channel channel,
                                       RestArgument ra)
                                throws HttpInvalidAuthenticationException

Method calls when a REST Post command is raised as answer

Parameters:

channel -

ra -

Returns:

if validation is done (or suppose to be)

Throws:

HttpInvalidAuthenticationException

afterDbPut

protected abstract boolean afterDbPut(io.netty.channel.Channel channel,
                                      RestArgument ra)
                               throws HttpInvalidAuthenticationException

Method calls when a REST Put command is raised as answer

Parameters:

channel -

ra -

Returns:

if validation is done (or suppose to be)

Throws:

HttpInvalidAuthenticationException

afterDbDelete

protected abstract boolean afterDbDelete(io.netty.channel.Channel channel,
                                         RestArgument ra)
                                  throws HttpInvalidAuthenticationException

Method calls when a REST Delete command is raised as answer

Parameters:

channel -

ra -

Returns:

if validation is done (or suppose to be)

Throws:

HttpInvalidAuthenticationException

afterDbGetMultiple

protected abstract boolean afterDbGetMultiple(io.netty.channel.Channel channel,
                                              RestArgument ra)
                                       throws HttpInvalidAuthenticationException

Method calls when a REST GetMultiple command is raised as answer

Parameters:

channel -

ra -

Returns:

if validation is done (or suppose to be)

Throws:

HttpInvalidAuthenticationException

afterDbOptions

protected abstract boolean afterDbOptions(io.netty.channel.Channel channel,
                                          RestArgument ra)
                                   throws HttpInvalidAuthenticationException

Method calls when a REST Options command is raised as answer

Parameters:

channel -

ra -

Returns:

if validation is done (or suppose to be)

Throws:

HttpInvalidAuthenticationException

afterError

protected abstract boolean afterError(io.netty.channel.Channel channel,
                                      RestArgument ra)
                               throws HttpInvalidAuthenticationException

Method calls when a REST command is in error

Parameters:

channel -

ra - (might be null)

Returns:

if validation is done (or suppose to be)

Throws:

HttpInvalidAuthenticationException

get

protected boolean get(io.netty.channel.Channel channel,
                      RestArgument ra)
               throws HttpInvalidAuthenticationException

Throws:

HttpInvalidAuthenticationException

put

protected boolean put(io.netty.channel.Channel channel,
                      RestArgument ra)
               throws HttpInvalidAuthenticationException

Throws:

HttpInvalidAuthenticationException

post

protected boolean post(io.netty.channel.Channel channel,
                       RestArgument ra)
                throws HttpInvalidAuthenticationException

Throws:

HttpInvalidAuthenticationException

delete

protected boolean delete(io.netty.channel.Channel channel,
                         RestArgument ra)
                  throws HttpInvalidAuthenticationException

Throws:

HttpInvalidAuthenticationException

options

protected boolean options(io.netty.channel.Channel channel,
                          RestArgument ra)
                   throws HttpInvalidAuthenticationException

Throws:

HttpInvalidAuthenticationException

channelRead0

protected void channelRead0(io.netty.channel.ChannelHandlerContext ctx,
                            io.netty.handler.codec.http.HttpObject msg)
                     throws Exception

Specified by:

channelRead0 in class io.netty.channel.SimpleChannelInboundHandler<io.netty.handler.codec.http.HttpObject>

Throws:

Exception

exceptionCaught

public void exceptionCaught(io.netty.channel.ChannelHandlerContext ctx,
                            Throwable cause)
                     throws Exception

Specified by:

exceptionCaught in interface io.netty.channel.ChannelHandler

Specified by:

exceptionCaught in interface io.netty.channel.ChannelInboundHandler

Overrides:

exceptionCaught in class io.netty.channel.ChannelInboundHandlerAdapter

Throws:

Exception