|
|||||||||
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.http.HttpConnector
@MessageConnectorSummary(info="Connects to some url by http or https protocol.", addressFormat="", properties={"user -- username to use","password -- password to use","updateDelay -- frequency (in ms) of checking if new data is available","fetchDelay -- similar to updateDelay, but used when data was sent recently","fetchCount -- number of times to use fetchDelay after sending piece of data"}) public class HttpConnector
Field Summary | |
---|---|
static java.lang.String |
CONNECTION_ID_PARAMETER
Connection id parameters might be specified in URL to distinguish multiple connections that work in a single HTTP session (for example use address like "http://localhost:9090/sample/QDServlet? |
static java.lang.String |
DEFAULT_CONNECTION_ID
Default connection ID that is used when CONNECTION_ID_PARAMETER request
property is not specified. |
static int |
DEFAULT_FETCH_COUNT
|
static long |
DEFAULT_FETCH_DELAY
|
static long |
DEFAULT_UPDATE_DELAY
|
protected AbstractConnectionHandler<?> |
handler
|
Fields inherited from class com.devexperts.qd.qtp.AbstractMessageConnector |
---|
DEFAULT_READ_AGGREGATION_SIZE, DEFAULT_RECONNECT_DELAY, log |
Constructor Summary | |
---|---|
HttpConnector(com.devexperts.connector.proto.ApplicationConnectionFactory factory,
java.lang.String address)
Creates new HTTP socket connector. |
|
HttpConnector(MessageAdapter.Factory factory,
java.lang.String address)
Deprecated. use HttpConnector(com.devexperts.connector.proto.ApplicationConnectionFactory , String) |
Method Summary | |
---|---|
java.lang.String |
getAddress()
Returns address string of this connector. |
int |
getConnectionCount()
Returns number of established connections. |
com.devexperts.transport.stats.EndpointStats |
getEndpointStats()
Returns statistics for this message connector. |
int |
getFetchCount()
|
long |
getFetchDelay()
Returns "fetch" delay that is used between subsequent POST requests if any data was sent upstream. |
java.lang.String |
getPassword()
|
java.lang.String |
getProxyHost()
|
int |
getProxyPort()
|
MessageConnectorState |
getState()
Returns message connector state. |
long |
getUpdateDelay()
Returns "update" delay that is used between subsequent POST requests by default. |
java.lang.String |
getUser()
|
protected void |
handlerClosed(com.devexperts.qd.qtp.http.HttpConnectorHandler handler)
|
boolean |
isActive()
Returns true if connector is started (not stopped). |
boolean |
isFile()
|
void |
setAddress(java.lang.String address)
|
void |
setFetchCount(int fetchCount)
|
void |
setFetchDelay(long fetchDelay)
Sets "fetch" delay. |
void |
setFile(boolean file)
|
void |
setPassword(java.lang.String password)
|
void |
setProxyHost(java.lang.String proxyHost)
|
void |
setProxyPort(int proxyPort)
|
void |
setStats(QDStats stats)
Sets stats for this connector. |
void |
setUpdateDelay(long updateDelay)
Sets "update" delay. |
void |
setUser(java.lang.String user)
|
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 |
---|
public static final java.lang.String CONNECTION_ID_PARAMETER
public static final java.lang.String DEFAULT_CONNECTION_ID
CONNECTION_ID_PARAMETER
request
property is not specified.
public static final int DEFAULT_FETCH_COUNT
public static final long DEFAULT_FETCH_DELAY
public static final long DEFAULT_UPDATE_DELAY
protected volatile AbstractConnectionHandler<?> handler
Constructor Detail |
---|
@Deprecated public HttpConnector(MessageAdapter.Factory factory, java.lang.String address)
HttpConnector(com.devexperts.connector.proto.ApplicationConnectionFactory , String)
factory
- message adapter factory to useaddress
- address HTTP address to connect to
java.lang.NullPointerException
- if factory
or address
is null
public HttpConnector(com.devexperts.connector.proto.ApplicationConnectionFactory factory, java.lang.String address)
factory
- application connection factory to useaddress
- address HTTP address to connect to
java.lang.NullPointerException
- if factory
or address
is null
Method Detail |
---|
public java.lang.String getAddress()
MessageConnectorMBean
getAddress
in interface MessageConnectorMBean
public void setAddress(java.lang.String address)
setAddress
in interface HttpConnectorMBean
public java.lang.String getUser()
getUser
in interface HttpConnectorMBean
public void setUser(java.lang.String user)
setUser
in interface HttpConnectorMBean
public java.lang.String getPassword()
getPassword
in interface HttpConnectorMBean
public void setPassword(java.lang.String password)
setPassword
in interface HttpConnectorMBean
public int getFetchCount()
getFetchCount
in interface HttpConnectorMBean
public void setFetchCount(int fetchCount)
setFetchCount
in interface HttpConnectorMBean
public long getFetchDelay()
HttpConnectorMBean
getFetchDelay
in interface HttpConnectorMBean
public void setFetchDelay(long fetchDelay)
HttpConnectorMBean
HttpConnectorMBean.getFetchDelay()
.
setFetchDelay
in interface HttpConnectorMBean
fetchDelay
- see HttpConnectorMBean.getFetchDelay()
public long getUpdateDelay()
HttpConnectorMBean
getUpdateDelay
in interface HttpConnectorMBean
public void setUpdateDelay(long updateDelay)
HttpConnectorMBean
HttpConnectorMBean.getUpdateDelay()
.
setUpdateDelay
in interface HttpConnectorMBean
updateDelay
- see HttpConnectorMBean.getUpdateDelay()
public java.lang.String getProxyHost()
getProxyHost
in interface HttpConnectorMBean
public void setProxyHost(java.lang.String proxyHost)
setProxyHost
in interface HttpConnectorMBean
public int getProxyPort()
getProxyPort
in interface HttpConnectorMBean
public void setProxyPort(int proxyPort)
setProxyPort
in interface HttpConnectorMBean
public boolean isFile()
isFile
in interface HttpConnectorMBean
public void setFile(boolean file)
setFile
in interface HttpConnectorMBean
public void start()
MessageConnectorMBean
start
in interface MessageConnectorMBean
start
in class AbstractMessageConnector
public void stop()
MessageConnectorMBean
stop
in interface MessageConnectorMBean
stop
in class AbstractMessageConnector
protected void handlerClosed(com.devexperts.qd.qtp.http.HttpConnectorHandler handler)
public void setStats(QDStats stats)
QDStats.SType#HTTP_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
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |