Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * Copyright 2012-2015 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;
 
 
 
 public class WorkflowWorker implements WorkerBase {
 
     private final GenericWorkflowWorker genericWorker;
 
 
     private final Collection<Class<?>> workflowImplementationTypes = new ArrayList<Class<?>>();
 
     public WorkflowWorker(AmazonSimpleWorkflow serviceString domainString taskListToPoll) {
          = new GenericWorkflowWorker(servicedomaintaskListToPoll);
     }
 
     @Override
     public AmazonSimpleWorkflow getService() {
         return .getService();
     }
 
     @Override
     public String getDomain() {
         return .getDomain();
     }
 
     @Override
     public boolean isRegisterDomain() {
         return .isRegisterDomain();
     }
 
     @Override
     public void setRegisterDomain(boolean registerDomain) {
         .setRegisterDomain(registerDomain);
     }
 
     @Override
     public long getDomainRetentionPeriodInDays() {
         return .getDomainRetentionPeriodInDays();
     }
 
     @Override
     public void setDomainRetentionPeriodInDays(long domainRetentionPeriodInDays) {
         .setDomainRetentionPeriodInDays(domainRetentionPeriodInDays);
     }
 
     @Override
     public String getTaskListToPoll() {
         return .getTaskListToPoll();
     }
 
     @Override
     public double getMaximumPollRatePerSecond() {
         return .getMaximumPollRatePerSecond();
     }
 
     @Override
     public void setMaximumPollRatePerSecond(double maximumPollRatePerSecond) {
         .setMaximumPollRatePerSecond(maximumPollRatePerSecond);
     }
 
     @Override
     public int getMaximumPollRateIntervalMilliseconds() {
     }
 
     @Override
     public void setMaximumPollRateIntervalMilliseconds(int maximumPollRateIntervalMilliseconds) {
         .setMaximumPollRateIntervalMilliseconds(maximumPollRateIntervalMilliseconds);
     }
 
     @Override
         return .getUncaughtExceptionHandler();
     }
 
     @Override
    public void setUncaughtExceptionHandler(UncaughtExceptionHandler uncaughtExceptionHandler) {
        .setUncaughtExceptionHandler(uncaughtExceptionHandler);
    }
    @Override
    public String getIdentity() {
        return .getIdentity();
    }
    @Override
    public void setIdentity(String identity) {
        .setIdentity(identity);
    }
    @Override
    public long getPollBackoffInitialInterval() {
    }
    @Override
    public void setPollBackoffInitialInterval(long backoffInitialInterval) {
        .setPollBackoffInitialInterval(backoffInitialInterval);
    }
    @Override
    public long getPollBackoffMaximumInterval() {
    }
    @Override
    public void setPollBackoffMaximumInterval(long backoffMaximumInterval) {
        .setPollBackoffMaximumInterval(backoffMaximumInterval);
    }
    @Override
    public boolean isDisableServiceShutdownOnStop() {
    }
    @Override
    public void setDisableServiceShutdownOnStop(boolean disableServiceShutdownOnStop) {
        .setDisableServiceShutdownOnStop(disableServiceShutdownOnStop);
    }
    @Override
    public double getPollBackoffCoefficient() {
        return .getPollBackoffCoefficient();
    }
    @Override
    public void setPollBackoffCoefficient(double backoffCoefficient) {
        .setPollBackoffCoefficient(backoffCoefficient);
    }
    @Override
    public int getPollThreadCount() {
        return .getPollThreadCount();
    }
    @Override
    public void setPollThreadCount(int threadCount) {
        .setPollThreadCount(threadCount);
    }
    @Override
    public void registerTypesToPoll() {
    }
    @Override
    public void start() {
        .start();
    }
    @Override
    public void shutdown() {
        .shutdown();
    }
    @Override
    public void shutdownNow() {
        .shutdownNow();
    }
    @Override
    public boolean awaitTermination(long timeoutTimeUnit unitthrows InterruptedException {
        return .awaitTermination(timeoutunit);
    }
    @Override
    public boolean isRunning() {
        return .isRunning();
    }
    @Override
    public void suspendPolling() {
        .suspendPolling();
    }
    @Override
    public void resumePolling() {
        .resumePolling();
    }
    public void setWorkflowImplementationTypes(Collection<Class<?>> workflowImplementationTypes)
            throws InstantiationExceptionIllegalAccessException {
        for (Class<?> workflowImplementationType : workflowImplementationTypes) {
            addWorkflowImplementationType(workflowImplementationType);
        }
    }
        return ;
    }
    public void addWorkflowImplementationType(Class<?> workflowImplementationTypethrows InstantiationExceptionIllegalAccessException {
        .addWorkflowImplementationType(workflowImplementationType);
    }
    public void addWorkflowImplementationType(Class<?> workflowImplementationTypeDataConverter converterthrows InstantiationExceptionIllegalAccessException {
        .addWorkflowImplementationType(workflowImplementationTypeconverter);
    }
    
    @Override
    public String toString() {
        return this.getClass().getSimpleName() + "[genericWorker=" +  + ", wokflowImplementationTypes="
                +  + "]";
    }
    @Override
    public boolean shutdownAndAwaitTermination(long timeoutTimeUnit unitthrows InterruptedException {
        return .shutdownAndAwaitTermination(timeoutunit);
    }
    public DataConverter getDataConverter() {
        return .getDataConverter();
    }
    public void setDefaultConverter(DataConverter converter) {
        .setDataConverter(converter);
    }
    @Override
    public void setDisableTypeRegistrationOnStart(boolean disableTypeRegistrationOnStart) {
        .setDisableTypeRegistrationOnStart(disableTypeRegistrationOnStart);
    }
    @Override
    public boolean isDisableTypeRegistrationOnStart() {
    }
New to GrepCode? Check out our FAQ X