Package com.tangosol.coherence.commonj
Class WorkManager.SendFeedback
- java.lang.Object
-
- com.tangosol.util.Base
-
- com.tangosol.net.AbstractInvocable
-
- com.tangosol.coherence.commonj.WorkManager.AbstractWork
-
- com.tangosol.coherence.commonj.WorkManager.SendFeedback
-
- All Implemented Interfaces:
ExternalizableLite
,PortableObject
,Invocable
,InvocableInOrder
,PriorityTask
,Serializable
,Runnable
- Enclosing class:
- WorkManager
protected static class WorkManager.SendFeedback extends WorkManager.AbstractWork
Invocable task that delivers a WorkEvent to a WorkListener.Since there has to be a guaranteed order between the SendFeedBack execution and processing of the WorkItem completion, we should always process this on the service thread (see COH-14990).
- See Also:
- Serialized Form
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class com.tangosol.util.Base
Base.LoggingWriter
-
-
Field Summary
-
Fields inherited from class com.tangosol.coherence.commonj.WorkManager.AbstractWork
m_lWorkId, m_nMemberId
-
Fields inherited from class com.tangosol.util.Base
LOG_ALWAYS, LOG_CONFIG, LOG_DEBUG, LOG_ERR, LOG_INFO, LOG_MAX, LOG_MIN, LOG_QUIET, LOG_WARN, POWER_0, POWER_G, POWER_K, POWER_M, POWER_T, UNIT_D, UNIT_H, UNIT_M, UNIT_MS, UNIT_NS, UNIT_S, UNIT_US
-
Fields inherited from interface com.tangosol.net.PriorityTask
SCHEDULE_FIRST, SCHEDULE_IMMEDIATE, SCHEDULE_STANDARD, TIMEOUT_DEFAULT, TIMEOUT_NONE
-
-
Constructor Summary
Constructors Constructor Description SendFeedback()
Default constructor (necessary for a lite serialization).SendFeedback(WorkManager.WorkStatus status)
Construct a SendFeedback task.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description WorkManager.WorkStatus
getWorkStatus()
Return a WorkStatus object for this feedback.void
init(InvocationService service)
Called by the InvocationService exactly once on this Invocable object as part of its initialization.void
readExternal(PofReader in)
Restore the contents of a user type instance by reading its state using the specified PofReader object.void
readExternal(DataInput in)
Restore the contents of this object by loading the object's state from the passed DataInput object.void
run()
Called exactly once by the InvocationService to invoke this Invocable object.void
writeExternal(PofWriter out)
Save the contents of a POF user type instance by writing its state using the specified PofWriter object.void
writeExternal(DataOutput out)
Save the contents of this object by storing the object's state into the passed DataOutput object.-
Methods inherited from class com.tangosol.coherence.commonj.WorkManager.AbstractWork
getMember, getMemberId, getSchedulingPriority, getWorkId
-
Methods inherited from class com.tangosol.net.AbstractInvocable
getExecutionTimeoutMillis, getRequestTimeoutMillis, getResult, getService, isRespondInOrder, runCanceled, setResult
-
Methods inherited from class com.tangosol.util.Base
azzert, azzert, azzert, azzertFailed, breakLines, breakLines, capitalize, checkNotEmpty, checkNotNull, checkRange, computeSafeWaitTime, decimalValue, dup, dup, ensureBigDecimal, ensureClassLoader, ensureRuntimeException, ensureRuntimeException, equals, equalsDeep, err, err, err, err, err, escape, formatDateTime, getCallerStackFrame, getCommonMonitor, getCommonMonitor, getCommonMonitor, getContextClassLoader, getContextClassLoader, getDeepMessage, getErr, getLastSafeTimeMillis, getLog, getMaxDecDigits, getMaxHexDigits, getOriginalException, getOut, getProcessRandom, getRandom, getRandomBinary, getRandomBinary, getRandomString, getSafeTimeMillis, getStackFrame, getStackFrames, getStackTrace, getStackTrace, getStackTrace, getThreadFactory, getTimeZone, getUpTimeMillis, hashCode, hexValue, indentString, indentString, isDecimal, isHex, isLogEcho, isOctal, log, log, log, log, log, makeInteger, makeLong, makeThread, mergeArray, mergeBooleanArray, mergeByteArray, mergeCharArray, mergeDoubleArray, mergeFloatArray, mergeIntArray, mergeLongArray, mod, mod, octalValue, out, out, out, out, out, pad, parseBandwidth, parseBandwidth, parseDelimitedString, parseHex, parseHex, parseMemorySize, parseMemorySize, parsePercentage, parseTime, parseTime, parseTimeNanos, parseTimeNanos, printStackTrace, randomize, randomize, randomize, randomize, read, read, read, read, read, read, read, replace, setErr, setLog, setLogEcho, setOut, sleep, toBandwidthString, toBandwidthString, toCharEscape, toCrc, toCrc, toCrc, toCrc, toCrc, toDecString, toDelimitedString, toDelimitedString, toDelimitedString, toDelimitedString, toHex, toHex, toHexDump, toHexEscape, toHexEscape, toHexEscape, toHexEscape, toHexString, toMemorySizeString, toMemorySizeString, toQuotedCharEscape, toQuotedStringEscape, toSqlString, toString, toString, toStringEscape, toUnicodeEscape, trace, trace, trace, trace, trace, trace, trace, trace, trace, truncateString, truncateString, wait
-
-
-
-
Constructor Detail
-
SendFeedback
public SendFeedback()
Default constructor (necessary for a lite serialization).
-
SendFeedback
public SendFeedback(WorkManager.WorkStatus status)
Construct a SendFeedback task.- Parameters:
status
- the work status
-
-
Method Detail
-
init
public void init(InvocationService service)
Called by the InvocationService exactly once on this Invocable object as part of its initialization.- Specified by:
init
in interfaceInvocable
- Overrides:
init
in classAbstractInvocable
- Parameters:
service
- the containing InvocationService
-
run
public void run()
Called exactly once by the InvocationService to invoke this Invocable object.
-
getWorkStatus
public WorkManager.WorkStatus getWorkStatus()
Return a WorkStatus object for this feedback.- Returns:
- a WorkStatus object
-
readExternal
public void readExternal(DataInput in) throws IOException
Restore the contents of this object by loading the object's state from the passed DataInput object.- Specified by:
readExternal
in interfaceExternalizableLite
- Overrides:
readExternal
in classWorkManager.AbstractWork
- Parameters:
in
- the DataInput stream to read data from in order to restore the state of this object- Throws:
IOException
- if an I/O exception occursNotActiveException
- if the object is not in its initial state, and therefore cannot be deserialized into
-
writeExternal
public void writeExternal(DataOutput out) throws IOException
Save the contents of this object by storing the object's state into the passed DataOutput object.- Specified by:
writeExternal
in interfaceExternalizableLite
- Overrides:
writeExternal
in classWorkManager.AbstractWork
- Parameters:
out
- the DataOutput stream to write the state of this object to- Throws:
IOException
- if an I/O exception occurs
-
readExternal
public void readExternal(PofReader in) throws IOException
Restore the contents of a user type instance by reading its state using the specified PofReader object.- Specified by:
readExternal
in interfacePortableObject
- Overrides:
readExternal
in classWorkManager.AbstractWork
- Parameters:
in
- the PofReader from which to read the object's state- Throws:
IOException
- if an I/O error occurs
-
writeExternal
public void writeExternal(PofWriter out) throws IOException
Save the contents of a POF user type instance by writing its state using the specified PofWriter object.- Specified by:
writeExternal
in interfacePortableObject
- Overrides:
writeExternal
in classWorkManager.AbstractWork
- Parameters:
out
- the PofWriter to which to write the object's state- Throws:
IOException
- if an I/O error occurs
-
-