com.devexperts.qd.qtp

Class AbstractServerConnector

java.lang.Object

com.devexperts.qd.qtp.AbstractMessageConnector

com.devexperts.qd.qtp.AbstractServerConnector

All Implemented Interfaces:

MessageConnector, MessageConnector.Bindable, MessageConnectorMBean, ServerConnectorMBean

Direct Known Subclasses:

ServerSocketConnector

public abstract class AbstractServerConnector
extends AbstractMessageConnector
implements MessageConnector.Bindable, ServerConnectorMBean

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 boolean	active
protected InetAddress	bindAddress
protected String	bindAddressString
protected int	maxConnections
protected int	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

Modifier	Constructor and Description
protected	AbstractServerConnector(com.devexperts.connector.proto.ApplicationConnectionFactory factory) Constructs new abstract message connector.

Method Summary

Modifier and Type	Method and Description
protected boolean	cancelScheduledTask()
String	closeConnections(double percent, String period, boolean stopAcceptor) Smooth closing a percent of connections during a specified period.
String	getAddress() Address string of connector.
String	getBindAddr() Network interface address to bind socket to
InetAddress	getBindInetAddress()
protected abstract List<Closeable>	getConnections()
int	getLocalPort() Local TCP/IP port
int	getMaxConnections() Max number of connections
boolean	isActive() True when connector is active (started).
void	setBindAddr(String newBindAddress)
void	setLocalPort(int port)
void	setMaxConnections(int maxConnections)
void	start() Starts connector (connection is immediately established).
protected abstract void	startAcceptorInternal()
protected abstract void	startImpl(boolean startAcceptor)
void	stopAcceptor() Stop accepting new connections
protected abstract boolean	stopAcceptorInternal()
String	stopGracefully(String period) Stopping server socket acceptor and smooth closing of all connections during a specified period

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, reconfigure, reconnect, removeMessageConnectorListener, resetEndpointStats, restart, restartImpl, retrieveCompleteEndpointStats, setFactory, setFieldReplacer, setName, setPassword, setReconnectDelay, setStats, setThreadPriority, setUser, stop, stopAndWait, stopImpl, 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.Bindable

normalizeBindAddr

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

isAccepting

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

getConnectionCount, getEndpointStats, getFieldReplacer, getName, getPassword, getReconnectDelay, getState, getThreadPriority, getUser, reconnect, resetEndpointStats, restart, retrieveCompleteEndpointStats, setFieldReplacer, setName, setPassword, setReconnectDelay, setThreadPriority, setUser, stop

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

awaitProcessed

Field Detail

active

protected volatile boolean active

port

protected volatile int port

bindAddress

protected volatile InetAddress bindAddress

bindAddressString

protected volatile String bindAddressString

maxConnections

protected volatile int maxConnections

Constructor Detail

AbstractServerConnector

protected AbstractServerConnector(com.devexperts.connector.proto.ApplicationConnectionFactory factory)

Constructs new abstract message connector.

Parameters:

factory - application connection factory to use

Throws:

NullPointerException - if factory is null

Method Detail

start

public void start()

Description copied from interface: MessageConnectorMBean

Starts connector (connection is immediately established). Does nothing if connector is already started.

Specified by:

start in interface MessageConnectorMBean

Specified by:

start in class AbstractMessageConnector

isActive

public boolean isActive()

Description copied from interface: MessageConnectorMBean

True when connector is active (started).

Specified by:

isActive in interface MessageConnectorMBean

Returns:

true if connector is started (not stopped)

getLocalPort

public int getLocalPort()

Description copied from interface: ServerConnectorMBean

Local TCP/IP port

Specified by:

getLocalPort in interface ServerConnectorMBean

setLocalPort

public void setLocalPort(int port)

Specified by:

setLocalPort in interface ServerConnectorMBean

getAddress

public String getAddress()

Description copied from interface: MessageConnectorMBean

Address string of connector.

Specified by:

getAddress in interface MessageConnectorMBean

Returns:

address string of this connector. It is "[host1[:port1],host2[:port2],...]:port" for client socket connector and ":port" for server socket connector.

getBindAddr

public String getBindAddr()

Description copied from interface: ServerConnectorMBean

Network interface address to bind socket to

Specified by:

getBindAddr in interface MessageConnector.Bindable

Specified by:

getBindAddr in interface ServerConnectorMBean

getBindInetAddress

public InetAddress getBindInetAddress()

setBindAddr

public void setBindAddr(String newBindAddress)
                 throws UnknownHostException

Specified by:

setBindAddr in interface MessageConnector.Bindable

Specified by:

setBindAddr in interface ServerConnectorMBean

Throws:

UnknownHostException

getMaxConnections

public int getMaxConnections()

Description copied from interface: ServerConnectorMBean

Max number of connections

Specified by:

getMaxConnections in interface ServerConnectorMBean

setMaxConnections

public void setMaxConnections(int maxConnections)

Specified by:

setMaxConnections in interface ServerConnectorMBean

closeConnections

public String closeConnections(double percent,
                               String period,
                               boolean stopAcceptor)

Smooth closing a percent of connections during a specified period. Optionally socket accepting can be disabled in this period.

Specified by:

closeConnections in interface ServerConnectorMBean

Parameters:

percent - of connections which will be closed gracefully

period - period in TimePeriod format

stopAcceptor - true if acceptor must be disabled for a specified period

Returns:

message with invocation result

stopGracefully

public String stopGracefully(String period)

Stopping server socket acceptor and smooth closing of all connections during a specified period

Specified by:

stopGracefully in interface ServerConnectorMBean

Parameters:

period - period in TimePeriod format

Returns:

message with invocation result

stopAcceptor

public void stopAcceptor()

Description copied from interface: ServerConnectorMBean

Stop accepting new connections

Specified by:

stopAcceptor in interface ServerConnectorMBean

startImpl

protected abstract void startImpl(boolean startAcceptor)

getConnections

protected abstract List<Closeable> getConnections()

stopAcceptorInternal

protected abstract boolean stopAcceptorInternal()

startAcceptorInternal

protected abstract void startAcceptorInternal()

cancelScheduledTask

protected boolean cancelScheduledTask()