public abstract class RequestWithConfirmation<RESULT> extends SignalActor
signal, i.e., one with a response.NO_TIMEOUT| Constructor and Description |
|---|
RequestWithConfirmation(SignalProtocol<?> protocol,
java.lang.Enum<?> literal) |
RequestWithConfirmation(SignalProtocol<?> protocol,
short signalID) |
RequestWithConfirmation(SignalProtocol<?> protocol,
short id,
java.lang.String name) |
| Modifier and Type | Method and Description |
|---|---|
protected abstract RESULT |
confirming(ExtendedDataInputStream in)
Important Note: The confirmation must not be empty, i.e.
|
protected java.util.concurrent.ExecutorService |
getAsyncExecutorService() |
protected abstract void |
requesting(ExtendedDataOutputStream out) |
RESULT |
send() |
RESULT |
send(long timeout) |
java.util.concurrent.Future<RESULT> |
sendAsync() |
executecloseChannelAfterMe, closeInputStreamAfterMe, closeOutputStreamAfterMe, finishInputStream, finishOutputStream, flush, getAdditionalInfo, getBufferInputStream, getBufferOutputStream, getCorrelationID, getCurrentInputStream, getCurrentOutputStream, getID, getName, getProtocol, run, toString, wrapInputStream, wrapOutputStreampublic RequestWithConfirmation(SignalProtocol<?> protocol, short id, java.lang.String name)
public RequestWithConfirmation(SignalProtocol<?> protocol, short signalID)
public RequestWithConfirmation(SignalProtocol<?> protocol, java.lang.Enum<?> literal)
public java.util.concurrent.Future<RESULT> sendAsync()
public RESULT send() throws java.lang.Exception, RemoteException
java.lang.ExceptionRemoteExceptionpublic RESULT send(long timeout) throws java.lang.Exception, RemoteException
java.lang.ExceptionRemoteExceptionprotected java.util.concurrent.ExecutorService getAsyncExecutorService()
protected abstract void requesting(ExtendedDataOutputStream out) throws java.lang.Exception
java.lang.Exceptionprotected abstract RESULT confirming(ExtendedDataInputStream in) throws java.lang.Exception
boolean. Otherwise synchronization problems will result!java.lang.ExceptionCopyright (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