public abstract class IndicationWithMonitoring extends IndicationWithResponse
signal with additional support for remote progress monitoring.NO_TIMEOUT| Constructor and Description |
|---|
IndicationWithMonitoring(SignalProtocol<?> protocol,
Enum<?> literal) |
IndicationWithMonitoring(SignalProtocol<?> protocol,
short signalID) |
IndicationWithMonitoring(SignalProtocol<?> protocol,
short id,
String name) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
execute(BufferInputStream in,
BufferOutputStream out) |
protected int |
getIndicatingWorkPercent() |
protected ExecutorService |
getMonitoringExecutorService() |
protected void |
indicating(ExtendedDataInputStream in) |
protected abstract void |
indicating(ExtendedDataInputStream in,
OMMonitor monitor) |
protected void |
responding(ExtendedDataOutputStream out)
Important Note: The response must not be empty, i.e. the stream must be used at least to write a
boolean. |
protected abstract void |
responding(ExtendedDataOutputStream out,
OMMonitor monitor) |
closeChannelAfterException, getExceptionMessagecloseChannelAfterMe, closeInputStreamAfterMe, closeOutputStreamAfterMe, finishInputStream, finishOutputStream, flush, getAdditionalInfo, getBufferInputStream, getBufferOutputStream, getCorrelationID, getCurrentInputStream, getCurrentOutputStream, getID, getName, getProtocol, run, toString, wrapInputStream, wrapOutputStreampublic IndicationWithMonitoring(SignalProtocol<?> protocol, short id, String name)
public IndicationWithMonitoring(SignalProtocol<?> protocol, short signalID)
public IndicationWithMonitoring(SignalProtocol<?> protocol, Enum<?> literal)
protected void execute(BufferInputStream in, BufferOutputStream out) throws Exception
execute in class IndicationWithResponseExceptionprotected final void indicating(ExtendedDataInputStream in) throws Exception
indicating in class IndicationWithResponseExceptionprotected final void responding(ExtendedDataOutputStream out) throws Exception
IndicationWithResponseboolean. Otherwise synchronization problems will result!responding in class IndicationWithResponseExceptionprotected abstract void indicating(ExtendedDataInputStream in, OMMonitor monitor) throws Exception
Exceptionprotected abstract void responding(ExtendedDataOutputStream out, OMMonitor monitor) throws Exception
Exceptionprotected ExecutorService getMonitoringExecutorService()
protected int getIndicatingWorkPercent()
Copyright (c) 2011-2015 Eike Stepper (Berlin, Germany) and others.