|
|||||||||
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 avaliable","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 | |
---|---|
protected java.lang.String |
address
|
static java.lang.String |
CONNECTION_ID_PARAMETER
Connection id paramteres 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 int |
fetchCount
|
protected long |
fetchDelay
|
protected com.devexperts.qd.qtp.http.HttpConnectorHandler |
handler
|
protected java.lang.String |
password
|
protected java.lang.String |
proxyHost
|
protected int |
proxyPort
|
protected long |
updateDelay
|
protected java.lang.String |
user
|
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 description of connectior's state as a string. |
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). |
void |
setAddress(java.lang.String address)
|
void |
setFetchCount(int fetchCount)
|
void |
setFetchDelay(long fetchDelay)
Sets "fetch" delay. |
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.MessageConnector |
---|
addMessageConnectorListener, getName, getReconnectDelay, getStats, getThreadPriority, removeMessageConnectorListener, 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 java.lang.String address
protected java.lang.String user
protected java.lang.String password
protected int fetchCount
protected long fetchDelay
protected long updateDelay
protected java.lang.String proxyHost
protected int proxyPort
protected volatile com.devexperts.qd.qtp.http.HttpConnectorHandler 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()
MessageConnector
getAddress
in interface MessageConnector
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()
public void setProxyHost(java.lang.String proxyHost)
public int getProxyPort()
public void setProxyPort(int proxyPort)
public void start()
MessageConnector
start
in interface MessageConnector
start
in class AbstractMessageConnector
public void stop()
MessageConnector
stop
in interface MessageConnector
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()
MessageConnector
isActive
in interface MessageConnector
public MessageConnectorState getState()
MessageConnector
getState
in interface MessageConnector
public int getConnectionCount()
MessageConnector
getConnectionCount
in interface MessageConnector
public com.devexperts.transport.stats.EndpointStats getEndpointStats()
MessageConnector
getEndpointStats
in interface MessageConnector
getEndpointStats
in class AbstractMessageConnector
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |