erwink

import com.google.common.util.concurrent.Monitor;

import java.util.concurrent.atomic.AtomicInteger;

/**
 * Created by IntelliJ IDEA.
 * User: bbejeck
 * Date: 11/11/11
 * Time: 10:01 PM
 */

erwink

// ©2012 Viktor Klang

package akka.klang

import akka.dispatch.{ DispatcherPrerequisites, ExecutorServiceFactory, ExecutorServiceConfigurator }
import com.typesafe.config.Config
import java.util.concurrent.{ ExecutorService, AbstractExecutorService, ThreadFactory, TimeUnit }
import java.util.Collections
import javax.swing.SwingUtilities

erwink

package net.arjones.sandbox;

import net.lag.configgy.Config;
import net.lag.kestrel.PersistentQueue;

public class KestrelTest {

	public static void main(String[] args) throws InterruptedException {
		Config config = new Config();