Class JobSink
java.lang.Object
QueueNet.NodeSection
NodeSections.PipeSection
NodeSections.InputSection
NodeSections.JobSink
This class implements a sink: every incoming job is destroyed.
- Author:
- Francesco Radaelli
-
Field Summary
Fields inherited from class NodeSection
EXCEPTION_MEASURE_DOES_NOT_EXIST, EXCEPTION_PROPERTY_NOT_AVAILABLE, INPUT, jobsList, logger, MSG_NOT_PROCESSED, MSG_PROCESSED, NO_ADDRESS, OUTPUT, PROPERTY_ID_ARRIVING_JOBS, PROPERTY_ID_AVERAGE_UTILIZATION, PROPERTY_ID_DEPARTING_JOBS, PROPERTY_ID_RESIDENCE_TIME, PROPERTY_ID_RESIDENT_JOBS, PROPERTY_ID_UTILIZATION, SERVICE -
Constructor Summary
ConstructorsConstructorDescriptionJobSink()Default Constructor creates the JobSink that can be used only as Input Section. -
Method Summary
Modifier and TypeMethodDescriptionprotected voidnodeLinked(NetNode node) This method should be overridden to implement a specific behaviour of the node section when the node section itself is linked to the owner node.protected intprocess(NetMessage message) This method implements a sink.voidshowForkJobExitWarning(JobClass jobClass) Shows the fork job exit warning.Methods inherited from class InputSection
sendForward, sendForwardMethods inherited from class NodeSection
analyze, analyze, analyzeFCR, analyzeFJ, analyzeJoin, analyzeTransition, getClassCompatibilities, getDoubleSectionProperty, getDoubleSectionProperty, getIntSectionProperty, getIntSectionProperty, getJobClasses, getJobInfoList, getObject, getObject, getOwnerNode, getParameter, getParameter, getSectionID, getServerTypes, isEnabled, isEnabled, isMine, isMyOwnerNode, redirect, removeMessage, send, send, send, send, send, send, sendAckAfterDrop, sendMe, sendMe, updateVisitPath
-
Constructor Details
-
JobSink
public JobSink()Default Constructor creates the JobSink that can be used only as Input Section.
-
-
Method Details
-
nodeLinked
Description copied from class:NodeSectionThis method should be overridden to implement a specific behaviour of the node section when the node section itself is linked to the owner node. This method should be used to set node section properties depending on the owner node ones.- Overrides:
nodeLinkedin classNodeSection- Parameters:
node- Owner node.- Throws:
NetException
-
process
This method implements a sink. It eats all incoming jobs.- Specified by:
processin classNodeSection- Parameters:
message- message to be processed.- Returns:
- the resulting int
- Throws:
NetException
-
showForkJobExitWarning
Shows the fork job exit warning.
-