|
|||||||||
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 message connector state. |
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)
Changes QDStats associated with this message connector. |
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.MessageConnectorMBean |
---|
getName, getReconnectDelay, getThreadPriority, 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()
MessageConnectorMBean
start
in interface MessageConnectorMBean
start
in class AbstractMessageConnector
public void stop()
MessageConnectorMBean
stop
in interface MessageConnectorMBean
stop
in class AbstractMessageConnector
public boolean isActive()
MessageConnectorMBean
isActive
in interface MessageConnectorMBean
public MessageConnectorState getState()
MessageConnectorMBean
getState
in interface MessageConnectorMBean
public int getConnectionCount()
MessageConnectorMBean
getConnectionCount
in interface MessageConnectorMBean
public com.devexperts.transport.stats.EndpointStats getEndpointStats()
MessageConnectorMBean
getEndpointStats
in interface MessageConnectorMBean
getEndpointStats
in class AbstractMessageConnector
public java.lang.String getAddress()
MessageConnectorMBean
getAddress
in interface MessageConnectorMBean
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)
MessageConnector
QDStats
associated with this message connector.
setStats
in interface MessageConnector
setStats
in class AbstractMessageConnector
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |