public class MARSConnector extends Connector
isAdvancedStatEnabled, SYS_PROPERTY_NO_ADV_STATISTICS
Constructor and Description |
---|
MARSConnector(MARS mars,
boolean receive,
boolean send)
Creates new MARS connector for specified
MARS instance and communication link direction. |
Modifier and Type | Method and Description |
---|---|
protected ConnectionAdapter |
createConnectionAdapter(Socket socket)
|
int |
getReadBufferLimit()
Returns limit of read buffer at which connection is closed.
|
void |
setReadBufferLimit(int read_buffer_limit)
Sets new limit of read buffer at which connection is closed.
|
fireConnectorListenerProcessing, getAddress, getConnectorListener, getHeartbeatPeriod, getHeartbeatTimeout, getReconnectionPeriod, getSkewedPeriod, getSkewFactor, getSocketAddress, log, log, restart, setAddress, setConnectorListener, setHeartbeatPeriod, setHeartbeatTimeout, setReconnectionPeriod, setSkewFactor, start, stop, toString
public MARSConnector(MARS mars, boolean receive, boolean send)
MARS
instance and communication link direction.mars
- instance to be serviced by this connector.receive
- determines if this connector shall process data received from remote host.send
- determines if this connector shall send data to remote host.public int getReadBufferLimit()
public void setReadBufferLimit(int read_buffer_limit)
IllegalArgumentException
- if specified limit is lower than 256 characters.protected ConnectionAdapter createConnectionAdapter(Socket socket) throws Throwable
Connector
ConnectionAdapter
for specified Socket
.createConnectionAdapter
in class Connector
Throwable
Copyright © 2014 Devexperts. All Rights Reserved.