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 boolean |
closeChannelAfterException() |
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.
|
closeChannelAfterMe, closeInputStreamAfterMe, closeOutputStreamAfterMe, finishInputStream, finishOutputStream, flush, getAdditionalInfo, 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 boolean closeChannelAfterException()
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) 2014 Eike Stepper (Berlin, Germany) and others.
All rights reserved. This program and the accompanying materials are made available under the terms of the Eclipse Public License v1.0 which accompanies this distribution, and is available at http://www.eclipse.org/legal/epl-v10.html