public abstract class IndicationWithResponse extends SignalReactor
signal
, i.e., one with a response.NO_TIMEOUT
Constructor and Description |
---|
IndicationWithResponse(SignalProtocol<?> protocol,
java.lang.Enum<?> literal) |
IndicationWithResponse(SignalProtocol<?> protocol,
short signalID) |
IndicationWithResponse(SignalProtocol<?> protocol,
short id,
java.lang.String name) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
closeChannelAfterException() |
protected void |
execute(BufferInputStream in,
BufferOutputStream out) |
protected java.lang.String |
getExceptionMessage(java.lang.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, java.lang.String name)
public IndicationWithResponse(SignalProtocol<?> protocol, short signalID)
public IndicationWithResponse(SignalProtocol<?> protocol, java.lang.Enum<?> literal)
protected boolean closeChannelAfterException()
protected java.lang.String getExceptionMessage(java.lang.Throwable t)
protected void execute(BufferInputStream in, BufferOutputStream out) throws java.lang.Exception
protected abstract void indicating(ExtendedDataInputStream in) throws java.lang.Exception
java.lang.Exception
protected abstract void responding(ExtendedDataOutputStream out) throws java.lang.Exception
boolean
. Otherwise synchronization problems will result!java.lang.Exception
Copyright (c) 2004-2019 Eike Stepper (Loehne, 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