- java.lang.Object
-
- org.eclipse.net4j.signal.Signal
-
- org.eclipse.net4j.signal.SignalActor
-
- org.eclipse.net4j.signal.RequestWithConfirmation<RESULT>
-
- org.eclipse.net4j.signal.RequestWithMonitoring<RESULT>
-
- All Implemented Interfaces:
- Runnable
public abstract class RequestWithMonitoring<RESULT> extends RequestWithConfirmation<RESULT>
Represents the sender side of a two-waysignalwith additional support for remote progress monitoring.- Since:
- 2.0
-
-
Field Summary
Fields Modifier and Type Field and Description static longDEFAULT_CANCELATION_POLL_INTERVALstatic intDEFAULT_MONITOR_PROGRESS_SECONDSstatic intDEFAULT_MONITOR_TIMEOUT_SECONDS-
Fields inherited from class org.eclipse.net4j.signal.Signal
NO_TIMEOUT
-
-
Constructor Summary
Constructors Constructor and Description RequestWithMonitoring(SignalProtocol<?> protocol, Enum<?> literal)RequestWithMonitoring(SignalProtocol<?> protocol, short signalID)RequestWithMonitoring(SignalProtocol<?> protocol, short id, String name)
-
Method Summary
Methods Modifier and Type Method and Description protected RESULTconfirming(ExtendedDataInputStream in)Important Note: The confirmation must not be empty, i.e. the stream must be used at least to read aboolean.protected abstract RESULTconfirming(ExtendedDataInputStream in, OMMonitor monitor)Important Note: The confirmation must not be empty, i.e. the stream must be used at least to read aboolean.protected ExecutorServicegetCancelationExecutorService()protected longgetCancelationPollInterval()protected intgetConfirmingWorkPercent()protected intgetMonitorProgressSeconds()protected intgetMonitorTimeoutSeconds()protected intgetRequestingWorkPercent()protected voidrequesting(ExtendedDataOutputStream out)protected abstract voidrequesting(ExtendedDataOutputStream out, OMMonitor monitor)RESULTsend()RESULTsend(long timeout)RESULTsend(long timeout, OMMonitor monitor)RESULTsend(OMMonitor monitor)Future<RESULT>sendAsync()Future<RESULT>sendAsync(OMMonitor monitor)-
Methods inherited from class org.eclipse.net4j.signal.RequestWithConfirmation
getAsyncExecutorService
-
Methods inherited from class org.eclipse.net4j.signal.SignalActor
execute
-
Methods inherited from class org.eclipse.net4j.signal.Signal
finishInputStream, finishOutputStream, flush, getBufferInputStream, getBufferOutputStream, getCorrelationID, getCurrentInputStream, getCurrentOutputStream, getID, getName, getProtocol, run, toString, wrapInputStream, wrapOutputStream
-
-
-
-
Field Detail
-
DEFAULT_CANCELATION_POLL_INTERVAL
public static final long DEFAULT_CANCELATION_POLL_INTERVAL
- Since:
- 2.0
- See Also:
- Constant Field Values
-
DEFAULT_MONITOR_PROGRESS_SECONDS
public static final int DEFAULT_MONITOR_PROGRESS_SECONDS
- Since:
- 2.0
- See Also:
- Constant Field Values
-
DEFAULT_MONITOR_TIMEOUT_SECONDS
public static final int DEFAULT_MONITOR_TIMEOUT_SECONDS
- Since:
- 2.0
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
RequestWithMonitoring
public RequestWithMonitoring(SignalProtocol<?> protocol, short id, String name)
- Since:
- 2.0
-
RequestWithMonitoring
public RequestWithMonitoring(SignalProtocol<?> protocol, short signalID)
- Since:
- 2.0
-
RequestWithMonitoring
public RequestWithMonitoring(SignalProtocol<?> protocol, Enum<?> literal)
- Since:
- 2.0
-
-
Method Detail
-
sendAsync
public Future<RESULT> sendAsync()
- Overrides:
sendAsyncin classRequestWithConfirmation<RESULT>
-
send
public RESULT send() throws Exception, RemoteException
- Overrides:
sendin classRequestWithConfirmation<RESULT>- Throws:
ExceptionRemoteException
-
send
public RESULT send(long timeout) throws Exception, RemoteException
- Overrides:
sendin classRequestWithConfirmation<RESULT>- Throws:
ExceptionRemoteException
-
send
public RESULT send(OMMonitor monitor) throws Exception, RemoteException
- Throws:
ExceptionRemoteException
-
send
public RESULT send(long timeout, OMMonitor monitor) throws Exception, RemoteException
- Throws:
ExceptionRemoteException
-
requesting
protected final void requesting(ExtendedDataOutputStream out) throws Exception
- Specified by:
requestingin classRequestWithConfirmation<RESULT>- Throws:
Exception
-
confirming
protected final RESULT confirming(ExtendedDataInputStream in) throws Exception
Description copied from class:RequestWithConfirmationImportant Note: The confirmation must not be empty, i.e. the stream must be used at least to read aboolean. Otherwise synchronization problems will result!- Specified by:
confirmingin classRequestWithConfirmation<RESULT>- Throws:
Exception
-
requesting
protected abstract void requesting(ExtendedDataOutputStream out, OMMonitor monitor) throws Exception
- Throws:
Exception
-
confirming
protected abstract RESULT confirming(ExtendedDataInputStream in, OMMonitor monitor) throws Exception
Important Note: The confirmation must not be empty, i.e. the stream must be used at least to read aboolean. Otherwise synchronization problems will result!- Throws:
Exception
-
getCancelationExecutorService
protected ExecutorService getCancelationExecutorService()
- Since:
- 2.0
-
getCancelationPollInterval
protected long getCancelationPollInterval()
- Since:
- 2.0
-
getMonitorProgressSeconds
protected int getMonitorProgressSeconds()
- Since:
- 2.0
-
getMonitorTimeoutSeconds
protected int getMonitorTimeoutSeconds()
- Since:
- 2.0
-
getRequestingWorkPercent
protected int getRequestingWorkPercent()
- Since:
- 2.0
-
getConfirmingWorkPercent
protected int getConfirmingWorkPercent()
- Since:
- 2.0
-
-