org.adroitlogic.ultraesb.transport.http
Class HttpNIOSender

java.lang.Object
  org.adroitlogic.ultraesb.core.config.AbstractConfigurationElement
      org.adroitlogic.ultraesb.transport.base.AbstractTransportSender
          org.adroitlogic.ultraesb.transport.http.HttpNIOSender

All Implemented Interfaces:

ConfigurationElement, org.adroitlogic.ultraesb.transport.base.ManagementSupport, org.springframework.beans.factory.BeanNameAware, org.springframework.context.ApplicationContextAware

Direct Known Subclasses:

HttpsNIOSender

public class HttpNIOSender
extends org.adroitlogic.ultraesb.transport.base.AbstractTransportSender
implements org.adroitlogic.ultraesb.transport.base.ManagementSupport

The HTTP transport sender

Nested Class Summary

Nested classes/interfaces inherited from interface org.adroitlogic.ultraesb.api.ConfigurationElement

ConfigurationElement.State

Field Summary

Fields inherited from class org.adroitlogic.ultraesb.transport.base.AbstractTransportSender

logger, metrics, originatingTransport, properties

Fields inherited from class org.adroitlogic.ultraesb.core.config.AbstractConfigurationElement

config, ctx, debugOn, derivedName, id, outdated, state

Constructor Summary

HttpNIOSender(FileCache fileCache)
The default constructor, accepting the FileCache to use

Method Summary

void	setConnectionDebugHeaders(java.util.Set connectionDebugHeaders) Sets the list of HTTP headers to be dumped on a connection failure, when connection debugging is enabled
void	setContinueOnCheckedExceptions(boolean continueOnCheckedExceptions) Control behavior of engine on checked exceptions
void	setContinueOnRuntimeExceptions(boolean continueOnRuntimeExceptions) Control behavior of engine on runtime exceptions (WARNING: It maybe dangerous to ignore runtime exceptions)
void	setEnableConnectionDebug(boolean enableConnectionDebug) Debug connection information on errors
void	setKeepalive(int keepalive) Set the default keepalive time for connections kept for reuse.
void	setKeepAliveSafetyThreshold(int keepAliveSafetyThreshold) Set the keep-alive safety threshold to not use a connection, when the keep-alive window is about to end
void	setProxyBypassList(java.lang.String[] proxyBypassList) A list of addresses for which to bypass the proxy and go direct
void	setProxyHost(java.lang.String proxyHost) HTTP proxy hostname
void	setProxyPort(int proxyPort) HTTP proxy port
void	setReplaceUserAgent(boolean replaceUserAgent) Replace the user agent header on requests sent to indicate UltraESB
void	setUnzipResponseEntities(boolean unzipResponseEntities) Unzip compressed responses.
void	setZeroCopyEnabled(boolean zeroCopyEnabled) Turn on/off use of Zero-Copy
void	toDetailedViewExt(org.adroitlogic.ultraesb.jmx.view.TransportView view)

Methods inherited from class org.adroitlogic.ultraesb.transport.base.AbstractTransportSender

getAvgSizeReceived, getAvgSizeSent, getBytesReceived, getBytesSent, getDetails, getFaultsReceiving, getFaultsSending, getLastResetTime, getMaxSizeReceived, getMaxSizeSent, getMessagesReceived, getMessagesSent, getMetricsWindow, getMinSizeReceived, getMinSizeSent, getReceiveErrorCodeTable, getSendErrorCodeTable, getTimeoutsReceiving, getTimeoutsSending, pause, resetStatistics, resume, setProperties, stop, toBasicView, toDetailedView

Methods inherited from class org.adroitlogic.ultraesb.core.config.AbstractConfigurationElement

equals, getAppCtx, getDerivedName, getId, getState, hashCode, isDebugOn, isStarted, maintenanceShutdown, markAsOutdated, setApplicationContext, setBeanName, setConfig, setDebugOn, setDerivedName, setId, setState, start, throwIllegalStateException, undeploy

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.adroitlogic.ultraesb.transport.base.ManagementSupport

getAvgSizeReceived, getAvgSizeSent, getBytesReceived, getBytesSent, getFaultsReceiving, getFaultsSending, getLastResetTime, getMaxSizeReceived, getMaxSizeSent, getMessagesReceived, getMessagesSent, getMetricsWindow, getMinSizeReceived, getMinSizeSent, getReceiveErrorCodeTable, getSendErrorCodeTable, getTimeoutsReceiving, getTimeoutsSending, maintenanceShutdown, pause, resetStatistics, resume

Constructor Detail

HttpNIOSender

public HttpNIOSender(FileCache fileCache)

The default constructor, accepting the FileCache to use

Parameters:

fileCache - file cache to use

Method Detail

setZeroCopyEnabled

public void setZeroCopyEnabled(boolean zeroCopyEnabled)

Turn on/off use of Zero-Copy

Parameters:

zeroCopyEnabled - false turns off (default true)

setProxyHost

public void setProxyHost(java.lang.String proxyHost)

HTTP proxy hostname

Parameters:

proxyHost - HTTP proxy host

setProxyPort

public void setProxyPort(int proxyPort)

HTTP proxy port

Parameters:

proxyPort - HTTP proxy port

setConnectionDebugHeaders

public void setConnectionDebugHeaders(java.util.Set connectionDebugHeaders)

Sets the list of HTTP headers to be dumped on a connection failure, when connection debugging is enabled

Parameters:

connectionDebugHeaders - a set of HTTP header names, or a single entry 'none' or 'all'

setEnableConnectionDebug

public void setEnableConnectionDebug(boolean enableConnectionDebug)

Debug connection information on errors

Parameters:

enableConnectionDebug - enable when true

setKeepalive

public void setKeepalive(int keepalive)

Set the default keepalive time for connections kept for reuse. Should be lesser than the remote servers for optimal performance

Parameters:

keepalive - the time used for keepalive in ms

setKeepAliveSafetyThreshold

public void setKeepAliveSafetyThreshold(int keepAliveSafetyThreshold)

Set the keep-alive safety threshold to not use a connection, when the keep-alive window is about to end

Parameters:

keepAliveSafetyThreshold - threshold to not use a connection in ms

setProxyBypassList

public void setProxyBypassList(java.lang.String[] proxyBypassList)

A list of addresses for which to bypass the proxy and go direct

Parameters:

proxyBypassList - list of addresses to bypass proxy

setReplaceUserAgent

public void setReplaceUserAgent(boolean replaceUserAgent)

Replace the user agent header on requests sent to indicate UltraESB

Parameters:

replaceUserAgent - false disables (default true)

setUnzipResponseEntities

public void setUnzipResponseEntities(boolean unzipResponseEntities)

Unzip compressed responses. Where compressed responses are not required for processing, it may be better to leave them intact for extreme direct proxying cases

Parameters:

unzipResponseEntities - false leaves compressed responses intact (Default true)

setContinueOnRuntimeExceptions

public void setContinueOnRuntimeExceptions(boolean continueOnRuntimeExceptions)

Control behavior of engine on runtime exceptions (WARNING: It maybe dangerous to ignore runtime exceptions)

Parameters:

continueOnRuntimeExceptions - if true, ignores runtime exceptions

setContinueOnCheckedExceptions

public void setContinueOnCheckedExceptions(boolean continueOnCheckedExceptions)

Control behavior of engine on checked exceptions

Parameters:

continueOnCheckedExceptions - if true, ignores checked exceptions

toDetailedViewExt

public void toDetailedViewExt(org.adroitlogic.ultraesb.jmx.view.TransportView view)

Overrides:

toDetailedViewExt in class org.adroitlogic.ultraesb.transport.base.AbstractTransportSender