Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * Copyright 2012 Amazon.com, Inc. or its affiliates. All Rights Reserved.
   *
   * Licensed under the Apache License, Version 2.0 (the "License").
   * You may not use this file except in compliance with the License.
   * A copy of the License is located at
   *
   *  http://aws.amazon.com/apache2.0
   *
  * or in the "license" file accompanying this file. This file is distributed
  * on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
  * express or implied. See the License for the specific language governing
  * permissions and limitations under the License.
  */
 package com.amazonaws.services.simpleworkflow.flow.spring;
 
 import java.util.List;
 
 import  org.springframework.context.SmartLifecycle;
 
 
 public class SpringActivityWorker implements WorkerBase, SmartLifecycle {
     
     private final GenericActivityWorker genericWorker;
     
 
     private int startPhase;
 
     private long terminationTimeoutSeconds = 60;
 
     private boolean disableAutoStartup;
     
     public SpringActivityWorker() {
          = new GenericActivityWorker();
     }
 
     public SpringActivityWorker(AmazonSimpleWorkflow serviceString domainString taskListToPoll) {
          = new GenericActivityWorker(servicedomaintaskListToPoll);
     }
     
     public AmazonSimpleWorkflow getService() {
         return .getService();
     }
 
     public void setService(AmazonSimpleWorkflow service) {
         .setService(service);
     }
     
     public String getDomain() {
         return .getDomain();
     }
     
     public void setDomain(String domain) {
         .setDomain(domain);
     }
     
     public boolean isRegisterDomain() {
         return .isRegisterDomain();
     }
     
     public void setRegisterDomain(boolean registerDomain) {
         .setRegisterDomain(registerDomain);
     }
     
     public long getDomainRetentionPeriodInDays() {
         return .getDomainRetentionPeriodInDays();
     }
     
     public void setDomainRetentionPeriodInDays(long domainRetentionPeriodInDays) {
         .setDomainRetentionPeriodInDays(domainRetentionPeriodInDays);
     }
     
     public String getTaskListToPoll() {
         return .getTaskListToPoll();
     }
     
     public void setTaskListToPoll(String taskListToPoll) {
         .setTaskListToPoll(taskListToPoll);
     }
     
     public DataConverter getDataConverter() {
         return .getDataConverter();
     }
 
     public void setDataConverter(DataConverter dataConverter) {
         .setDataConverter(dataConverter);
     }
 
    public double getMaximumPollRatePerSecond() {
    }
    
    public void setMaximumPollRatePerSecond(double maximumPollRatePerSecond) {
        .setMaximumPollRatePerSecond(maximumPollRatePerSecond);
    }
    }
    
    public void setMaximumPollRateIntervalMilliseconds(int maximumPollRateIntervalMilliseconds) {
        .setMaximumPollRateIntervalMilliseconds(maximumPollRateIntervalMilliseconds);
    }
    public String getIdentity() {
        return .getIdentity();
    }
    
    public void setIdentity(String identity) {
        .setIdentity(identity);
    }
    
    }
    public void setUncaughtExceptionHandler(UncaughtExceptionHandler uncaughtExceptionHandler) {
        .setUncaughtExceptionHandler(uncaughtExceptionHandler);
    }
    
    public long getPollBackoffInitialInterval() {
    }
    
    public void setPollBackoffInitialInterval(long backoffInitialInterval) {
        .setPollBackoffInitialInterval(backoffInitialInterval);
    }
    public long getPollBackoffMaximumInterval() {
    }
    public void setPollBackoffMaximumInterval(long backoffMaximumInterval) {
        .setPollBackoffMaximumInterval(backoffMaximumInterval);
    }
    public double getPollBackoffCoefficient() {
        return .getPollBackoffCoefficient();
    }
    
    public void setPollBackoffCoefficient(double backoffCoefficient) {
        .setPollBackoffCoefficient(backoffCoefficient);
    }
    
    public int getPollThreadCount() {
        return .getPollThreadCount();
    }
    public void setPollThreadCount(int threadCount) {
        .setPollThreadCount(threadCount);
    }
    
    public int getTaskExecutorThreadPoolSize() {
    }
    public void setTaskExecutorThreadPoolSize(int taskExecutorThreadPoolSize) {
        .setTaskExecutorThreadPoolSize(taskExecutorThreadPoolSize);
    }
    
    public boolean isDisableServiceShutdownOnStop() {
    }
    
    public void setDisableServiceShutdownOnStop(boolean disableServiceShutdownOnStop) {
        .setDisableServiceShutdownOnStop(disableServiceShutdownOnStop);
    }
    
    public void suspendPolling() {
        .suspendPolling();
    }
    public void resumePolling() {
        .resumePolling();
    }
    
    @Override
    public void start() {
        .start();
    }
    
    public void stopNow() {
        .shutdownNow();
    }
    
    @Override
    public void shutdown() {
        .shutdown();
    }
    @Override
    public void shutdownNow() {
        .shutdownNow();
    }
    @Override
    public boolean shutdownAndAwaitTermination(long timeoutTimeUnit unitthrows InterruptedException {
        return .shutdownAndAwaitTermination(timeoutunit);
    }
    public boolean awaitTermination(long timeoutTimeUnit unitthrows InterruptedException {
        return .awaitTermination(timeoutunit);
    }
    
    @Override
    public void stop() {
        shutdown();
        try {
        }
        catch (InterruptedException e) {
        }
    }
    
    public boolean isRunning() {
        return .isRunning();
    }
    
    public void setActivitiesImplementations(Iterable<ObjectactivitiesImplementations)
        for (Object activitiesImplementation : activitiesImplementations) {
            addActivitiesImplementation(activitiesImplementation);
        }
    }
    
        return .getActivitiesImplementations();
    }
    
    public List<ActivityTypeaddActivitiesImplementation(Object activitiesImplementation)
        return .addActivitiesImplementation(activitiesImplementation);
    }
    @Override
    public void registerTypesToPoll() {
    }

    

Returns:
default is 0
    @Override
    public int getPhase() {
        return ;
    }
    public void setPhase(int startPhase) {
        this. = startPhase;
    }
    
    @Override
    public boolean isAutoStartup() {
        return !;
    }
    public long getTerminationTimeoutSeconds() {
        return ;
    }
    public void setTerminationTimeoutSeconds(long terminationTimeoutSeconds) {
        this. = terminationTimeoutSeconds;
    }
    public boolean isDisableAutoStartup() {
        return ;
    }
    public void setDisableAutoStartup(boolean disableAutoStartup) {
        this. = disableAutoStartup;
    }
    
    @Override
    public void setDisableTypeRegistrationOnStart(boolean disableTypeRegistrationOnStart) {
        .setDisableTypeRegistrationOnStart(disableTypeRegistrationOnStart);
    }
    @Override
    public boolean isDisableTypeRegistrationOnStart() {
    }
    @Override
    public void stop(Runnable callback) {
        stop();
        callback.run();
    }
    @Override
    public String toString() {
        return this.getClass().getSimpleName() + "[genericWorker=" +  + ", factory=" +  + "]";
    }
New to GrepCode? Check out our FAQ X