|
|||||||||
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.socket.ServerSocketConnector
@MessageConnectorSummary(info="Creates server TCP/IP socket connection", addressFormat=":", properties={}) public class ServerSocketConnector
The ServerSocketConnector
handles standard server socket using blocking API.
Field Summary | |
---|---|
protected com.devexperts.qd.qtp.socket.SocketAcceptor |
acceptor
|
protected java.net.InetAddress |
bindAddr
|
protected java.lang.String |
bindAddrString
|
protected SocketHandler.CloseListener |
closeListener
|
protected java.util.Set<com.devexperts.qd.qtp.socket.SocketHandler> |
handlers
|
protected int |
port
|
protected boolean |
useTls
|
Fields inherited from class com.devexperts.qd.qtp.AbstractMessageConnector |
---|
DEFAULT_READ_AGGREGATION_SIZE, DEFAULT_RECONNECT_DELAY, log |
Constructor Summary | |
---|---|
ServerSocketConnector(com.devexperts.connector.proto.ApplicationConnectionFactory factory,
int port)
Creates new server socket connector. |
|
ServerSocketConnector(MessageAdapter.Factory factory,
int port)
Deprecated. use ServerSocketConnector(com.devexperts.connector.proto.ApplicationConnectionFactory, int) |
Method Summary | |
---|---|
protected void |
addHandler(com.devexperts.qd.qtp.socket.SocketHandler handler)
|
void |
close()
Deprecated. Use stop() |
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()
|
MessageConnectorState |
getState()
Returns description of connectior's state as a string. |
boolean |
getTls()
|
protected void |
handlerClosed(com.devexperts.qd.qtp.socket.SocketHandler handler)
|
boolean |
isActive()
Returns true if connector is started (not stopped). |
void |
setBindAddr(java.lang.String bindAddrString)
|
void |
setLocalPort(int port)
Changes local port and restarts connector if new port is different from the old one and the connector was running. |
void |
setStats(QDStats stats)
Sets stats for this connector. |
void |
setTls(boolean useTls)
|
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 |
Field Detail |
---|
protected int port
protected java.lang.String bindAddrString
protected java.net.InetAddress bindAddr
protected boolean useTls
protected final java.util.Set<com.devexperts.qd.qtp.socket.SocketHandler> handlers
protected final SocketHandler.CloseListener closeListener
protected volatile com.devexperts.qd.qtp.socket.SocketAcceptor acceptor
Constructor Detail |
---|
@Deprecated public ServerSocketConnector(MessageAdapter.Factory factory, int port)
ServerSocketConnector(com.devexperts.connector.proto.ApplicationConnectionFactory, int)
factory
- message adapter factory to useport
- TCP port to use
java.lang.NullPointerException
- if factory
is null
public ServerSocketConnector(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 java.lang.String getAddress()
MessageConnector
getAddress
in interface MessageConnector
public void setLocalPort(int port)
setLocalPort
in interface ServerSocketConnectorMBean
public int getLocalPort()
getLocalPort
in interface ServerSocketConnectorMBean
public java.lang.String getBindAddr()
getBindAddr
in interface ServerSocketConnectorMBean
public void setBindAddr(java.lang.String bindAddrString) throws java.net.UnknownHostException
setBindAddr
in interface ServerSocketConnectorMBean
java.net.UnknownHostException
public boolean getTls()
public void setTls(boolean useTls)
public void setStats(QDStats stats)
QDStats.SType#SERVER_SOCKET_CONNECTOR
or
a suitable substitute. This method may be invoked only once.
setStats
in interface MessageConnector
setStats
in class AbstractMessageConnector
java.lang.IllegalStateException
- if already set.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 void start()
MessageConnector
start
in interface MessageConnector
start
in class AbstractMessageConnector
public void close()
stop()
public void stop()
MessageConnector
stop
in interface MessageConnector
stop
in class AbstractMessageConnector
protected void addHandler(com.devexperts.qd.qtp.socket.SocketHandler handler)
protected void handlerClosed(com.devexperts.qd.qtp.socket.SocketHandler handler)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |