public abstract class RequestWithMonitoring<RESULT> extends RequestWithConfirmation<RESULT>
signal with additional support for remote progress monitoring.| Modifier and Type | Field and Description |
|---|---|
static long |
DEFAULT_CANCELATION_POLL_INTERVAL |
static int |
DEFAULT_MONITOR_PROGRESS_SECONDS |
static int |
DEFAULT_MONITOR_TIMEOUT_SECONDS |
NO_TIMEOUT| Constructor and Description |
|---|
RequestWithMonitoring(SignalProtocol<?> protocol,
java.lang.Enum<?> literal) |
RequestWithMonitoring(SignalProtocol<?> protocol,
short signalID) |
RequestWithMonitoring(SignalProtocol<?> protocol,
short id,
java.lang.String name) |
| Modifier and Type | Method and Description |
|---|---|
protected RESULT |
confirming(ExtendedDataInputStream in)
Important Note: The confirmation must not be empty, i.e.
|
protected abstract RESULT |
confirming(ExtendedDataInputStream in,
OMMonitor monitor)
Important Note: The confirmation must not be empty, i.e.
|
protected java.util.concurrent.ExecutorService |
getCancelationExecutorService() |
protected long |
getCancelationPollInterval() |
protected int |
getConfirmingWorkPercent() |
protected int |
getMonitorProgressSeconds() |
protected int |
getMonitorTimeoutSeconds() |
protected int |
getRequestingWorkPercent() |
protected void |
requesting(ExtendedDataOutputStream out) |
protected abstract void |
requesting(ExtendedDataOutputStream out,
OMMonitor monitor) |
RESULT |
send() |
RESULT |
send(long timeout) |
RESULT |
send(long timeout,
OMMonitor monitor) |
RESULT |
send(OMMonitor monitor) |
java.util.concurrent.Future<RESULT> |
sendAsync() |
java.util.concurrent.Future<RESULT> |
sendAsync(OMMonitor monitor) |
getAsyncExecutorServiceexecutecloseChannelAfterMe, closeInputStreamAfterMe, closeOutputStreamAfterMe, finishInputStream, finishOutputStream, flush, getAdditionalInfo, getBufferInputStream, getBufferOutputStream, getCorrelationID, getCurrentInputStream, getCurrentOutputStream, getID, getName, getProtocol, run, toString, wrapInputStream, wrapOutputStreampublic static final long DEFAULT_CANCELATION_POLL_INTERVAL
public static final int DEFAULT_MONITOR_PROGRESS_SECONDS
public static final int DEFAULT_MONITOR_TIMEOUT_SECONDS
public RequestWithMonitoring(SignalProtocol<?> protocol, short id, java.lang.String name)
public RequestWithMonitoring(SignalProtocol<?> protocol, short signalID)
public RequestWithMonitoring(SignalProtocol<?> protocol, java.lang.Enum<?> literal)
public java.util.concurrent.Future<RESULT> sendAsync()
sendAsync in class RequestWithConfirmation<RESULT>public RESULT send() throws java.lang.Exception, RemoteException
send in class RequestWithConfirmation<RESULT>java.lang.ExceptionRemoteExceptionpublic RESULT send(long timeout) throws java.lang.Exception, RemoteException
send in class RequestWithConfirmation<RESULT>java.lang.ExceptionRemoteExceptionpublic RESULT send(OMMonitor monitor) throws java.lang.Exception, RemoteException
java.lang.ExceptionRemoteExceptionpublic RESULT send(long timeout, OMMonitor monitor) throws java.lang.Exception, RemoteException
java.lang.ExceptionRemoteExceptionprotected final void requesting(ExtendedDataOutputStream out) throws java.lang.Exception
requesting in class RequestWithConfirmation<RESULT>java.lang.Exceptionprotected final RESULT confirming(ExtendedDataInputStream in) throws java.lang.Exception
RequestWithConfirmationboolean. Otherwise synchronization problems will result!confirming in class RequestWithConfirmation<RESULT>java.lang.Exceptionprotected abstract void requesting(ExtendedDataOutputStream out, OMMonitor monitor) throws java.lang.Exception
java.lang.Exceptionprotected abstract RESULT confirming(ExtendedDataInputStream in, OMMonitor monitor) throws java.lang.Exception
boolean. Otherwise synchronization problems will result!java.lang.Exceptionprotected java.util.concurrent.ExecutorService getCancelationExecutorService()
protected long getCancelationPollInterval()
protected int getMonitorProgressSeconds()
protected int getMonitorTimeoutSeconds()
protected int getRequestingWorkPercent()
protected int getConfirmingWorkPercent()
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