org.jboss.ws.core.client.transport

Class NettyClient

java.lang.Object

org.jboss.ws.core.client.transport.NettyClient

public class NettyClient
extends Object

A http client using Netty

Since:

29-Jun-2009

Author:

alessio.soldano@jboss.com

Field Summary

Fields

Modifier and Type	Field and Description
static String	PROTOCOL
static String	RESPONSE_CODE
static String	RESPONSE_CODE_MESSAGE
static String	RESPONSE_HEADERS

Constructor Summary

Constructors

Constructor and Description
NettyClient(Marshaller marshaller, UnMarshaller unmarshaller) Construct a Netty client with the provided marshaller/unmarshaller.

Method Summary

Methods

Modifier and Type	Method and Description
Integer	getChunkSize()
Object	invoke(Object reqMessage, String targetAddress, boolean oneway, Map<String,Object> additionalHeaders, Map<String,Object> callProps) Performs the invocation; a HTTP GET is performed when the reqMessage is null, otherwise a HTTP POST is performed.
protected void	setActualChunkedLength(org.jboss.netty.handler.codec.http.HttpRequest message, Map<String,Object> callProps) Set the actual chunk size according to the endpoint config overwrite and/or configured features.
protected void	setActualTimeout(Map<String,Object> callProps) Set the actual timeout according to specified caller properties
protected void	setAdditionalHeaders(org.jboss.netty.handler.codec.http.HttpMessage message, Map<String,Object> headers) Copy the provided additional headers to the Netty's HttpMessage.
protected void	setAuthorization(org.jboss.netty.handler.codec.http.HttpMessage message, Map<String,Object> callProps) Set the required headers in the Netty's HttpMessage to allow for proper authorization.
void	setChunkSize(Integer chunkSize) Set the chunk size for chunked transfer encoding.

Methods inherited from class java.lang.Object

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

Field Detail

RESPONSE_CODE

public static final String RESPONSE_CODE

See Also:

Constant Field Values

RESPONSE_CODE_MESSAGE

public static final String RESPONSE_CODE_MESSAGE

See Also:

Constant Field Values

PROTOCOL

public static final String PROTOCOL

See Also:

Constant Field Values

RESPONSE_HEADERS

public static final String RESPONSE_HEADERS

See Also:

Constant Field Values

Constructor Detail

NettyClient

public NettyClient(Marshaller marshaller,
           UnMarshaller unmarshaller)

Construct a Netty client with the provided marshaller/unmarshaller.

Parameters:

marshaller -

unmarshaller -

Method Detail

invoke

public Object invoke(Object reqMessage,
            String targetAddress,
            boolean oneway,
            Map<String,Object> additionalHeaders,
            Map<String,Object> callProps)
              throws IOException

Performs the invocation; a HTTP GET is performed when the reqMessage is null, otherwise a HTTP POST is performed.

Parameters:

reqMessage - The request message

targetAddress - The target address

oneway - True for one-way message exchanges and when maintaining sessions using cookies.

additionalHeaders - Additional http headers to be added to the request

callProps -

Returns:

Throws:

IOException

setActualChunkedLength

protected void setActualChunkedLength(org.jboss.netty.handler.codec.http.HttpRequest message,
                          Map<String,Object> callProps)

Set the actual chunk size according to the endpoint config overwrite and/or configured features.

Parameters:

message -

setActualTimeout

protected void setActualTimeout(Map<String,Object> callProps)

Set the actual timeout according to specified caller properties

Parameters:

callProps -

setAuthorization

protected void setAuthorization(org.jboss.netty.handler.codec.http.HttpMessage message,
                    Map<String,Object> callProps)
                         throws IOException

Set the required headers in the Netty's HttpMessage to allow for proper authorization.

Parameters:

message -

callProps -

Throws:

IOException

setAdditionalHeaders

protected void setAdditionalHeaders(org.jboss.netty.handler.codec.http.HttpMessage message,
                        Map<String,Object> headers)

Copy the provided additional headers to the Netty's HttpMessage.

Parameters:

message -

headers -

getChunkSize

public Integer getChunkSize()

Returns:

The current chunk size

setChunkSize

public void setChunkSize(Integer chunkSize)

Set the chunk size for chunked transfer encoding. The default chunk size is 1024 bytes.

Parameters:

chunkSize -