public class DispatchJobQueueEvent extends AbstractDispatchEvent<DispatchJobQueueEvent>
Constructor and Description |
---|
DispatchJobQueueEvent(String owner,
InvocationContext context,
BlockingQueue<IterationInternalEvent<? extends IterationInternalEvent<?>>> queue,
List<? extends Activity<?>> activities)
Create a new job queue event, specifying the queue of Completion and Job
objects and the list of activities which will be used to process the
corresponding dispatch events
|
Modifier and Type | Method and Description |
---|---|
List<? extends Activity<?>> |
getActivities() |
DispatchMessageType |
getMessageType()
Return the DispatchMessageType for this event object
|
BlockingQueue<IterationInternalEvent<? extends IterationInternalEvent<?>>> |
getQueue() |
DispatchJobQueueEvent |
popOwningProcess()
Return a copy of the event subclass with the last owning process removed
from the owning process list.
|
DispatchJobQueueEvent |
pushOwningProcess(String localProcessName)
Return a copy of the event subclass with the specified local process name
appended to the owning process identifier field.
|
getContext, getIndex, getOwningProcess, isFinal, popOwner, pushOwner, toString
public DispatchJobQueueEvent(String owner, InvocationContext context, BlockingQueue<IterationInternalEvent<? extends IterationInternalEvent<?>>> queue, List<? extends Activity<?>> activities)
owner
- context
- queue
- activities
- public BlockingQueue<IterationInternalEvent<? extends IterationInternalEvent<?>>> getQueue()
public DispatchJobQueueEvent popOwningProcess() throws ProcessIdentifierException
Event
popOwningProcess
in class Event<DispatchJobQueueEvent>
ProcessIdentifierException
public DispatchJobQueueEvent pushOwningProcess(String localProcessName) throws ProcessIdentifierException
Event
pushOwningProcess
in class Event<DispatchJobQueueEvent>
localProcessName
- name to addProcessIdentifierException
- if the local process name contains the ':' characterpublic DispatchMessageType getMessageType()
AbstractDispatchEvent
getMessageType
in class AbstractDispatchEvent<DispatchJobQueueEvent>
DispatchMessageType.JOB_QUEUE
.Copyright © 2015–2016 The Apache Software Foundation. All rights reserved.