|
|||||||||
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.ClientSocketConnector
@MessageConnectorSummary(info="Connects to some host using TCP/IP client socket.", addressFormat=": public class ClientSocketConnector", properties={})
The ClientSocketConnector
handles standard client socket using blocking API.
Field Summary | |
---|---|
protected com.devexperts.qd.qtp.socket.SocketHandler |
handler
|
protected java.lang.String |
host
|
protected int |
port
|
protected java.lang.String |
proxyHost
|
protected int |
proxyPort
|
protected com.devexperts.qd.qtp.socket.ClientSocketSource |
socketSource
|
protected javax.net.ssl.TrustManager |
trustManager
|
protected boolean |
useTls
|
Fields inherited from class com.devexperts.qd.qtp.AbstractMessageConnector |
---|
DEFAULT_READ_AGGREGATION_SIZE, DEFAULT_RECONNECT_DELAY, log |
Constructor Summary | |
---|---|
ClientSocketConnector(com.devexperts.connector.proto.ApplicationConnectionFactory factory,
java.lang.String host,
int port)
Creates new client socket connector. |
|
ClientSocketConnector(MessageAdapter.Factory factory,
java.lang.String host,
int port)
Deprecated. use ClientSocketConnector(com.devexperts.connector.proto.ApplicationConnectionFactory, String, int) |
Method Summary | |
---|---|
java.lang.String |
getAddress()
Returns address string of this connector. |
int |
getConnectionCount()
Returns number of established connections. |
java.lang.String |
getCurrentHost()
|
int |
getCurrentPort()
|
com.devexperts.transport.stats.EndpointStats |
getEndpointStats()
Returns statistics for this message connector. |
java.lang.String |
getHost()
|
int |
getPort()
|
java.lang.String |
getProxyHost()
|
int |
getProxyPort()
|
MessageConnectorState |
getState()
Returns description of connectior's state as a string. |
boolean |
getTls()
|
javax.net.ssl.TrustManager |
getTrustManager()
|
void |
handlerClosed(com.devexperts.qd.qtp.socket.SocketHandler handler)
|
boolean |
isActive()
Returns true if connector is started (not stopped). |
void |
setHost(java.lang.String host)
Changes connection host string and restarts connector if new host string is different from the old one and the connector was running. |
void |
setPort(int port)
Changes connection port and restarts connector if new port is different from the old one and the connector was running. |
void |
setProxyHost(java.lang.String proxyHost)
|
void |
setProxyPort(int proxyPort)
|
void |
setStats(QDStats stats)
Sets stats for this connector. |
void |
setTls(boolean useTls)
|
void |
setTrustManager(javax.net.ssl.TrustManager trustManager)
Sets the custom trust manager to be used by SSLSocketFactory . |
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 java.lang.String host
protected int port
protected java.lang.String proxyHost
protected int proxyPort
protected boolean useTls
protected javax.net.ssl.TrustManager trustManager
protected volatile com.devexperts.qd.qtp.socket.SocketHandler handler
protected com.devexperts.qd.qtp.socket.ClientSocketSource socketSource
Constructor Detail |
---|
@Deprecated public ClientSocketConnector(MessageAdapter.Factory factory, java.lang.String host, int port)
ClientSocketConnector(com.devexperts.connector.proto.ApplicationConnectionFactory, String, int)
factory
- message adapter factory to usehost
- host to connect toport
- TCP port to connect to
java.lang.NullPointerException
- if factory
or host
is null
public ClientSocketConnector(com.devexperts.connector.proto.ApplicationConnectionFactory factory, java.lang.String host, int port)
factory
- application connection factory factory to usehost
- host to connect toport
- TCP port to connect to
java.lang.NullPointerException
- if factory
or host
is null
Method Detail |
---|
public java.lang.String getAddress()
MessageConnector
getAddress
in interface MessageConnector
public java.lang.String getHost()
getHost
in interface ClientSocketConnectorMBean
public void setHost(java.lang.String host)
setHost
in interface ClientSocketConnectorMBean
public int getPort()
getPort
in interface ClientSocketConnectorMBean
public void setPort(int port)
setPort
in interface ClientSocketConnectorMBean
public java.lang.String getProxyHost()
getProxyHost
in interface ClientSocketConnectorMBean
public void setProxyHost(java.lang.String proxyHost)
setProxyHost
in interface ClientSocketConnectorMBean
public int getProxyPort()
getProxyPort
in interface ClientSocketConnectorMBean
public void setProxyPort(int proxyPort)
setProxyPort
in interface ClientSocketConnectorMBean
public boolean getTls()
public void setTls(boolean useTls)
public javax.net.ssl.TrustManager getTrustManager()
public void setTrustManager(javax.net.ssl.TrustManager trustManager)
trust manager
to be used by SSLSocketFactory
.
This property has effect only when the connector is configured to use TLS
.
trustManager
- trust manager to use instead of the default one, or null
in order to use default one.public void setStats(QDStats stats)
QDStats.SType#CLIENT_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
getState
in interface ClientSocketConnectorMBean
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 stop()
MessageConnector
stop
in interface MessageConnector
stop
in class AbstractMessageConnector
public void handlerClosed(com.devexperts.qd.qtp.socket.SocketHandler handler)
handlerClosed
in interface SocketHandler.CloseListener
public java.lang.String getCurrentHost()
getCurrentHost
in interface ClientSocketConnectorMBean
public int getCurrentPort()
getCurrentPort
in interface ClientSocketConnectorMBean
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |