public class DispatchJobEvent extends AbstractDispatchEvent<DispatchJobEvent>
Constructor and Description |
---|
DispatchJobEvent(String owningProcess,
int[] index,
InvocationContext context,
Map<String,T2Reference> data,
List<? extends Activity<?>> activities)
Create a new job event, specifying a complete set of input data and a
list of activities which could potentially consume this data
|
Modifier and Type | Method and Description |
---|---|
List<? extends Activity<?>> |
getActivities()
Returns a list of activity instances which can be applied to the data
contained by this job event.
|
Map<String,T2Reference> |
getData()
The actual data carried by this dispatch job event object is in the form
of a map, where the keys of the map are Strings identifying the named
input and the values are Strings containing valid data identifiers within
the context of a visible DataManager object (see CloudOne specification
for further information on the DataManager system)
|
DispatchMessageType |
getMessageType()
Return the DispatchMessageType for this event object
|
DispatchJobEvent |
popOwningProcess()
Return a copy of the event subclass with the last owning process removed
from the owning process list.
|
DispatchJobEvent |
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 DispatchJobEvent(String owningProcess, int[] index, InvocationContext context, Map<String,T2Reference> data, List<? extends Activity<?>> activities)
owningProcess
- index
- context
- data
- activities
- public Map<String,T2Reference> getData()
public List<? extends Activity<?>> getActivities()
public DispatchJobEvent popOwningProcess() throws ProcessIdentifierException
Event
popOwningProcess
in class Event<DispatchJobEvent>
ProcessIdentifierException
public DispatchJobEvent pushOwningProcess(String localProcessName) throws ProcessIdentifierException
Event
pushOwningProcess
in class Event<DispatchJobEvent>
localProcessName
- name to addProcessIdentifierException
- if the local process name contains the ':' characterpublic DispatchMessageType getMessageType()
AbstractDispatchEvent
getMessageType
in class AbstractDispatchEvent<DispatchJobEvent>
DispatchMessageType.JOB
.Copyright © 2015–2016 The Apache Software Foundation. All rights reserved.