Package org.jppf.server.job.management

Class DriverJobManagement

java.lang.Object
javax.management.NotificationBroadcasterSupport
org.jppf.server.job.management.DriverJobManagement
All Implemented Interfaces:
NotificationBroadcaster, NotificationEmitter, org.jppf.server.job.management.DriverJobManagementMBean
public class DriverJobManagement extends NotificationBroadcasterSupport implements org.jppf.server.job.management.DriverJobManagementMBean
Implementation of the job management bean.
Author:
Laurent Cohen

  • Constructor Details

    • DriverJobManagement

      public DriverJobManagement(JPPFDriver driver)
      Initialize this MBean.
      Parameters:
      driver - reference to the JPPF driver.

  • Method Details

    • cancelJob

      public void cancelJob(String jobUuid) throws Exception
      Specified by:
      cancelJob in interface org.jppf.server.job.management.DriverJobManagementMBean
      Throws:
      Exception

    • suspendJob

      public void suspendJob(String jobUuid, Boolean requeue) throws Exception
      Specified by:
      suspendJob in interface org.jppf.server.job.management.DriverJobManagementMBean
      Throws:
      Exception

    • resumeJob

      public void resumeJob(String jobUuid) throws Exception
      Specified by:
      resumeJob in interface org.jppf.server.job.management.DriverJobManagementMBean
      Throws:
      Exception

    • updateMaxNodes

      public void updateMaxNodes(String jobUuid, Integer maxNodes) throws Exception
      Specified by:
      updateMaxNodes in interface org.jppf.server.job.management.DriverJobManagementMBean
      Throws:
      Exception

    • getAllJobUuids

      public String[] getAllJobUuids() throws Exception
      Specified by:
      getAllJobUuids in interface org.jppf.server.job.management.DriverJobManagementMBean
      Throws:
      Exception

    • getJobInformation

      public org.jppf.job.JobInformation getJobInformation(String jobUuid) throws Exception
      Get an object describing the job with the specified uuid.
      Specified by:
      getJobInformation in interface org.jppf.server.job.management.DriverJobManagementMBean
      Parameters:
      jobUuid - the id of the job to get information about.
      Returns:
      an instance of JobInformation.
      Throws:
      Exception - if any error occurs.

    • getNodeInformation

      public org.jppf.server.job.management.NodeJobInformation[] getNodeInformation(String jobUuid) throws Exception
      Specified by:
      getNodeInformation in interface org.jppf.server.job.management.DriverJobManagementMBean
      Throws:
      Exception

    • updatePriority

      public void updatePriority(String jobUuid, Integer newPriority)
      Specified by:
      updatePriority in interface org.jppf.server.job.management.DriverJobManagementMBean

    • sendNotification

      public void sendNotification(Notification notification)
      Overrides:
      sendNotification in class NotificationBroadcasterSupport

    • cancelJobs

      public void cancelJobs(org.jppf.job.JobSelector selector) throws Exception
      Specified by:
      cancelJobs in interface org.jppf.server.job.management.DriverJobManagementMBean
      Throws:
      Exception

    • suspendJobs

      public void suspendJobs(org.jppf.job.JobSelector selector, Boolean requeue) throws Exception
      Specified by:
      suspendJobs in interface org.jppf.server.job.management.DriverJobManagementMBean
      Throws:
      Exception

    • resumeJobs

      public void resumeJobs(org.jppf.job.JobSelector selector) throws Exception
      Specified by:
      resumeJobs in interface org.jppf.server.job.management.DriverJobManagementMBean
      Throws:
      Exception

    • updateMaxNodes

      public void updateMaxNodes(org.jppf.job.JobSelector selector, Integer maxNodes) throws Exception
      Specified by:
      updateMaxNodes in interface org.jppf.server.job.management.DriverJobManagementMBean
      Throws:
      Exception

    • getJobInformation

      public org.jppf.job.JobInformation[] getJobInformation(org.jppf.job.JobSelector selector) throws Exception
      Specified by:
      getJobInformation in interface org.jppf.server.job.management.DriverJobManagementMBean
      Throws:
      Exception

    • getNodeInformation

      public Map<String,org.jppf.server.job.management.NodeJobInformation[]> getNodeInformation(org.jppf.job.JobSelector selector) throws Exception
      Specified by:
      getNodeInformation in interface org.jppf.server.job.management.DriverJobManagementMBean
      Throws:
      Exception

    • updatePriority

      public void updatePriority(org.jppf.job.JobSelector selector, Integer newPriority)
      Specified by:
      updatePriority in interface org.jppf.server.job.management.DriverJobManagementMBean

    • updateJobs

      public void updateJobs(org.jppf.job.JobSelector selector, org.jppf.node.protocol.JobSLA sla, org.jppf.node.protocol.JobMetadata metadata)
      Specified by:
      updateJobs in interface org.jppf.server.job.management.DriverJobManagementMBean

    • addNotificationListener

      public void addNotificationListener(NotificationListener listener, NotificationFilter filter, Object handback)
      Specified by:
      addNotificationListener in interface NotificationBroadcaster
      Overrides:
      addNotificationListener in class NotificationBroadcasterSupport

    • removeNotificationListener

      public void removeNotificationListener(NotificationListener listener) throws ListenerNotFoundException
      Specified by:
      removeNotificationListener in interface NotificationBroadcaster
      Overrides:
      removeNotificationListener in class NotificationBroadcasterSupport
      Throws:
      ListenerNotFoundException

    • removeNotificationListener

      public void removeNotificationListener(NotificationListener listener, NotificationFilter filter, Object handback) throws ListenerNotFoundException
      Specified by:
      removeNotificationListener in interface NotificationEmitter
      Overrides:
      removeNotificationListener in class NotificationBroadcasterSupport
      Throws:
      ListenerNotFoundException