public class PachubeSenderRT extends PublisherRT<PachubePointVO>
Modifier and Type | Class and Description |
---|---|
(package private) class |
PachubeSenderRT.PachubeSendThread |
Modifier and Type | Field and Description |
---|---|
(package private) org.apache.commons.httpclient.HttpClient |
httpClient |
(package private) static org.apache.commons.logging.Log |
LOG |
private static int |
MAX_FAILURES |
static int |
SEND_EXCEPTION_EVENT |
(package private) EventType |
sendExceptionEventType |
(package private) PachubeSenderVO |
vo |
POINT_DISABLED_EVENT, pointRTs, queue, QUEUE_SIZE_WARNING_EVENT
Constructor and Description |
---|
PachubeSenderRT(PachubeSenderVO vo) |
Modifier and Type | Method and Description |
---|---|
protected PublishQueue<PachubePointVO> |
createPublishQueue(PublisherVO<PachubePointVO> vo) |
(package private) PublishQueue<PachubePointVO> |
getPublishQueue() |
void |
initialize() |
createEventContext, getId, getPersistentData, getVo, initialize, joinTermination, pointInitialized, pointTerminated, publish, scheduleTimeout, setPersistentData, terminate
static final org.apache.commons.logging.Log LOG
private static final int MAX_FAILURES
public static final int SEND_EXCEPTION_EVENT
final EventType sendExceptionEventType
final PachubeSenderVO vo
final org.apache.commons.httpclient.HttpClient httpClient
public PachubeSenderRT(PachubeSenderVO vo)
protected PublishQueue<PachubePointVO> createPublishQueue(PublisherVO<PachubePointVO> vo)
createPublishQueue
in class PublisherRT<PachubePointVO>
public void initialize()
initialize
in class PublisherRT<PachubePointVO>
PublishQueue<PachubePointVO> getPublishQueue()