ryantenney

@Bean
@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
public ZooKeeperAnnotationBeanPostProcessor zooKeeperAnnotationBeanPostProcessor() {
  ZooKeeperAnnotationBeanPostProcessor proc = new ZooKeeperAnnotationBeanPostProcessor();
  proc.setCuratorFramework(curatorFramework());
  return proc;
}

@Bean
@Role(BeanDefinition.ROLE_INFRASTRUCTURE)

ryantenney

jar=$1
propertiesFile=`tar -tvf $jar | grep pom.properties | awk ' { print $9 } '`
properties=`tar -xf $jar -O $propertiesFile`

groupId=`echo "$properties" | grep groupId | awk -F'=' ' { print $2 }'`
artifactId=`echo "$properties" | grep artifactId | awk -F'=' ' { print $2 }'`

jar=$artifactId.jar

mvn org.apache.maven.plugins:maven-dependency-plugin:2.8:get \

ryantenney

package com.enernoc.cost.common.util.concurrent;

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.Callable;
import java.util.concurrent.Executors;
import java.util.concurrent.FutureTask;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.RejectedExecutionHandler;
import java.util.concurrent.RunnableFuture;
import java.util.concurrent.Semaphore;

ryantenney

package com.enernoc.cost.common.util.concurrent;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.AbstractQueue;
import java.util.Collection;
import java.util.HashSet;
import java.util.Iterator;
import java.util.LinkedList;