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

Class HttpRestR66Client

java.lang.Object

org.waarp.gateway.kernel.rest.client.HttpRestClientHelper

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

public class HttpRestR66Client
extends HttpRestClientHelper

Http Rest R66 client helper class

Constructor Summary

Constructors

Constructor and Description
HttpRestR66Client(String baseUri, io.netty.channel.ChannelInitializer<io.netty.channel.socket.SocketChannel> initializer, int client, long timeout) Prepare the future connection

Method Summary

Modifier and Type	Method and Description
AbstractDbData	getDbDataFromFuture(DbSession dbSession, RestFuture future)
JsonPacket	getJsonPacketFromFuture(RestFuture future)
String	getPrimaryProperty(RestArgument bodyResponse)
String	getPrimaryPropertyName(String model)
HttpRestR66Handler.RESTHANDLERS	getRestHandler(RestArgument bodyResponse)
RestFuture	sendQuery(RestConfiguration config, io.netty.channel.Channel channel, io.netty.handler.codec.http.HttpMethod method, String host, String addedUri, String user, String pwd, Map<String,String> uriArgs, String json) Send an HTTP query using the channel for target

Methods inherited from class org.waarp.gateway.kernel.rest.client.HttpRestClientHelper

closeAll, getChannel, main, sendQuery, sendQuery

Methods inherited from class java.lang.Object

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

Constructor Detail

HttpRestR66Client

public HttpRestR66Client(String baseUri,
                         io.netty.channel.ChannelInitializer<io.netty.channel.socket.SocketChannel> initializer,
                         int client,
                         long timeout)

Prepare the future connection

Parameters:

baseUri - in general = '/'

initializer - the associated Initializer including the REST handler for client side

client - limit number of concurrent connected clients

timeout - time out for network connection

Method Detail

sendQuery

public RestFuture sendQuery(RestConfiguration config,
                            io.netty.channel.Channel channel,
                            io.netty.handler.codec.http.HttpMethod method,
                            String host,
                            String addedUri,
                            String user,
                            String pwd,
                            Map<String,String> uriArgs,
                            String json)

Send an HTTP query using the channel for target

Parameters:

config - configuration for REST service

channel - target of the query

method - HttpMethod to use

host - target of the query (shall be the same as for the channel)

addedUri - additional uri, added to baseUri (shall include also extra arguments) (might be null)

user - user to use in authenticated Rest procedure (might be null)

pwd - password to use in authenticated Rest procedure (might be null)

uriArgs - arguments for Uri if any (might be null)

json - json to send as body in the request (might be null); Useful in PUT, POST but should not in GET, DELETE, OPTIONS

Returns:

the RestFuture associated with this request

getRestHandler

public HttpRestR66Handler.RESTHANDLERS getRestHandler(RestArgument bodyResponse)

Parameters:

bodyResponse -

Returns:

the associated RESTHANDLERS if any, else null

getPrimaryProperty

public String getPrimaryProperty(RestArgument bodyResponse)

Parameters:

bodyResponse -

Returns:

the primary property value associated with the Model (from the bodyResponse), else null

getPrimaryPropertyName

public String getPrimaryPropertyName(String model)

Parameters:

model -

Returns:

the primary property name associated with the Model

getDbDataFromFuture

public AbstractDbData getDbDataFromFuture(DbSession dbSession,
                                          RestFuture future)
                                   throws HttpIncorrectRequestException

Parameters:

dbSession -

future -

Returns:

the DbData allocated from result if any, else null

Throws:

HttpIncorrectRequestException

getJsonPacketFromFuture

public JsonPacket getJsonPacketFromFuture(RestFuture future)
                                   throws HttpIncorrectRequestException

Parameters:

future -

Returns:

the JsonPacket from result if any, else null

Throws:

HttpIncorrectRequestException