public abstract class IndicationWithResponse extends SignalReactor
signal
, i.e., one with a response.NO_TIMEOUT
Constructor and Description |
---|
IndicationWithResponse(SignalProtocol<?> protocol,
Enum<?> literal) |
IndicationWithResponse(SignalProtocol<?> protocol,
short signalID) |
IndicationWithResponse(SignalProtocol<?> protocol,
short id,
String name) |
Modifier and Type | Method and Description |
---|---|
protected void |
execute(BufferInputStream in,
BufferOutputStream out) |
protected String |
getExceptionMessage(Throwable t) |
protected abstract void |
indicating(ExtendedDataInputStream in) |
protected abstract 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 . |
finishInputStream, finishOutputStream, flush, getBufferInputStream, getBufferOutputStream, getCorrelationID, getCurrentInputStream, getCurrentOutputStream, getID, getName, getProtocol, run, toString, wrapInputStream, wrapOutputStream
public IndicationWithResponse(SignalProtocol<?> protocol, short id, String name)
public IndicationWithResponse(SignalProtocol<?> protocol, short signalID)
public IndicationWithResponse(SignalProtocol<?> protocol, Enum<?> literal)
protected void execute(BufferInputStream in, BufferOutputStream out) throws Exception
protected abstract void indicating(ExtendedDataInputStream in) throws Exception
Exception
protected abstract void responding(ExtendedDataOutputStream out) throws Exception
boolean
. Otherwise synchronization problems will result!Exception
Copyright (c) 2011, 2012 Eike Stepper (Berlin, Germany) and others.