|
|||||||||
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 message connector state. |
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.MessageConnectorMBean |
---|
getName, getReconnectDelay, getThreadPriority, 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()
MessageConnectorMBean
getAddress
in interface MessageConnectorMBean
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()
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 void start()
MessageConnectorMBean
start
in interface MessageConnectorMBean
start
in class AbstractMessageConnector
public void close()
stop()
public void stop()
MessageConnectorMBean
stop
in interface MessageConnectorMBean
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 |