com.serotonin.mango.rt.publish.persistent

Class PersistentSenderRT

java.lang.Object

com.serotonin.mango.rt.publish.PublisherRT<PersistentPointVO>

com.serotonin.mango.rt.publish.persistent.PersistentSenderRT

All Implemented Interfaces:

TimeoutClient

public class PersistentSenderRT
extends PublisherRT<PersistentPointVO>

Field Summary

Fields

Modifier and Type	Field and Description
static int	CONNECTION_ABORTED_EVENT
static int	CONNECTION_FAILED_EVENT
static int	CONNECTION_LOST_EVENT
(package private) EventType	connectionAbortedEventType
(package private) EventType	connectionFailedEventType
(package private) EventType	connectionLostEventType
(package private) static org.apache.commons.logging.Log	LOG
static int	PROTOCOL_FAILURE_EVENT
(package private) EventType	protocolFailureEventType
private PersistentSendThread	sendThread
static int	SYNC_COMPLETION_EVENT
(package private) EventType	syncCompletionEventType
(package private) PersistentSenderVO	vo

Fields inherited from class com.serotonin.mango.rt.publish.PublisherRT

POINT_DISABLED_EVENT, pointRTs, queue, QUEUE_SIZE_WARNING_EVENT

Constructor Summary

Constructors

Constructor and Description
PersistentSenderRT(PersistentSenderVO vo)

Method Summary

Modifier and Type	Method and Description
int	getConnectingIndex()
int	getPacketsToSend()
int	getPointCount()
(package private) java.util.List<PublishedPointRT<PersistentPointVO>>	getPointRTs()
(package private) PublishQueue<PersistentPointVO>	getPublishQueue()
int	getQueueSize()
int	getSyncRequestsSent()
int	getSyncStatus()
void	initialize()
boolean	isConnected()
protected void	pointInitialized(PublishedPointRT<PersistentPointVO> rt)
(package private) void	raiseConnectionEvent(EventType type, java.lang.Exception e)
(package private) void	raiseConnectionEvent(EventType type, com.serotonin.web.i18n.LocalizableMessage lm)
(package private) void	raiseSyncCompletionEvent(com.serotonin.web.i18n.LocalizableMessage lm)
boolean	startSync()
private void	updatePublishedPointVO(PersistentPointVO ppvo, DataPointVO dpvo)

Methods inherited from class com.serotonin.mango.rt.publish.PublisherRT

createEventContext, createPublishQueue, getId, getPersistentData, getVo, initialize, joinTermination, pointTerminated, publish, scheduleTimeout, setPersistentData, terminate

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOG

static final org.apache.commons.logging.Log LOG

CONNECTION_FAILED_EVENT

public static final int CONNECTION_FAILED_EVENT

See Also:

Constant Field Values

PROTOCOL_FAILURE_EVENT

public static final int PROTOCOL_FAILURE_EVENT

See Also:

Constant Field Values

CONNECTION_ABORTED_EVENT

public static final int CONNECTION_ABORTED_EVENT

See Also:

Constant Field Values

CONNECTION_LOST_EVENT

public static final int CONNECTION_LOST_EVENT

See Also:

Constant Field Values

SYNC_COMPLETION_EVENT

public static final int SYNC_COMPLETION_EVENT

See Also:

Constant Field Values

connectionFailedEventType

final EventType connectionFailedEventType

protocolFailureEventType

final EventType protocolFailureEventType

connectionAbortedEventType

final EventType connectionAbortedEventType

connectionLostEventType

final EventType connectionLostEventType

syncCompletionEventType

final EventType syncCompletionEventType

vo

final PersistentSenderVO vo

sendThread

private PersistentSendThread sendThread

Constructor Detail

PersistentSenderRT

public PersistentSenderRT(PersistentSenderVO vo)

Method Detail

getPublishQueue

PublishQueue<PersistentPointVO> getPublishQueue()

getPointRTs

java.util.List<PublishedPointRT<PersistentPointVO>> getPointRTs()

getPointCount

public int getPointCount()

getQueueSize

public int getQueueSize()

isConnected

public boolean isConnected()

getConnectingIndex

public int getConnectingIndex()

getPacketsToSend

public int getPacketsToSend()

getSyncStatus

public int getSyncStatus()

getSyncRequestsSent

public int getSyncRequestsSent()

startSync

public boolean startSync()

pointInitialized

protected void pointInitialized(PublishedPointRT<PersistentPointVO> rt)

Overrides:

pointInitialized in class PublisherRT<PersistentPointVO>

initialize

public void initialize()

Specified by:

initialize in class PublisherRT<PersistentPointVO>

updatePublishedPointVO

private void updatePublishedPointVO(PersistentPointVO ppvo,
                                    DataPointVO dpvo)

raiseConnectionEvent

void raiseConnectionEvent(EventType type,
                          java.lang.Exception e)

raiseConnectionEvent

void raiseConnectionEvent(EventType type,
                          com.serotonin.web.i18n.LocalizableMessage lm)

raiseSyncCompletionEvent

void raiseSyncCompletionEvent(com.serotonin.web.i18n.LocalizableMessage lm)