public class PuaSender
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
private boolean |
_allDataSend |
private java.lang.Runnable |
_closedCallback |
private DataDescription |
_dataDescription |
private ClientDavInterface |
_dav |
private static Debug |
_debug |
private java.lang.Object |
_flushLock |
private boolean |
_isAlive |
private ClientSenderInterface |
_mySender |
private SystemObject |
_object |
private java.util.Deque<Data> |
_queue |
private static java.util.concurrent.ScheduledExecutorService |
_sendControlService |
private byte |
_state |
private java.util.concurrent.ScheduledFuture<?> |
_timeoutFuture |
static byte |
NO_SEND_CONTROL_YET |
static byte |
TIMEOUT |
Constructor and Description |
---|
PuaSender(ClientDavInterface dav,
SystemObject object,
DataDescription dataDescription,
java.lang.Runnable closedCallback) |
PuaSender(ClientDavInterface dav,
SystemObject object,
DataDescription dataDescription,
java.lang.Runnable closedCallback,
long timeout) |
Modifier and Type | Method and Description |
---|---|
boolean |
flush()
Wartet, bis alle verbleibenden Datensätze gesendet wurden
|
DataDescription |
getDataDescription() |
ClientDavInterface |
getDav() |
SystemObject |
getObject() |
boolean |
isAlive() |
private boolean |
queueIsEmpty() |
void |
send(Data data) |
java.lang.String |
toString() |
private void |
updateState(byte state) |
public static final byte NO_SEND_CONTROL_YET
public static final byte TIMEOUT
private final ClientSenderInterface _mySender
private final ClientDavInterface _dav
private final SystemObject _object
private final DataDescription _dataDescription
private final java.lang.Runnable _closedCallback
private volatile byte _state
private final java.util.Deque<Data> _queue
private static final java.util.concurrent.ScheduledExecutorService _sendControlService
private final java.util.concurrent.ScheduledFuture<?> _timeoutFuture
private static final Debug _debug
private volatile boolean _isAlive
private final java.lang.Object _flushLock
private boolean _allDataSend
public PuaSender(ClientDavInterface dav, SystemObject object, DataDescription dataDescription, java.lang.Runnable closedCallback)
public PuaSender(ClientDavInterface dav, SystemObject object, DataDescription dataDescription, java.lang.Runnable closedCallback, long timeout)
public void send(Data data)
private void updateState(byte state)
private boolean queueIsEmpty()
public java.lang.String toString()
toString
in class java.lang.Object
public SystemObject getObject()
public DataDescription getDataDescription()
public ClientDavInterface getDav()
public boolean isAlive()
public boolean flush()