public abstract class TCPNIOSender extends AbstractTransportSender
ConfigurationElement.State
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
CONNECTION_EST_TIME |
static java.lang.String |
CONNECTION_IN_USE |
static java.lang.String |
RESPONSE_CORRELATION_MAP |
protected org.adroitlogic.ultraesb.transport.tcp.TCPServiceHandler |
serviceHandler |
static java.lang.String |
TCP_HOST_AND_PORT |
static java.lang.String |
TCP_REQUEST |
logger, metrics, originatingTransport, properties
Constructor and Description |
---|
TCPNIOSender(FileCache fileCache) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.http.nio.reactor.IOEventDispatch |
getIOEventDispatch(FileCache fileCache,
org.adroitlogic.ultraesb.transport.tcp.TCPServiceHandler serviceHandler,
org.adroitlogic.ultraesb.transport.tcp.util.ConnectionManager connMgr,
org.apache.http.params.HttpParams params,
org.adroitlogic.ultraesb.transport.TransportMetricsCollector metrics,
boolean readToString,
java.lang.String charset) |
protected boolean |
getProperty(java.lang.String name,
boolean def) |
protected int |
getProperty(java.lang.String name,
int def) |
protected abstract org.adroitlogic.ultraesb.transport.tcp.TCPMessage |
getTCPRequest(org.adroitlogic.ultraesb.core.MessageImpl message) |
TransportSender.SendingResult |
send(org.adroitlogic.ultraesb.core.MessageImpl message) |
void |
setOriginatingTransport(java.lang.String originatingTransport) |
void |
start() |
getDetails, getOriginatingTransport, pause, resetStatistics, resume, setProperties, stop, toBasicView, toDetailedView, toDetailedViewExt
equals, getDeploymentUnit, getDerivedName, getId, getState, getStreamCount, getTimerStreamMax, getTimerStreamMean, getTimerStreamMin, getTimerStreamPer, hashCode, init, isDebugOn, isStarted, maintenanceShutdown, markAsOutdated, resetCounter, resetTimer, resolveMetricsStreams, setBeanName, setConfig, setDebugOn, setDerivedName, setId, setMetricsEngine, setState, throwIllegalStateException, undeploy
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
retire
public static final java.lang.String RESPONSE_CORRELATION_MAP
public static final java.lang.String CONNECTION_IN_USE
public static final java.lang.String CONNECTION_EST_TIME
public static final java.lang.String TCP_REQUEST
public static final java.lang.String TCP_HOST_AND_PORT
protected org.adroitlogic.ultraesb.transport.tcp.TCPServiceHandler serviceHandler
public TCPNIOSender(FileCache fileCache)
public void setOriginatingTransport(java.lang.String originatingTransport)
public void start()
start
in interface ConfigurationElement
start
in class AbstractTransportSender
protected org.apache.http.nio.reactor.IOEventDispatch getIOEventDispatch(FileCache fileCache, org.adroitlogic.ultraesb.transport.tcp.TCPServiceHandler serviceHandler, org.adroitlogic.ultraesb.transport.tcp.util.ConnectionManager connMgr, org.apache.http.params.HttpParams params, org.adroitlogic.ultraesb.transport.TransportMetricsCollector metrics, boolean readToString, java.lang.String charset)
protected abstract org.adroitlogic.ultraesb.transport.tcp.TCPMessage getTCPRequest(org.adroitlogic.ultraesb.core.MessageImpl message)
public TransportSender.SendingResult send(org.adroitlogic.ultraesb.core.MessageImpl message)
protected int getProperty(java.lang.String name, int def)
protected boolean getProperty(java.lang.String name, boolean def)