com.devexperts.qd.qtp.socket

Class ServerSocketConnector

java.lang.Object

com.devexperts.qd.qtp.AbstractMessageConnector

com.devexperts.qd.qtp.AbstractServerConnector

com.devexperts.qd.qtp.socket.ServerSocketConnector

All Implemented Interfaces:

MessageConnector, MessageConnector.Bindable, MessageConnectorMBean, ServerConnectorMBean, ServerSocketConnectorMBean

@MessageConnectorSummary(info="Creates server TCP/IP socket connection.",
                         addressFormat=":<port>")
public class ServerSocketConnector
extends AbstractServerConnector
implements ServerSocketConnectorMBean

The ServerSocketConnector handles standard server socket using blocking API.

Nested Class Summary

Nested classes/interfaces inherited from class com.devexperts.qd.qtp.AbstractMessageConnector

AbstractMessageConnector.Joinable

Nested classes/interfaces inherited from interface com.devexperts.qd.qtp.MessageConnector

MessageConnector.Bindable

Field Summary

Fields

Modifier and Type	Field and Description
protected com.devexperts.qd.qtp.socket.SocketAcceptor	acceptor
protected SocketHandler.CloseListener	closeListener
protected Set<com.devexperts.qd.qtp.socket.SocketHandler>	handlers
protected boolean	useTls

Fields inherited from class com.devexperts.qd.qtp.AbstractServerConnector

active, bindAddress, bindAddressString, maxConnections, port

Fields inherited from class com.devexperts.qd.qtp.AbstractMessageConnector

log

Fields inherited from interface com.devexperts.qd.qtp.MessageConnector.Bindable

ANY_BIND_ADDRESS

Constructor Summary

Constructors

Constructor and Description
ServerSocketConnector(com.devexperts.connector.proto.ApplicationConnectionFactory factory, int port) Creates new server socket connector.
ServerSocketConnector(MessageAdapter.Factory factory, int port) Deprecated. use ServerSocketConnector(ApplicationConnectionFactory, int)

Method Summary

Modifier and Type	Method and Description
protected void	addHandler(com.devexperts.qd.qtp.socket.SocketHandler handler)
int	getConnectionCount() Number of established connections
protected List<Closeable>	getConnections()
MessageConnectorState	getState() State of connector.
boolean	getTls()
protected void	handlerClosed(com.devexperts.qd.qtp.socket.SocketHandler handler)
boolean	isAccepting() Checks whether the connection can be accepted
protected boolean	isNewConnectionAllowed()
protected void	reconfigure()
com.devexperts.transport.stats.EndpointStats	retrieveCompleteEndpointStats() Retrieves endpoint statistics for this message connector since its creation
void	setStats(QDStats stats) Sets stats for this connector.
void	setTls(boolean useTls)
protected void	startAcceptorInternal()
protected void	startImpl(boolean startAcceptor)
protected boolean	stopAcceptorInternal()
protected AbstractMessageConnector.Joinable	stopImpl()

Methods inherited from class com.devexperts.qd.qtp.AbstractServerConnector

cancelScheduledTask, closeConnections, getAddress, getBindAddr, getBindInetAddress, getLocalPort, getMaxConnections, isActive, setBindAddr, setLocalPort, setMaxConnections, start, stopAcceptor, stopGracefully

Methods inherited from class com.devexperts.qd.qtp.AbstractMessageConnector

addClosedConnectionStats, addMessageConnectorListener, close, closeImpl, getClosedConnectionCount, getEndpointStats, getFactory, getFieldReplacer, getLogging, getName, getPassword, getReconnectDelay, getStats, getThreadPriority, getUser, handlerClosed, isClosed, notifyMessageConnectorListeners, reconnect, removeMessageConnectorListener, resetEndpointStats, restart, restartImpl, setFactory, setFieldReplacer, setName, setPassword, setReconnectDelay, setThreadPriority, setUser, stop, stopAndWait, 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.ServerConnectorMBean

closeConnections, getBindAddr, getLocalPort, getMaxConnections, setBindAddr, setLocalPort, setMaxConnections, stopAcceptor, stopGracefully

Methods inherited from interface com.devexperts.qd.qtp.MessageConnectorMBean

getAddress, getEndpointStats, getFieldReplacer, getName, getPassword, getReconnectDelay, getThreadPriority, getUser, isActive, reconnect, resetEndpointStats, restart, setFieldReplacer, setName, setPassword, setReconnectDelay, setThreadPriority, setUser, start, stop

Methods inherited from interface com.devexperts.qd.qtp.MessageConnector.Bindable

normalizeBindAddr

Methods inherited from interface com.devexperts.qd.qtp.MessageConnector

awaitProcessed

Field Detail

useTls

protected volatile boolean useTls

handlers

protected final Set<com.devexperts.qd.qtp.socket.SocketHandler> handlers

closeListener

protected final SocketHandler.CloseListener closeListener

acceptor

protected volatile com.devexperts.qd.qtp.socket.SocketAcceptor acceptor

Constructor Detail

ServerSocketConnector

@Deprecated
public ServerSocketConnector(MessageAdapter.Factory factory,
                                         int port)

Deprecated. use ServerSocketConnector(ApplicationConnectionFactory, int)

Creates new server socket connector.

Parameters:

factory - message adapter factory to use

port - TCP port to use

Throws:

NullPointerException - if factory is null

ServerSocketConnector

public ServerSocketConnector(com.devexperts.connector.proto.ApplicationConnectionFactory factory,
                             int port)

Creates new server socket connector.

Parameters:

factory - application connection factory to use

port - TCP port to use

Throws:

NullPointerException - if factory is null

Method Detail

getTls

public boolean getTls()

setTls

public void setTls(boolean useTls)

setStats

public void setStats(QDStats stats)

Sets stats for this connector. Stats should be of type QDStats.SType#SERVER_SOCKET_CONNECTOR or a suitable substitute. This method may be invoked only once.

Specified by:

setStats in interface MessageConnector

Overrides:

setStats in class AbstractMessageConnector

Throws:

IllegalStateException - if already set.

isAccepting

public boolean isAccepting()

Description copied from interface: ServerConnectorMBean

Checks whether the connection can be accepted

Specified by:

isAccepting in interface ServerConnectorMBean

getState

public MessageConnectorState getState()

Description copied from interface: MessageConnectorMBean

State of connector.

Specified by:

getState in interface MessageConnectorMBean

Returns:

message connector state.

getConnectionCount

public int getConnectionCount()

Description copied from interface: MessageConnectorMBean

Number of established connections

Specified by:

getConnectionCount in interface MessageConnectorMBean

retrieveCompleteEndpointStats

public com.devexperts.transport.stats.EndpointStats retrieveCompleteEndpointStats()

Description copied from interface: MessageConnectorMBean

Retrieves endpoint statistics for this message connector since its creation

Specified by:

retrieveCompleteEndpointStats in interface MessageConnectorMBean

Overrides:

retrieveCompleteEndpointStats in class AbstractMessageConnector

reconfigure

protected void reconfigure()

Overrides:

reconfigure in class AbstractMessageConnector

startImpl

protected void startImpl(boolean startAcceptor)

Specified by:

startImpl in class AbstractServerConnector

stopImpl

protected AbstractMessageConnector.Joinable stopImpl()

Specified by:

stopImpl in class AbstractMessageConnector

stopAcceptorInternal

protected boolean stopAcceptorInternal()

Specified by:

stopAcceptorInternal in class AbstractServerConnector

startAcceptorInternal

protected void startAcceptorInternal()

Specified by:

startAcceptorInternal in class AbstractServerConnector

addHandler

protected void addHandler(com.devexperts.qd.qtp.socket.SocketHandler handler)

handlerClosed

protected void handlerClosed(com.devexperts.qd.qtp.socket.SocketHandler handler)

isNewConnectionAllowed

protected boolean isNewConnectionAllowed()

getConnections

protected List<Closeable> getConnections()

Specified by:

getConnections in class AbstractServerConnector