com.devexperts.qd.qtp

Interface MessageConnector

All Superinterfaces:

MessageConnectorMBean

All Known Implementing Classes:

AbstractMessageConnector, AbstractServerConnector, ClientSocketConnector, ServerSocketConnector

public interface MessageConnector
extends MessageConnectorMBean

Implemented by every QTP message connector.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	MessageConnector.Bindable Deprecated. Experimental API. May be subject to backward-incompatible changes in the future.

Method Summary

Modifier and Type	Method and Description
void	addMessageConnectorListener(MessageConnectorListener listener) Adds the specified listener to this message connector.
default void	awaitProcessed() Waits until this connector stops processing (becomes quescient).
default void	close() Permanently closes connector and releases its resources.
long	getClosedConnectionCount() Returns total number of closed connector since the creation of connector.
com.devexperts.connector.proto.ApplicationConnectionFactory	getFactory() Returns ApplicationConnectionFactory that is used by this message connector.
QDStats	getStats() Returns QDStats associated with this message connector.
void	removeMessageConnectorListener(MessageConnectorListener listener) Removes the specified listener from this message connector.
void	setFactory(com.devexperts.connector.proto.ApplicationConnectionFactory factory) Changes ApplicationConnectionFactory that is used by this message connector.
void	setStats(QDStats stats) Changes QDStats associated with this message connector.
void	stopAndWait() Stops connector and waits while all its threads are terminated.

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

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

Method Detail

getStats

QDStats getStats()

Returns QDStats associated with this message connector.

Returns:

QDStats associated with this message connector

setStats

void setStats(QDStats stats)

Changes QDStats associated with this message connector.

addMessageConnectorListener

void addMessageConnectorListener(MessageConnectorListener listener)

Adds the specified listener to this message connector.

Parameters:

listener - newly adding MessageConnectorListener.

removeMessageConnectorListener

void removeMessageConnectorListener(MessageConnectorListener listener)

Removes the specified listener from this message connector.

Parameters:

listener - removing MessageConnectorListener.

getFactory

com.devexperts.connector.proto.ApplicationConnectionFactory getFactory()

Returns ApplicationConnectionFactory that is used by this message connector.

Returns:

ApplicationConnectionFactory that is used by this message connector.

setFactory

void setFactory(com.devexperts.connector.proto.ApplicationConnectionFactory factory)

Changes ApplicationConnectionFactory that is used by this message connector.

Parameters:

factory - ApplicationConnectionFactory that will be used by this message connector.

awaitProcessed

default void awaitProcessed()
                     throws InterruptedException

Waits until this connector stops processing (becomes quescient).

Throws:

InterruptedException - if interrupted.

Implementation Requirements:

Default implementation does nothing.

stopAndWait

void stopAndWait()
          throws InterruptedException

Stops connector and waits while all its threads are terminated.

Throws:

InterruptedException - if interrupted.

getClosedConnectionCount

long getClosedConnectionCount()

Returns total number of closed connector since the creation of connector.

close

default void close()

Permanently closes connector and releases its resources.