|
Oracle® Coherence Java API Reference Release 12.1.2.0.3 E26043-02 |
|||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object
com.tangosol.util.Base
com.tangosol.coherence.commonj.WorkManager.RemoteWorkManager
protected class WorkManager.RemoteWorkManager
RemoteWorkManager is a delegating WorkManager wrapper.
Field Summary | |
---|---|
protected Member |
m_memberPinned The service Member this RemoteWorkManager is pinned to. |
Fields inherited from interface commonj.work.WorkManager |
---|
IMMEDIATE, INDEFINITE |
Constructor Summary | |
---|---|
WorkManager.RemoteWorkManager(Member memberPinned) |
Method Summary | |
---|---|
commonj.work.WorkItem |
schedule(commonj.work.Work work) Dispatches a Work asynchronously. |
commonj.work.WorkItem |
schedule(commonj.work.Work work, commonj.work.WorkListener workListener) Dispatches a Work asynchronously. |
protected commonj.work.WorkItem |
schedule(commonj.work.Work work, commonj.work.WorkListener workListener, Member member) Accepts a Work instance for processing at the specified Member. |
boolean |
waitForAll(java.util.Collection collWorkItems, long lTimeoutMillis) |
java.util.Collection |
waitForAny(java.util.Collection collWorkItems, long lTimeoutMillis) |
Field Detail |
---|
protected Member m_memberPinned
Constructor Detail |
---|
public WorkManager.RemoteWorkManager(Member memberPinned)
Method Detail |
---|
public commonj.work.WorkItem schedule(commonj.work.Work work) throws commonj.work.WorkException, java.lang.IllegalArgumentException
If a JVM that this pinned WorkManager represents has failed then a WorkRejectedException
will be thrown even if the remote JVM restarts. The pinned WorkManager must be refreshed by using a normal WorkManager and then acquiring a new pinned WorkManager.
schedule
in interface commonj.work.WorkManager
work
- the Work to executecommonj.work.WorkException
- thrown if queuing this up results in an exceptionjava.lang.IllegalArgumentException
public commonj.work.WorkItem schedule(commonj.work.Work work, commonj.work.WorkListener workListener) throws commonj.work.WorkException, java.lang.IllegalArgumentException
If a JVM that this pinned WorkManager represents has failed then a WorkRejectedException
will be thrown even if the remote JVM restarts. The pinned WorkManager must be refreshed by using a normal WorkManager and then acquiring a new pinned WorkManager.
schedule
in interface commonj.work.WorkManager
work
- the Work to executecommonj.work.WorkException
- thrown if queuing this up results in an exceptionjava.lang.IllegalArgumentException
protected commonj.work.WorkItem schedule(commonj.work.Work work, commonj.work.WorkListener workListener, Member member) throws commonj.work.WorkException
work
- the Work to executeworkListener
- an optional WorkListener which is used to inform the application of the progress of a Workmember
- the Member to execute the Work atcommonj.work.WorkException
- thrown if queuing this up results in an exceptionpublic boolean waitForAll(java.util.Collection collWorkItems, long lTimeoutMillis) throws java.lang.InterruptedException, java.lang.IllegalArgumentException
waitForAll
in interface commonj.work.WorkManager
java.lang.InterruptedException
java.lang.IllegalArgumentException
WorkManager.waitForAll(java.util.Collection, long)
public java.util.Collection waitForAny(java.util.Collection collWorkItems, long lTimeoutMillis) throws java.lang.InterruptedException, java.lang.IllegalArgumentException
waitForAny
in interface commonj.work.WorkManager
java.lang.InterruptedException
java.lang.IllegalArgumentException
WorkManager.waitForAny(java.util.Collection, long)
|
Oracle® Coherence Java API Reference Release 12.1.2.0.3 E26043-02 |
|||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |