Class RequestWithMonitoring<RESULT>

    • 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,
                                     java.lang.String name)
        Since:
        2.0
      • RequestWithMonitoring

        public RequestWithMonitoring​(SignalProtocol<?> protocol,
                                     short signalID)
        Since:
        2.0
      • RequestWithMonitoring

        public RequestWithMonitoring​(SignalProtocol<?> protocol,
                                     java.lang.Enum<?> literal)
        Since:
        2.0
    • Method Detail

      • sendAsync

        public java.util.concurrent.Future<RESULT> sendAsync​(org.eclipse.net4j.util.om.monitor.OMMonitor monitor)
      • send

        public RESULT send​(long timeout,
                           org.eclipse.net4j.util.om.monitor.OMMonitor monitor)
                    throws java.lang.Exception,
                           RemoteException
        Throws:
        java.lang.Exception
        RemoteException
      • requesting

        protected final void requesting​(org.eclipse.net4j.util.io.ExtendedDataOutputStream out)
                                 throws java.lang.Exception
        Specified by:
        requesting in class RequestWithConfirmation<RESULT>
        Throws:
        java.lang.Exception
      • confirming

        protected final RESULT confirming​(org.eclipse.net4j.util.io.ExtendedDataInputStream in)
                                   throws java.lang.Exception
        Description copied from class: RequestWithConfirmation
        Important Note: The confirmation must not be empty, i.e. the stream must be used at least to read a boolean. Otherwise synchronization problems will result!
        Specified by:
        confirming in class RequestWithConfirmation<RESULT>
        Throws:
        java.lang.Exception
      • requesting

        protected 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
      • confirming

        protected 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 a boolean. Otherwise synchronization problems will result!
        Throws:
        java.lang.Exception
      • getCancelationExecutorService

        protected java.util.concurrent.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