public class NettyTransportHandler extends Object
Modifier and Type | Method and Description |
---|---|
protected void |
checkKeepAliveHeaders(Map<String,Object> metadata,
Map<String,Object> headers)
Update the keep-alive status according to the received message's headers.
|
void |
end()
End the transport handler, closing the underlying connection.
|
void |
finished(Map<String,Object> metadata,
Map<String,Object> headers)
Signal end of processing for the current connection.
|
org.jboss.netty.channel.Channel |
getChannel()
Get the channel for using the http connection
|
org.jboss.netty.channel.Channel |
getChannel(Long timeout)
Get the channel for using the http connection
|
static boolean |
getHttpKeepAliveSet() |
static NettyTransportHandler |
getInstance(URL url,
boolean useCache,
org.jboss.netty.channel.ChannelPipelineFactory pipelineFactory) |
static NettyTransportHandler |
getInstance(URL url,
org.jboss.netty.channel.ChannelPipelineFactory pipelineFactory) |
int |
getKeepAliveTimeout() |
URL |
getUrl() |
void |
goOn(Map<String,Object> metadata,
Map<String,Object> headers)
Signal an invocation has been done using the current connection,
but we're going on using it.
|
protected boolean |
isKeepingAlive() |
protected void |
putInKeepAliveCache() |
void |
setKeepAliveConnections(int keepAliveConnections) |
public static NettyTransportHandler getInstance(URL url, org.jboss.netty.channel.ChannelPipelineFactory pipelineFactory)
public static NettyTransportHandler getInstance(URL url, boolean useCache, org.jboss.netty.channel.ChannelPipelineFactory pipelineFactory)
public org.jboss.netty.channel.Channel getChannel() throws ConnectException
IOException
ConnectException
public org.jboss.netty.channel.Channel getChannel(Long timeout) throws ConnectException
timeout
- IOException
ConnectException
public void goOn(Map<String,Object> metadata, Map<String,Object> headers)
headers
- The received message's headerspublic void finished(Map<String,Object> metadata, Map<String,Object> headers)
headers
- The received message's headersprotected void checkKeepAliveHeaders(Map<String,Object> metadata, Map<String,Object> headers)
headers
- The received message's headersprotected void putInKeepAliveCache()
public void end()
public static boolean getHttpKeepAliveSet()
protected boolean isKeepingAlive()
public int getKeepAliveTimeout()
public URL getUrl()
public void setKeepAliveConnections(int keepAliveConnections)
Copyright © 2013 JBoss, by Red Hat. All Rights Reserved.