Package org.unidata.mdm.core.service.job

Interface JobRemoteStepProcessor

  • All Superinterfaces:
    org.springframework.beans.factory.DisposableBean
    public interface JobRemoteStepProcessor
extends org.springframework.beans.factory.DisposableBean
    Receives and processes remote step execution requests on workers.
    Since:
    6.14

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      int getAwaitTerminationInSeconds()
      Returns the await termination timeout in seconds.
      com.hazelcast.core.HazelcastInstance getHazelcastInstance()
      Returns the Hazelcast instance which is used.
      org.springframework.batch.core.explore.JobExplorer getJobExplorer()
      Returns the job explorer.
      java.lang.String getJobName()
      Job name getter.
      org.springframework.batch.core.repository.JobRepository getJobRepository()
      Returns the job repository.
      com.hazelcast.collection.IQueue<org.springframework.messaging.Message<org.springframework.batch.integration.partition.StepExecutionRequest>> getQueue()
      Returns the queue.
      org.springframework.batch.core.step.StepLocator getStepLocator()
      Returns the step locator.
      int getThreadCount()
      Returns the thread count.
      com.hazelcast.topic.ITopic<org.springframework.messaging.Message<org.springframework.batch.integration.partition.StepExecutionRequest>> getTopic()
      Returns the topic.
      void setAwaitTerminationInSeconds​(int awaitTerminationInSeconds)
      Await termination timeout setter.
      void setJobExplorer​(org.springframework.batch.core.explore.JobExplorer jobExplorer)
      An explorer that should be used to check for StepExecution completion.
      void setJobName​(java.lang.String jobName)
      The job tag.
      void setJobRepository​(org.springframework.batch.core.repository.JobRepository jobRepository)
      Sets the job repository instance to use.
      void setQueue​(com.hazelcast.collection.IQueue<org.springframework.messaging.Message<org.springframework.batch.integration.partition.StepExecutionRequest>> queue)
      Queue instance setter.
      void setStepLocator​(org.springframework.batch.core.step.StepLocator stepLocator)
      Used to locate a Step to execute for each request.
      void setThreadCount​(int threadCount)
      Thread count setter.
      void setTopic​(com.hazelcast.topic.ITopic<org.springframework.messaging.Message<org.springframework.batch.integration.partition.StepExecutionRequest>> topic)
      Queue instance setter.

      • Methods inherited from interface org.springframework.beans.factory.DisposableBean

        destroy

    • Method Detail

      • setStepLocator

        void setStepLocator​(org.springframework.batch.core.step.StepLocator stepLocator)
        Used to locate a Step to execute for each request.
        Parameters:
        stepLocator - a StepLocator

      • getStepLocator

        org.springframework.batch.core.step.StepLocator getStepLocator()
        Returns the step locator.
        Returns:
        the stepLocator

      • setJobExplorer

        void setJobExplorer​(org.springframework.batch.core.explore.JobExplorer jobExplorer)
        An explorer that should be used to check for StepExecution completion.
        Parameters:
        jobExplorer - a JobExplorer that is linked to the shared repository used by all remote workers.

      • getJobExplorer

        org.springframework.batch.core.explore.JobExplorer getJobExplorer()
        Returns the job explorer.
        Returns:
        the jobExplorer

      • setJobRepository

        void setJobRepository​(org.springframework.batch.core.repository.JobRepository jobRepository)
        Sets the job repository instance to use.
        Parameters:
        jobRepository - the jobRepository to set

      • getJobRepository

        org.springframework.batch.core.repository.JobRepository getJobRepository()
        Returns the job repository.
        Returns:
        the jobRepository

      • setJobName

        void setJobName​(java.lang.String jobName)
        The job tag.
        Parameters:
        jobName - the jobName to set

      • getJobName

        java.lang.String getJobName()
        Job name getter.
        Returns:
        the jobName

      • setQueue

        void setQueue​(com.hazelcast.collection.IQueue<org.springframework.messaging.Message<org.springframework.batch.integration.partition.StepExecutionRequest>> queue)
        Queue instance setter.
        Parameters:
        queue - the queue to set

      • getQueue

        com.hazelcast.collection.IQueue<org.springframework.messaging.Message<org.springframework.batch.integration.partition.StepExecutionRequest>> getQueue()
        Returns the queue.
        Returns:
        the queue

      • setTopic

        void setTopic​(com.hazelcast.topic.ITopic<org.springframework.messaging.Message<org.springframework.batch.integration.partition.StepExecutionRequest>> topic)
        Queue instance setter.
        Parameters:
        topic - the queue to set

      • getTopic

        com.hazelcast.topic.ITopic<org.springframework.messaging.Message<org.springframework.batch.integration.partition.StepExecutionRequest>> getTopic()
        Returns the topic.
        Returns:
        the topic

      • setThreadCount

        void setThreadCount​(int threadCount)
        Thread count setter.
        Parameters:
        threadCount - the thread count

      • getThreadCount

        int getThreadCount()
        Returns the thread count.
        Returns:
        the threadCount

      • setAwaitTerminationInSeconds

        void setAwaitTerminationInSeconds​(int awaitTerminationInSeconds)
        Await termination timeout setter.
        Parameters:
        awaitTerminationInSeconds - the timeout

      • getAwaitTerminationInSeconds

        int getAwaitTerminationInSeconds()
        Returns the await termination timeout in seconds.
        Returns:
        the awaitTerminationInSeconds

      • getHazelcastInstance

        com.hazelcast.core.HazelcastInstance getHazelcastInstance()
        Returns the Hazelcast instance which is used.
        Returns:
        the HazelcastInstance which is used