Package org.eclipse.net4j.signal
Class RequestWithMonitoring<RESULT>
- 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:
- java.lang.Runnable
 - Direct Known Subclasses:
- AuthenticationRequest,- ConfirmationRequest
 
 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
- Author:
- Eike Stepper
 
- 
- 
Field SummaryFields Modifier and Type Field Description static longDEFAULT_CANCELATION_POLL_INTERVALstatic intDEFAULT_MONITOR_PROGRESS_SECONDSstatic intDEFAULT_MONITOR_TIMEOUT_SECONDS- 
Fields inherited from class org.eclipse.net4j.signal.SignalNO_TIMEOUT
 
- 
 - 
Constructor SummaryConstructors Constructor Description RequestWithMonitoring(SignalProtocol<?> protocol, short signalID)RequestWithMonitoring(SignalProtocol<?> protocol, short id, java.lang.String name)RequestWithMonitoring(SignalProtocol<?> protocol, java.lang.Enum<?> literal)
 - 
Method SummaryAll Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description protected RESULTconfirming(org.eclipse.net4j.util.io.ExtendedDataInputStream in)Important Note: The confirmation must not be empty, i.e.protected abstract RESULTconfirming(org.eclipse.net4j.util.io.ExtendedDataInputStream in, org.eclipse.net4j.util.om.monitor.OMMonitor monitor)Important Note: The confirmation must not be empty, i.e.protected java.util.concurrent.ExecutorServicegetCancelationExecutorService()protected longgetCancelationPollInterval()protected intgetConfirmingWorkPercent()protected intgetMonitorProgressSeconds()protected intgetMonitorTimeoutSeconds()protected intgetRequestingWorkPercent()protected voidrequesting(org.eclipse.net4j.util.io.ExtendedDataOutputStream out)protected abstract voidrequesting(org.eclipse.net4j.util.io.ExtendedDataOutputStream out, org.eclipse.net4j.util.om.monitor.OMMonitor monitor)RESULTsend()RESULTsend(long timeout)RESULTsend(long timeout, org.eclipse.net4j.util.om.monitor.OMMonitor monitor)RESULTsend(org.eclipse.net4j.util.om.monitor.OMMonitor monitor)java.util.concurrent.Future<RESULT>sendAsync()java.util.concurrent.Future<RESULT>sendAsync(org.eclipse.net4j.util.om.monitor.OMMonitor monitor)- 
Methods inherited from class org.eclipse.net4j.signal.RequestWithConfirmationgetAsyncExecutorService
 - 
Methods inherited from class org.eclipse.net4j.signal.SignalActorexecute
 - 
Methods inherited from class org.eclipse.net4j.signal.SignalcloseChannelAfterMe, closeInputStreamAfterMe, closeOutputStreamAfterMe, finishInputStream, finishOutputStream, flush, getAdditionalInfo, getBufferInputStream, getBufferOutputStream, getCorrelationID, getCurrentInputStream, getCurrentOutputStream, getID, getName, getProtocol, run, toString, toString, wrapInputStream, wrapOutputStream
 
- 
 
- 
- 
- 
Field Detail- 
DEFAULT_CANCELATION_POLL_INTERVALpublic static final long DEFAULT_CANCELATION_POLL_INTERVAL - Since:
- 2.0
- See Also:
- Constant Field Values
 
 - 
DEFAULT_MONITOR_PROGRESS_SECONDSpublic static final int DEFAULT_MONITOR_PROGRESS_SECONDS - Since:
- 2.0
- See Also:
- Constant Field Values
 
 - 
DEFAULT_MONITOR_TIMEOUT_SECONDSpublic static final int DEFAULT_MONITOR_TIMEOUT_SECONDS - Since:
- 2.0
- See Also:
- Constant Field Values
 
 
- 
 - 
Constructor Detail- 
RequestWithMonitoringpublic RequestWithMonitoring(SignalProtocol<?> protocol, short id, java.lang.String name) - Since:
- 2.0
 
 - 
RequestWithMonitoringpublic RequestWithMonitoring(SignalProtocol<?> protocol, short signalID) - Since:
- 2.0
 
 - 
RequestWithMonitoringpublic RequestWithMonitoring(SignalProtocol<?> protocol, java.lang.Enum<?> literal) - Since:
- 2.0
 
 
- 
 - 
Method Detail- 
sendAsyncpublic java.util.concurrent.Future<RESULT> sendAsync() - Overrides:
- sendAsyncin class- RequestWithConfirmation<RESULT>
 
 - 
sendAsyncpublic java.util.concurrent.Future<RESULT> sendAsync(org.eclipse.net4j.util.om.monitor.OMMonitor monitor) 
 - 
sendpublic RESULT send() throws java.lang.Exception, RemoteException - Overrides:
- sendin class- RequestWithConfirmation<RESULT>
- Throws:
- java.lang.Exception
- RemoteException
 
 - 
sendpublic RESULT send(long timeout) throws java.lang.Exception, RemoteException - Overrides:
- sendin class- RequestWithConfirmation<RESULT>
- Throws:
- java.lang.Exception
- RemoteException
 
 - 
sendpublic RESULT send(org.eclipse.net4j.util.om.monitor.OMMonitor monitor) throws java.lang.Exception, RemoteException - Throws:
- java.lang.Exception
- RemoteException
 
 - 
sendpublic RESULT send(long timeout, org.eclipse.net4j.util.om.monitor.OMMonitor monitor) throws java.lang.Exception, RemoteException - Throws:
- java.lang.Exception
- RemoteException
 
 - 
requestingprotected final void requesting(org.eclipse.net4j.util.io.ExtendedDataOutputStream out) throws java.lang.Exception- Specified by:
- requestingin class- RequestWithConfirmation<RESULT>
- Throws:
- java.lang.Exception
 
 - 
confirmingprotected final RESULT confirming(org.eclipse.net4j.util.io.ExtendedDataInputStream in) throws java.lang.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 class- RequestWithConfirmation<RESULT>
- Throws:
- java.lang.Exception
 
 - 
requestingprotected abstract void requesting(org.eclipse.net4j.util.io.ExtendedDataOutputStream out, org.eclipse.net4j.util.om.monitor.OMMonitor monitor) throws java.lang.Exception- Throws:
- java.lang.Exception
 
 - 
confirmingprotected abstract RESULT confirming(org.eclipse.net4j.util.io.ExtendedDataInputStream in, org.eclipse.net4j.util.om.monitor.OMMonitor monitor) throws java.lang.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:
- java.lang.Exception
 
 - 
getCancelationExecutorServiceprotected java.util.concurrent.ExecutorService getCancelationExecutorService() - Since:
- 2.0
 
 - 
getCancelationPollIntervalprotected long getCancelationPollInterval() - Since:
- 2.0
 
 - 
getMonitorProgressSecondsprotected int getMonitorProgressSeconds() - Since:
- 2.0
 
 - 
getMonitorTimeoutSecondsprotected int getMonitorTimeoutSeconds() - Since:
- 2.0
 
 - 
getRequestingWorkPercentprotected int getRequestingWorkPercent() - Since:
- 2.0
 
 - 
getConfirmingWorkPercentprotected int getConfirmingWorkPercent() - Since:
- 2.0
 
 
- 
 
-