org.waarp.gateway.kernel.rest.client

Class HttpRestClientHelper

java.lang.Object

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

Direct Known Subclasses:

HttpRestR66Client

public class HttpRestClientHelper
extends Object

Http Rest Client helper

Constructor Summary

Constructors

Constructor and Description
HttpRestClientHelper(String baseUri, int nbclient, long timeout, io.netty.channel.ChannelInitializer<io.netty.channel.socket.SocketChannel> Initializer)

Method Summary

Modifier and Type	Method and Description
void	closeAll() Finalize the HttpRestClientHelper
io.netty.channel.Channel	getChannel(String host, int port) Create one new connection to the remote host using port
static void	main(String[] args)
RestFuture	sendQuery(io.netty.channel.Channel channel, io.netty.handler.codec.http.HttpMethod method, String host, String addedUri, String user, Map<String,String> uriArgs, String json) Send an HTTP query using the channel for target, but without any Signature
RestFuture	sendQuery(HmacSha256 hmacSha256, 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, using signature

Methods inherited from class java.lang.Object

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

Constructor Detail

HttpRestClientHelper

public HttpRestClientHelper(String baseUri,
                            int nbclient,
                            long timeout,
                            io.netty.channel.ChannelInitializer<io.netty.channel.socket.SocketChannel> Initializer)

Parameters:

baseUri - base of all URI, in general simply "/" (default if null)

nbclient - max number of client connected at once

timeout - timeout used in connection

Initializer - the associated client pipeline factory

Method Detail

getChannel

public io.netty.channel.Channel getChannel(String host,
                                           int port)

Create one new connection to the remote host using port

Parameters:

host -

port -

Returns:

the channel if connected or Null if not

sendQuery

public RestFuture sendQuery(HmacSha256 hmacSha256,
                            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, using signature

Parameters:

hmacSha256 - SHA-256 key to create the signature

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

sendQuery

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

Send an HTTP query using the channel for target, but without any Signature

Parameters:

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)

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

closeAll

public void closeAll()

Finalize the HttpRestClientHelper

main

public static void main(String[] args)

Parameters:

args - as uri (http://host:port/uri method user pwd sign=path|nosign [json])