|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.devexperts.qd.qtp.AbstractMessageConnector
com.devexperts.qd.qtp.nio.NioServerConnector
@MessageConnectorSummary(info="TCP/IP server socket connector with scalable non-blocking api.", addressFormat="nio:", properties={}) public class NioServerConnector
Server socket connector that uses scalable non-blocking socket API (java.nio).
Field Summary |
---|
Fields inherited from class com.devexperts.qd.qtp.AbstractMessageConnector |
---|
DEFAULT_READ_AGGREGATION_SIZE, DEFAULT_RECONNECT_DELAY, log |
Constructor Summary | |
---|---|
NioServerConnector(com.devexperts.connector.proto.ApplicationConnectionFactory factory,
int port)
Creates new NIO server socket connector. |
|
NioServerConnector(MessageAdapter.Factory factory,
int port)
Deprecated. use NioServerConnector(com.devexperts.connector.proto.ApplicationConnectionFactory, int) |
Method Summary | |
---|---|
java.lang.String |
getAddress()
Returns address string of this connector. |
java.lang.String |
getBindAddr()
|
int |
getConnectionCount()
Returns number of established connections. |
com.devexperts.transport.stats.EndpointStats |
getEndpointStats()
Returns statistics for this message connector. |
int |
getLocalPort()
|
int |
getSocketTimeout()
|
MessageConnectorState |
getState()
Returns description of connectior's state as a string. |
boolean |
isActive()
Returns true if connector is started (not stopped). |
void |
setBindAddr(java.lang.String newBindAddress)
|
void |
setLocalPort(int port)
|
void |
setSocketTimeout(int socketTimeout)
|
void |
setStats(QDStats stats)
|
void |
start()
Starts connector (connection is immediately established). |
void |
stop()
Stops connector (connection is immediately dropped). |
Methods inherited from class com.devexperts.qd.qtp.AbstractMessageConnector |
---|
addClosedConnectionStats, addMessageConnectorListener, getFactory, getLogging, getName, getReconnectDelay, getStats, getThreadPriority, notifyMessageConnectorListeners, reconfigure, removeMessageConnectorListener, restart, setName, setReconnectDelay, setThreadPriority, toString |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface com.devexperts.qd.qtp.MessageConnector |
---|
addMessageConnectorListener, getName, getReconnectDelay, getStats, getThreadPriority, removeMessageConnectorListener, restart, setName, setReconnectDelay, setThreadPriority |
Constructor Detail |
---|
@Deprecated public NioServerConnector(MessageAdapter.Factory factory, int port)
NioServerConnector(com.devexperts.connector.proto.ApplicationConnectionFactory, int)
factory
- message adapter factory to useport
- TCP port to use
java.lang.NullPointerException
- if factory
is null
public NioServerConnector(com.devexperts.connector.proto.ApplicationConnectionFactory factory, int port)
factory
- application connection factory to useport
- TCP port to use
java.lang.NullPointerException
- if factory
is null
Method Detail |
---|
public void start()
MessageConnector
start
in interface MessageConnector
start
in class AbstractMessageConnector
public void stop()
MessageConnector
stop
in interface MessageConnector
stop
in class AbstractMessageConnector
public boolean isActive()
MessageConnector
isActive
in interface MessageConnector
public MessageConnectorState getState()
MessageConnector
getState
in interface MessageConnector
public int getConnectionCount()
MessageConnector
getConnectionCount
in interface MessageConnector
public com.devexperts.transport.stats.EndpointStats getEndpointStats()
MessageConnector
getEndpointStats
in interface MessageConnector
getEndpointStats
in class AbstractMessageConnector
public java.lang.String getAddress()
MessageConnector
getAddress
in interface MessageConnector
public int getLocalPort()
getLocalPort
in interface NioServerConnectorMBean
public void setLocalPort(int port)
setLocalPort
in interface NioServerConnectorMBean
public int getSocketTimeout()
public void setSocketTimeout(int socketTimeout)
public java.lang.String getBindAddr()
getBindAddr
in interface NioServerConnectorMBean
public void setBindAddr(java.lang.String newBindAddress) throws java.net.UnknownHostException
setBindAddr
in interface NioServerConnectorMBean
java.net.UnknownHostException
public void setStats(QDStats stats)
setStats
in interface MessageConnector
setStats
in class AbstractMessageConnector
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |