public abstract class Signal
extends java.lang.Object
implements java.lang.Runnable
signal protocol
.Modifier and Type | Field and Description |
---|---|
static long |
NO_TIMEOUT |
Constructor and Description |
---|
Signal(SignalProtocol<?> protocol,
java.lang.Enum<?> literal) |
Signal(SignalProtocol<?> protocol,
short id) |
Signal(SignalProtocol<?> protocol,
short id,
java.lang.String name)
Both implementation classes of a logical signal must have the same signalID.
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
closeChannelAfterMe() |
protected boolean |
closeInputStreamAfterMe() |
protected boolean |
closeOutputStreamAfterMe() |
protected abstract void |
execute(BufferInputStream in,
BufferOutputStream out) |
protected void |
finishInputStream(java.io.InputStream in) |
protected void |
finishOutputStream(java.io.OutputStream out) |
protected void |
flush() |
protected java.lang.String |
getAdditionalInfo() |
protected BufferInputStream |
getBufferInputStream() |
protected BufferOutputStream |
getBufferOutputStream() |
int |
getCorrelationID() |
protected java.io.InputStream |
getCurrentInputStream() |
protected java.io.OutputStream |
getCurrentOutputStream() |
short |
getID()
Returns the short integer ID of this signal that is unique among all signals of the associated
protocol . |
java.lang.String |
getName() |
SignalProtocol<?> |
getProtocol() |
void |
run() |
java.lang.String |
toString() |
protected java.io.InputStream |
wrapInputStream(java.io.InputStream in) |
protected java.io.OutputStream |
wrapOutputStream(java.io.OutputStream out) |
public static final long NO_TIMEOUT
public Signal(SignalProtocol<?> protocol, short id, java.lang.String name)
public Signal(SignalProtocol<?> protocol, short id)
Signal(SignalProtocol, short, String)
public Signal(SignalProtocol<?> protocol, java.lang.Enum<?> literal)
Signal(SignalProtocol, short, String)
public SignalProtocol<?> getProtocol()
public final short getID()
protocol
.public java.lang.String getName()
public final int getCorrelationID()
public java.lang.String toString()
toString
in class java.lang.Object
protected java.lang.String getAdditionalInfo()
public final void run()
run
in interface java.lang.Runnable
protected final BufferInputStream getBufferInputStream()
protected final BufferOutputStream getBufferOutputStream()
protected final void flush() throws java.io.IOException
java.io.IOException
protected boolean closeChannelAfterMe()
protected boolean closeInputStreamAfterMe()
protected boolean closeOutputStreamAfterMe()
protected java.io.InputStream getCurrentInputStream()
protected java.io.OutputStream getCurrentOutputStream()
protected java.io.InputStream wrapInputStream(java.io.InputStream in) throws java.io.IOException
java.io.IOException
protected java.io.OutputStream wrapOutputStream(java.io.OutputStream out) throws java.io.IOException
java.io.IOException
protected void finishInputStream(java.io.InputStream in) throws java.io.IOException
java.io.IOException
protected void finishOutputStream(java.io.OutputStream out) throws java.io.IOException
java.io.IOException
protected abstract void execute(BufferInputStream in, BufferOutputStream out) throws java.lang.Exception
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