Commit cc4b5d1

@@ -1,11 +1,11 @@
-using System.Runtime.Serialization.Formatters.Binary;
-
-namespace gorilla.infrastructure.cloning
-{
-    public class BinarySerializer<T> : FileStreamSerializer<T>
-    {
-        public BinarySerializer(string file_path) : base(file_path, new BinaryFormatter())
-        {
-        }
-    }
-}
\ No newline at end of file
+using System.Runtime.Serialization.Formatters.Binary;
+
+namespace jive.infrastructure.cloning
+{
+  public class BinarySerializer<T> : FileStreamSerializer<T>
+  {
+    public BinarySerializer(string file_path) : base(file_path, new BinaryFormatter())
+    {
+    }
+  }
+}

@@ -1,34 +1,34 @@
-using System.IO;
-using System.Runtime.Serialization;
-
-namespace gorilla.infrastructure.cloning
-{
-    public class FileStreamSerializer<T> : Serializer<T>
-    {
-        public FileStreamSerializer(string file_path, IFormatter formatter)
-        {
-            this.file_path = file_path;
-            this.formatter = formatter;
-        }
-
-        public void serialize(T to_serialize)
-        {
-            using (var stream = new FileStream(file_path, FileMode.Create, FileAccess.Write))
-                formatter.Serialize(stream, to_serialize);
-        }
-
-        public T deserialize()
-        {
-            using (var stream = new FileStream(file_path, FileMode.Open, FileAccess.Read))
-                return (T) formatter.Deserialize(stream);
-        }
-
-        public void Dispose()
-        {
-            File.Delete(file_path);
-        }
-
-        readonly string file_path;
-        readonly IFormatter formatter;
-    }
-}
\ No newline at end of file
+using System.IO;
+using System.Runtime.Serialization;
+
+namespace jive.infrastructure.cloning
+{
+  public class FileStreamSerializer<T> : Serializer<T>
+  {
+    public FileStreamSerializer(string file_path, IFormatter formatter)
+    {
+      this.file_path = file_path;
+      this.formatter = formatter;
+    }
+
+    public void serialize(T to_serialize)
+    {
+      using (var stream = new FileStream(file_path, FileMode.Create, FileAccess.Write))
+        formatter.Serialize(stream, to_serialize);
+    }
+
+    public T deserialize()
+    {
+      using (var stream = new FileStream(file_path, FileMode.Open, FileAccess.Read))
+        return (T) formatter.Deserialize(stream);
+    }
+
+    public void Dispose()
+    {
+      File.Delete(file_path);
+    }
+
+    readonly string file_path;
+    readonly IFormatter formatter;
+  }
+}

@@ -1,21 +1,21 @@
-using System.IO;
-
-namespace gorilla.infrastructure.cloning
-{
-    public interface IPrototype
-    {
-        T clone<T>(T item);
-    }
-
-    public class Prototype : IPrototype
-    {
-        public T clone<T>(T item)
-        {
-            using (var serializer = new BinarySerializer<T>(Path.GetTempFileName()))
-            {
-                serializer.serialize(item);
-                return serializer.deserialize();
-            }
-        }
-    }
-}
\ No newline at end of file
+using System.IO;
+
+namespace jive.infrastructure.cloning
+{
+  public interface IPrototype
+  {
+    T clone<T>(T item);
+  }
+
+  public class Prototype : IPrototype
+  {
+    public T clone<T>(T item)
+    {
+      using (var serializer = new BinarySerializer<T>(Path.GetTempFileName()))
+      {
+        serializer.serialize(item);
+        return serializer.deserialize();
+      }
+    }
+  }
+}

@@ -1,10 +1,10 @@
-using System;
-
-namespace gorilla.infrastructure.cloning
-{
-    public interface Serializer<T> : IDisposable
-    {
-        void serialize(T to_serialize);
-        T deserialize();
-    }
-}
\ No newline at end of file
+using System;
+
+namespace jive.infrastructure.cloning
+{
+  public interface Serializer<T> : IDisposable
+  {
+    void serialize(T to_serialize);
+    T deserialize();
+  }
+}

@@ -1,10 +1,10 @@
-using System.Collections.Generic;
-
-namespace gorilla.infrastructure.container
-{
-    public interface DependencyRegistry
-    {
-        Contract get_a<Contract>();
-        IEnumerable<Contract> get_all<Contract>();
-    }
-}
\ No newline at end of file
+using System.Collections.Generic;
+
+namespace jive.infrastructure.container
+{
+  public interface DependencyRegistry
+  {
+    Contract get_a<Contract>();
+    IEnumerable<Contract> get_all<Contract>();
+  }
+}

@@ -1,13 +1,13 @@
-using System;
-using gorilla.utility;
-
-namespace gorilla.infrastructure.container
-{
-    public class DependencyResolutionException<T> : Exception
-    {
-        public DependencyResolutionException(Exception inner_exception)
-            : base("Could not resolve {0}".format(typeof (T).FullName), inner_exception)
-        {
-        }
-    }
-}
\ No newline at end of file
+using System;
+using jive.utility;
+
+namespace jive.infrastructure.container
+{
+  public class DependencyResolutionException<T> : Exception
+  {
+    public DependencyResolutionException(Exception inner_exception)
+      : base("Could not resolve {0}".format(typeof (T).FullName), inner_exception)
+    {
+    }
+  }
+}

@@ -1,33 +1,33 @@
-using System;
-
-namespace gorilla.infrastructure.container
-{
-    static public class Resolve
-    {
-        static DependencyRegistry underlying_registry;
-        static bool initialized;
-
-        static public void initialize_with(DependencyRegistry registry)
-        {
-            underlying_registry = registry;
-            initialized = registry != null;
-        }
-
-        static public DependencyToResolve the<DependencyToResolve>()
-        {
-            try
-            {
-                return underlying_registry.get_a<DependencyToResolve>();
-            }
-            catch (Exception e)
-            {
-                throw new DependencyResolutionException<DependencyToResolve>(e);
-            }
-        }
-
-        static public bool is_initialized()
-        {
-            return initialized;
-        }
-    }
-}
\ No newline at end of file
+using System;
+
+namespace jive.infrastructure.container
+{
+  static public class Resolve
+  {
+    static DependencyRegistry underlying_registry;
+    static bool initialized;
+
+    static public void initialize_with(DependencyRegistry registry)
+    {
+      underlying_registry = registry;
+      initialized = registry != null;
+    }
+
+    static public DependencyToResolve the<DependencyToResolve>()
+    {
+      try
+      {
+        return underlying_registry.get_a<DependencyToResolve>();
+      }
+      catch (Exception e)
+      {
+        throw new DependencyResolutionException<DependencyToResolve>(e);
+      }
+    }
+
+    static public bool is_initialized()
+    {
+      return initialized;
+    }
+  }
+}

@@ -1,25 +1,25 @@
-using System;
-using gorilla.infrastructure.container;
-
-namespace gorilla.infrastructure.logging
-{
-    static public class Log
-    {
-        static public Logger For<T>(T item_to_create_logger_for)
-        {
-            return For(typeof (T));
-        }
-
-        static public Logger For(Type type_to_create_a_logger_for)
-        {
-            try
-            {
-                return Resolve.the<LogFactory>().create_for(type_to_create_a_logger_for);
-            }
-            catch
-            {
-                return new TextLogger(Console.Out);
-            }
-        }
-    }
-}
\ No newline at end of file
+using System;
+using jive.infrastructure.container;
+
+namespace jive.infrastructure.logging
+{
+  static public class Log
+  {
+    static public Logger For<T>(T item_to_create_logger_for)
+    {
+      return For(typeof (T));
+    }
+
+    static public Logger For(Type type_to_create_a_logger_for)
+    {
+      try
+      {
+        return Resolve.the<LogFactory>().create_for(type_to_create_a_logger_for);
+      }
+      catch
+      {
+        return new TextLogger(Console.Out);
+      }
+    }
+  }
+}

@@ -1,9 +1,9 @@
-using System;
-
-namespace gorilla.infrastructure.logging
-{
-    public interface LogFactory
-    {
-        Logger create_for(Type type_to_create_logger_for);
-    }
-}
\ No newline at end of file
+using System;
+
+namespace jive.infrastructure.logging
+{
+  public interface LogFactory
+  {
+    Logger create_for(Type type_to_create_logger_for);
+  }
+}

@@ -1,7 +1,6 @@
-namespace gorilla.infrastructure.logging
-{
-    public interface Loggable
-    {
-        
-    }
-}
\ No newline at end of file
+namespace jive.infrastructure.logging
+{
+  public interface Loggable
+  {
+  }
+}

@@ -1,11 +1,11 @@
-using System;
-
-namespace gorilla.infrastructure.logging
-{
-    public interface Logger
-    {
-        void informational(string formatted_string, params object[] arguments);
-        void debug(string formatted_string, params object[] arguments);
-        void error(Exception e);
-    }
-}
\ No newline at end of file
+using System;
+
+namespace jive.infrastructure.logging
+{
+  public interface Logger
+  {
+    void informational(string formatted_string, params object[] arguments);
+    void debug(string formatted_string, params object[] arguments);
+    void error(Exception e);
+  }
+}

@@ -1,17 +1,17 @@
-using System;
-
-namespace gorilla.infrastructure.logging
-{
-    public static class LoggingExtensions
-    {
-        public static Logger log<T>(this T item_to_log)
-        {
-            return Log.For(item_to_log);
-        }
-
-        public static void add_to_log(this Exception error_to_log)
-        {
-            Log.For(error_to_log).error(error_to_log);
-        }
-    }
-}
\ No newline at end of file
+using System;
+
+namespace jive.infrastructure.logging
+{
+  public static class LoggingExtensions
+  {
+    public static Logger log<T>(this T item_to_log)
+    {
+      return Log.For(item_to_log);
+    }
+
+    public static void add_to_log(this Exception error_to_log)
+    {
+      Log.For(error_to_log).error(error_to_log);
+    }
+  }
+}

@@ -1,33 +1,33 @@
-using System;
-using System.IO;
-using System.Threading;
-using gorilla.utility;
-
-namespace gorilla.infrastructure.logging
-{
-    public class TextLogger : Logger
-    {
-        readonly TextWriter writer;
-
-        public TextLogger(TextWriter writer)
-        {
-            this.writer = writer;
-        }
-
-        public void informational(string formatted_string, params object[] arguments)
-        {
-            writer.WriteLine(formatted_string, arguments);
-        }
-
-        public void debug(string formatted_string, params object[] arguments)
-        {
-            writer.WriteLine("[{0}] - {1}", Thread.CurrentThread.ManagedThreadId,
-                             formatted_string.format(arguments));
-        }
-
-        public void error(Exception e)
-        {
-            writer.WriteLine("{0}", e);
-        }
-    }
-}
\ No newline at end of file
+using System;
+using System.IO;
+using System.Threading;
+using jive.utility;
+
+namespace jive.infrastructure.logging
+{
+  public class TextLogger : Logger
+  {
+    readonly TextWriter writer;
+
+    public TextLogger(TextWriter writer)
+    {
+      this.writer = writer;
+    }
+
+    public void informational(string formatted_string, params object[] arguments)
+    {
+      writer.WriteLine(formatted_string, arguments);
+    }
+
+    public void debug(string formatted_string, params object[] arguments)
+    {
+      writer.WriteLine("[{0}] - {1}", Thread.CurrentThread.ManagedThreadId,
+          formatted_string.format(arguments));
+    }
+
+    public void error(Exception e)
+    {
+      writer.WriteLine("{0}", e);
+    }
+  }
+}

@@ -1,18 +1,18 @@
-using System;
-using System.Reflection;
-
-namespace gorilla.infrastructure.proxies
-{
-    static public class ExceptionExtensions
-    {
-        static readonly MethodInfo method =
-            typeof (Exception).GetMethod("InternalPreserveStackTrace",
-                                         BindingFlags.NonPublic | BindingFlags.Instance);
-
-        static public Exception preserve_stack_trace(this Exception exception)
-        {
-            method.Invoke(exception, new object[0]);
-            return exception;
-        }
-    }
-}
\ No newline at end of file
+using System;
+using System.Reflection;
+
+namespace jive.infrastructure.proxies
+{
+  static public class ExceptionExtensions
+  {
+    static readonly MethodInfo method =
+      typeof (Exception).GetMethod("InternalPreserveStackTrace",
+          BindingFlags.NonPublic | BindingFlags.Instance);
+
+    static public Exception preserve_stack_trace(this Exception exception)
+    {
+      method.Invoke(exception, new object[0]);
+      return exception;
+    }
+  }
+}

@@ -1,7 +1,7 @@
-namespace gorilla.infrastructure.proxies
-{
-    public interface Interceptor
-    {
-        void intercept(Invocation invocation);
-    }
-}
\ No newline at end of file
+namespace jive.infrastructure.proxies
+{
+  public interface Interceptor
+  {
+    void intercept(Invocation invocation);
+  }
+}

@@ -1,12 +1,12 @@
-using System.Reflection;
-
-namespace gorilla.infrastructure.proxies
-{
-    public interface Invocation
-    {
-        void proceed();
-        object[] arguments { get; }
-        MethodInfo method { get; }
-        object return_value { get; set; }
-    }
-}
\ No newline at end of file
+using System.Reflection;
+
+namespace jive.infrastructure.proxies
+{
+  public interface Invocation
+  {
+    void proceed();
+    object[] arguments { get; }
+    MethodInfo method { get; }
+    object return_value { get; set; }
+  }
+}

@@ -1,47 +1,47 @@
-//using System.Collections.Generic;
-//using System.Reflection;
-//using System.Runtime.Remoting.Messaging;
-//using gorilla.utility;
-
-//namespace gorilla.infrastructure.proxies
-//{
-    //public class MethodCallInvocation<T> : Invocation
-    //{
-        //readonly IMethodCallMessage call;
-        //readonly T target;
-        //readonly Stack<Interceptor> interceptors;
-
-        //public MethodCallInvocation(IEnumerable<Interceptor> interceptors, IMethodCallMessage call, T target)
-        //{
-            //this.call = call;
-            //this.target = target;
-            //this.interceptors = new Stack<Interceptor>(interceptors);
-            //arguments = call.Properties["__Args"].downcast_to<object[]>();
-            //method = call.MethodBase.downcast_to<MethodInfo>();
-        //}
-
-        //public object[] arguments { get; set; }
-
-        //public MethodInfo method { get; set; }
-
-        //public object return_value { get; set; }
-
-        //public void proceed()
-        //{
-            //if (interceptors.Count > 0)
-            //{
-                //interceptors.Pop().intercept(this);
-                //return;
-            //}
-
-            //try
-            //{
-                //return_value = call.MethodBase.Invoke(target, arguments);
-            //}
-            //catch (TargetInvocationException e)
-            //{
-                //throw e.InnerException.preserve_stack_trace();
-            //}
-        //}
-    //}
-//}
+//using System.Collections.Generic;
+//using System.Reflection;
+//using System.Runtime.Remoting.Messaging;
+//using jive.utility;
+
+//namespace jive.infrastructure.proxies
+//{
+    //public class MethodCallInvocation<T> : Invocation
+    //{
+        //readonly IMethodCallMessage call;
+        //readonly T target;
+        //readonly Stack<Interceptor> interceptors;
+
+        //public MethodCallInvocation(IEnumerable<Interceptor> interceptors, IMethodCallMessage call, T target)
+        //{
+            //this.call = call;
+            //this.target = target;
+            //this.interceptors = new Stack<Interceptor>(interceptors);
+            //arguments = call.Properties["__Args"].downcast_to<object[]>();
+            //method = call.MethodBase.downcast_to<MethodInfo>();
+        //}
+
+        //public object[] arguments { get; set; }
+
+        //public MethodInfo method { get; set; }
+
+        //public object return_value { get; set; }
+
+        //public void proceed()
+        //{
+            //if (interceptors.Count > 0)
+            //{
+                //interceptors.Pop().intercept(this);
+                //return;
+            //}
+
+            //try
+            //{
+                //return_value = call.MethodBase.Invoke(target, arguments);
+            //}
+            //catch (TargetInvocationException e)
+            //{
+                //throw e.InnerException.preserve_stack_trace();
+            //}
+        //}
+    //}
+//}

@@ -1,10 +1,10 @@
-//namespace gorilla.infrastructure.proxies
-//{
-    //static public class ProxyFactory
-    //{
-        //static public T create<T>(T target, params Interceptor[] interceptors)
-        //{
-            //return new RemotingProxyFactory<T>(target, interceptors).create_proxy();
-        //}
-    //}
-//}
+//namespace jive.infrastructure.proxies
+//{
+    //static public class ProxyFactory
+    //{
+        //static public T create<T>(T target, params Interceptor[] interceptors)
+        //{
+            //return new RemotingProxyFactory<T>(target, interceptors).create_proxy();
+        //}
+    //}
+//}

@@ -1,44 +1,44 @@
-//using System.Collections.Generic;
-//using System.Runtime.Remoting.Messaging;
-//using System.Runtime.Remoting.Proxies;
-//using gorilla.utility;
-
-//namespace gorilla.infrastructure.proxies
-//{
-    //public class RemotingProxyFactory<T> : RealProxy
-    //{
-        //readonly T target;
-        //readonly IEnumerable<Interceptor> interceptors;
-
-        //public RemotingProxyFactory(T target, IEnumerable<Interceptor> interceptors) : base(typeof (T))
-        //{
-            //this.target = target;
-            //this.interceptors = interceptors;
-        //}
-
-        //public override IMessage Invoke(IMessage message)
-        //{
-            //if (message.is_an_implementation_of<IMethodCallMessage>())
-            //{
-                //var call = message.downcast_to<IMethodCallMessage>();
-                //var invocation = new MethodCallInvocation<T>(interceptors, call, target);
-                //invocation.proceed();
-                //return return_value(invocation.return_value, invocation.arguments, call);
-            //}
-            //return null;
-        //}
-
-        //IMessage return_value(object return_value, object[] out_parameters, IMethodCallMessage call)
-        //{
-            //return new ReturnMessage(return_value,
-                                     //out_parameters,
-                                     //out_parameters == null ? 0 : out_parameters.Length,
-                                     //call.LogicalCallContext, call);
-        //}
-
-        //public T create_proxy()
-        //{
-            //return GetTransparentProxy().downcast_to<T>();
-        //}
-    //}
-//}
+//using System.Collections.Generic;
+//using System.Runtime.Remoting.Messaging;
+//using System.Runtime.Remoting.Proxies;
+//using jive.utility;
+
+//namespace jive.infrastructure.proxies
+//{
+    //public class RemotingProxyFactory<T> : RealProxy
+    //{
+        //readonly T target;
+        //readonly IEnumerable<Interceptor> interceptors;
+
+        //public RemotingProxyFactory(T target, IEnumerable<Interceptor> interceptors) : base(typeof (T))
+        //{
+            //this.target = target;
+            //this.interceptors = interceptors;
+        //}
+
+        //public override IMessage Invoke(IMessage message)
+        //{
+            //if (message.is_an_implementation_of<IMethodCallMessage>())
+            //{
+                //var call = message.downcast_to<IMethodCallMessage>();
+                //var invocation = new MethodCallInvocation<T>(interceptors, call, target);
+                //invocation.proceed();
+                //return return_value(invocation.return_value, invocation.arguments, call);
+            //}
+            //return null;
+        //}
+
+        //IMessage return_value(object return_value, object[] out_parameters, IMethodCallMessage call)
+        //{
+            //return new ReturnMessage(return_value,
+                                     //out_parameters,
+                                     //out_parameters == null ? 0 : out_parameters.Length,
+                                     //call.LogicalCallContext, call);
+        //}
+
+        //public T create_proxy()
+        //{
+            //return GetTransparentProxy().downcast_to<T>();
+        //}
+    //}
+//}

@@ -1,20 +1,20 @@
-using System;
-using System.Collections.Generic;
-
-namespace gorilla.infrastructure.reflection
-{
-    public class ApplicationAssembly : Assembly
-    {
-        readonly System.Reflection.Assembly assembly;
-
-        public ApplicationAssembly(System.Reflection.Assembly assembly)
-        {
-            this.assembly = assembly;
-        }
-
-        public IEnumerable<Type> all_types()
-        {
-            return assembly.GetTypes();
-        }
-    }
-}
\ No newline at end of file
+using System;
+using System.Collections.Generic;
+
+namespace jive.infrastructure.reflection
+{
+  public class ApplicationAssembly : Assembly
+  {
+    readonly System.Reflection.Assembly assembly;
+
+    public ApplicationAssembly(System.Reflection.Assembly assembly)
+    {
+      this.assembly = assembly;
+    }
+
+    public IEnumerable<Type> all_types()
+    {
+      return assembly.GetTypes();
+    }
+  }
+}

@@ -1,10 +1,10 @@
-using System;
-using System.Collections.Generic;
-
-namespace gorilla.infrastructure.reflection
-{
-    public interface Assembly
-    {
-        IEnumerable<Type> all_types();
-    }
-}
\ No newline at end of file
+using System;
+using System.Collections.Generic;
+
+namespace jive.infrastructure.reflection
+{
+  public interface Assembly
+  {
+    IEnumerable<Type> all_types();
+  }
+}

@@ -1,12 +1,12 @@
-using System;
-
-namespace gorilla.infrastructure.reflection
-{
-    public static class EnvironmentExtensions
-    {
-        public static string startup_directory<T>(this T item)
-        {
-            return AppDomain.CurrentDomain.BaseDirectory;
-        }
-    }
-}
\ No newline at end of file
+using System;
+
+namespace jive.infrastructure.reflection
+{
+  public static class EnvironmentExtensions
+  {
+    public static string startup_directory<T>(this T item)
+    {
+      return AppDomain.CurrentDomain.BaseDirectory;
+    }
+  }
+}

@@ -1,32 +1,32 @@
-using System.Collections;
-using System.Collections.Generic;
-using gorilla.infrastructure.container;
-using gorilla.utility;
-
-namespace gorilla.infrastructure.registries
-{
-    public class DefaultRegistry<T> : Registry<T>
-    {
-        readonly DependencyRegistry registry;
-
-        public DefaultRegistry(DependencyRegistry registry)
-        {
-            this.registry = registry;
-        }
-
-        public IEnumerable<T> all()
-        {
-            return registry.get_all<T>();
-        }
-
-        public IEnumerator<T> GetEnumerator()
-        {
-            return all().GetEnumerator();
-        }
-
-        IEnumerator IEnumerable.GetEnumerator()
-        {
-            return GetEnumerator();
-        }
-    }
-}
\ No newline at end of file
+using System.Collections;
+using System.Collections.Generic;
+using jive.infrastructure.container;
+using jive.utility;
+
+namespace jive.infrastructure.registries
+{
+  public class DefaultRegistry<T> : Registry<T>
+  {
+    readonly DependencyRegistry registry;
+
+    public DefaultRegistry(DependencyRegistry registry)
+    {
+      this.registry = registry;
+    }
+
+    public IEnumerable<T> all()
+    {
+      return registry.get_all<T>();
+    }
+
+    public IEnumerator<T> GetEnumerator()
+    {
+      return all().GetEnumerator();
+    }
+
+    IEnumerator IEnumerable.GetEnumerator()
+    {
+      return GetEnumerator();
+    }
+  }
+}

@@ -1,7 +1,7 @@
-namespace gorilla.infrastructure.threading
-{
-    public interface ApplicationThread
-    {
-        T provide_slot_for<T>() where T : class, new();
-    }
-}
\ No newline at end of file
+namespace jive.infrastructure.threading
+{
+  public interface ApplicationThread
+  {
+    T provide_slot_for<T>() where T : class, new();
+  }
+}

@@ -1,113 +1,113 @@
-using System;
-using System.Collections.Generic;
-using System.Threading;
-using gorilla.infrastructure.logging;
-using gorilla.utility;
-
-namespace gorilla.infrastructure.threading
-{
-    public class AsynchronousCommandProcessor : CommandProcessor
-    {
-        readonly Queue<Command> queued_commands;
-        readonly EventWaitHandle manual_reset;
-        readonly IList<Thread> worker_threads;
-        bool keep_working;
-
-        static public readonly Command Empty = new EmptyCommand();
-
-        public AsynchronousCommandProcessor()
-        {
-            queued_commands = new Queue<Command>();
-            worker_threads = new List<Thread>();
-            manual_reset = new ManualResetEvent(false);
-        }
-
-        public void add(Action command)
-        {
-            add(new AnonymousCommand(command));
-        }
-
-        public void add(Command command_to_process)
-        {
-            lock (queued_commands)
-            {
-                if (queued_commands.Contains(command_to_process)) return;
-                queued_commands.Enqueue(command_to_process);
-                reset_thread();
-            }
-        }
-
-        public void run()
-        {
-            reset_thread();
-            keep_working = true;
-            var worker_thread = new Thread(run_commands);
-            worker_thread.SetApartmentState(ApartmentState.STA);
-            worker_threads.Add(worker_thread);
-            worker_thread.Start();
-        }
-
-        public void stop()
-        {
-            keep_working = false;
-            manual_reset.Set();
-            //manual_reset.Close();
-        }
-
-        [STAThread]
-        void run_commands()
-        {
-            while (keep_working)
-            {
-                manual_reset.WaitOne();
-                run_next_command();
-            }
-        }
-
-        void run_next_command()
-        {
-            var command = Empty;
-            within_lock(() =>
-                        {
-                            if (queued_commands.Count == 0)
-                                manual_reset.Reset();
-                            else
-                                command = queued_commands.Dequeue();
-                        });
-            safely_invoke(() =>
-                          {
-                              command.run();
-                          });
-            reset_thread();
-        }
-
-        void safely_invoke(Action action)
-        {
-            try
-            {
-                action();
-            }
-            catch (Exception e)
-            {
-                this.log().error(e);
-            }
-        }
-
-        void reset_thread()
-        {
-            within_lock(() =>
-                        {
-                            if (queued_commands.Count > 0) manual_reset.Set();
-                            else manual_reset.Reset();
-                        });
-        }
-
-        void within_lock(Action action)
-        {
-            lock (queued_commands)
-            {
-                action();
-            }
-        }
-    }
-}
\ No newline at end of file
+using System;
+using System.Collections.Generic;
+using System.Threading;
+using jive.infrastructure.logging;
+using jive.utility;
+
+namespace jive.infrastructure.threading
+{
+  public class AsynchronousCommandProcessor : CommandProcessor
+  {
+    readonly Queue<Command> queued_commands;
+    readonly EventWaitHandle manual_reset;
+    readonly IList<Thread> worker_threads;
+    bool keep_working;
+
+    static public readonly Command Empty = new EmptyCommand();
+
+    public AsynchronousCommandProcessor()
+    {
+      queued_commands = new Queue<Command>();
+      worker_threads = new List<Thread>();
+      manual_reset = new ManualResetEvent(false);
+    }
+
+    public void add(Action command)
+    {
+      add(new AnonymousCommand(command));
+    }
+
+    public void add(Command command_to_process)
+    {
+      lock (queued_commands)
+      {
+        if (queued_commands.Contains(command_to_process)) return;
+        queued_commands.Enqueue(command_to_process);
+        reset_thread();
+      }
+    }
+
+    public void run()
+    {
+      reset_thread();
+      keep_working = true;
+      var worker_thread = new Thread(run_commands);
+      worker_thread.SetApartmentState(ApartmentState.STA);
+      worker_threads.Add(worker_thread);
+      worker_thread.Start();
+    }
+
+    public void stop()
+    {
+      keep_working = false;
+      manual_reset.Set();
+      //manual_reset.Close();
+    }
+
+    [STAThread]
+    void run_commands()
+    {
+      while (keep_working)
+      {
+        manual_reset.WaitOne();
+        run_next_command();
+      }
+    }
+
+    void run_next_command()
+    {
+      var command = Empty;
+      within_lock(() =>
+          {
+          if (queued_commands.Count == 0)
+          manual_reset.Reset();
+          else
+          command = queued_commands.Dequeue();
+          });
+      safely_invoke(() =>
+          {
+          command.run();
+          });
+      reset_thread();
+    }
+
+    void safely_invoke(Action action)
+    {
+      try
+      {
+        action();
+      }
+      catch (Exception e)
+      {
+        this.log().error(e);
+      }
+    }
+
+    void reset_thread()
+    {
+      within_lock(() =>
+          {
+          if (queued_commands.Count > 0) manual_reset.Set();
+          else manual_reset.Reset();
+          });
+    }
+
+    void within_lock(Action action)
+    {
+      lock (queued_commands)
+      {
+        action();
+      }
+    }
+  }
+}

@@ -1,6 +1,6 @@
-using gorilla.utility;
-
-namespace gorilla.infrastructure.threading
-{
-    public interface BackgroundThread : DisposableCommand {}
-}
\ No newline at end of file
+using jive.utility;
+
+namespace jive.infrastructure.threading
+{
+  public interface BackgroundThread : DisposableCommand {}
+}

@@ -1,49 +1,49 @@
-using System;
-using gorilla.infrastructure.container;
-using gorilla.utility;
-
-namespace gorilla.infrastructure.threading
-{
-    public interface IBackgroundThreadFactory
-    {
-        BackgroundThread create_for<CommandToExecute>() where CommandToExecute : DisposableCommand;
-        BackgroundThread create_for(Action action);
-    }
-
-    public class BackgroundThreadFactory : IBackgroundThreadFactory
-    {
-        readonly DependencyRegistry registry;
-
-        public BackgroundThreadFactory(DependencyRegistry registry)
-        {
-            this.registry = registry;
-        }
-
-        public BackgroundThread create_for<CommandToExecute>() where CommandToExecute : DisposableCommand
-        {
-            return new WorkderBackgroundThread(registry.get_a<CommandToExecute>());
-        }
-
-        public BackgroundThread create_for(Action action)
-        {
-            return new WorkderBackgroundThread(new AnonymousDisposableCommand(action));
-        }
-
-        class AnonymousDisposableCommand : DisposableCommand
-        {
-            readonly Action action;
-
-            public AnonymousDisposableCommand(Action action)
-            {
-                this.action = action;
-            }
-
-            public void run()
-            {
-                action();
-            }
-
-            public void Dispose() {}
-        }
-    }
-}
\ No newline at end of file
+using System;
+using jive.infrastructure.container;
+using jive.utility;
+
+namespace jive.infrastructure.threading
+{
+  public interface IBackgroundThreadFactory
+  {
+    BackgroundThread create_for<CommandToExecute>() where CommandToExecute : DisposableCommand;
+    BackgroundThread create_for(Action action);
+  }
+
+  public class BackgroundThreadFactory : IBackgroundThreadFactory
+  {
+    readonly DependencyRegistry registry;
+
+    public BackgroundThreadFactory(DependencyRegistry registry)
+    {
+      this.registry = registry;
+    }
+
+    public BackgroundThread create_for<CommandToExecute>() where CommandToExecute : DisposableCommand
+    {
+      return new WorkderBackgroundThread(registry.get_a<CommandToExecute>());
+    }
+
+    public BackgroundThread create_for(Action action)
+    {
+      return new WorkderBackgroundThread(new AnonymousDisposableCommand(action));
+    }
+
+    class AnonymousDisposableCommand : DisposableCommand
+    {
+      readonly Action action;
+
+      public AnonymousDisposableCommand(Action action)
+      {
+        this.action = action;
+      }
+
+      public void run()
+      {
+        action();
+      }
+
+      public void Dispose() {}
+    }
+  }
+}

@@ -1,12 +1,12 @@
-using System;
-using gorilla.utility;
-
-namespace gorilla.infrastructure.threading
+using System;
+using jive.utility;
+
+namespace jive.infrastructure.threading
 {
-    public interface CommandProcessor : Command
-    {
-        void add(Action command);
-        void add(Command command_to_process);
-        void stop();
-    }
-}
\ No newline at end of file
+  public interface CommandProcessor : Command
+  {
+    void add(Action command);
+    void add(Command command_to_process);
+    void stop();
+  }
+}

@@ -1,19 +1,19 @@
-using System.Threading;
-
-namespace gorilla.infrastructure.threading
+using System.Threading;
+
+namespace jive.infrastructure.threading
 {
-    public class CurrentThread : ApplicationThread
+  public class CurrentThread : ApplicationThread
+  {
+    public T provide_slot_for<T>() where T : class, new()
     {
-        public T provide_slot_for<T>() where T : class, new()
-        {
-            var slot = Thread.GetNamedDataSlot(create_key_for<T>());
-            if (null == Thread.GetData(slot)) Thread.SetData(slot, new T());
-            return (T) Thread.GetData(slot);
-        }
+      var slot = Thread.GetNamedDataSlot(create_key_for<T>());
+      if (null == Thread.GetData(slot)) Thread.SetData(slot, new T());
+      return (T) Thread.GetData(slot);
+    }
 
-        string create_key_for<T>()
-        {
-            return Thread.CurrentThread.ManagedThreadId + GetType().FullName + typeof (T).FullName;
-        }
+    string create_key_for<T>()
+    {
+      return Thread.CurrentThread.ManagedThreadId + GetType().FullName + typeof (T).FullName;
     }
-}
\ No newline at end of file
+  }
+}

@@ -1,48 +1,48 @@
-using System;
-using System.Collections.Generic;
-using gorilla.utility;
-
-namespace gorilla.infrastructure.threading
-{
-    public class IntervalTimer : Timer
-    {
-        readonly ITimerFactory factory;
-        readonly IDictionary<TimerClient, System.Timers.Timer> timers;
-
-        public IntervalTimer() : this(new TimerFactory())
-        {
-        }
-
-        public IntervalTimer(ITimerFactory factory)
-        {
-            this.factory = factory;
-            timers = new Dictionary<TimerClient, System.Timers.Timer>();
-        }
-
-        public void start_notifying(TimerClient client_to_be_notified, TimeSpan span)
-        {
-            stop_notifying(client_to_be_notified);
-
-            var timer = factory.create_for(span);
-            timer.Elapsed += (o, e) =>
-            {
-                client_to_be_notified.notify();
-            };
-            timer.Start();
-            timers[client_to_be_notified] = timer;
-        }
-
-        public void stop_notifying(TimerClient client_to_stop_notifying)
-        {
-            if (!timers.ContainsKey(client_to_stop_notifying)) return;
-            timers[client_to_stop_notifying].Stop();
-            timers[client_to_stop_notifying].Dispose();
-        }
-
-        public void Dispose()
-        {
-            timers.each(x => x.Value.Dispose());
-            timers.Clear();
-        }
-    }
-}
\ No newline at end of file
+using System;
+using System.Collections.Generic;
+using jive.utility;
+
+namespace jive.infrastructure.threading
+{
+  public class IntervalTimer : Timer
+  {
+    readonly ITimerFactory factory;
+    readonly IDictionary<TimerClient, System.Timers.Timer> timers;
+
+    public IntervalTimer() : this(new TimerFactory())
+    {
+    }
+
+    public IntervalTimer(ITimerFactory factory)
+    {
+      this.factory = factory;
+      timers = new Dictionary<TimerClient, System.Timers.Timer>();
+    }
+
+    public void start_notifying(TimerClient client_to_be_notified, TimeSpan span)
+    {
+      stop_notifying(client_to_be_notified);
+
+      var timer = factory.create_for(span);
+      timer.Elapsed += (o, e) =>
+      {
+        client_to_be_notified.notify();
+      };
+      timer.Start();
+      timers[client_to_be_notified] = timer;
+    }
+
+    public void stop_notifying(TimerClient client_to_stop_notifying)
+    {
+      if (!timers.ContainsKey(client_to_stop_notifying)) return;
+      timers[client_to_stop_notifying].Stop();
+      timers[client_to_stop_notifying].Dispose();
+    }
+
+    public void Dispose()
+    {
+      timers.each(x => x.Value.Dispose());
+      timers.Clear();
+    }
+  }
+}

@@ -1,9 +1,9 @@
-using System;
-
-namespace gorilla.infrastructure.threading
-{
-    public interface ITimerFactory
-    {
-        System.Timers.Timer create_for(TimeSpan span);
-    }
-}
\ No newline at end of file
+using System;
+
+namespace jive.infrastructure.threading
+{
+  public interface ITimerFactory
+  {
+    System.Timers.Timer create_for(TimeSpan span);
+  }
+}

@@ -1,12 +1,12 @@
-using System;
-using System.ComponentModel;
-
-namespace gorilla.infrastructure.threading
+using System;
+using System.ComponentModel;
+
+namespace jive.infrastructure.threading
 {
-    public interface IWorkerThread : IDisposable
-    {
-        event DoWorkEventHandler DoWork;
-        event EventHandler Disposed;
-        void begin();
-    }
-}
\ No newline at end of file
+  public interface IWorkerThread : IDisposable
+  {
+    event DoWorkEventHandler DoWork;
+    event EventHandler Disposed;
+    void begin();
+  }
+}

@@ -1,59 +1,59 @@
-using System;
-using System.Collections;
-using System.Collections.Generic;
-using System.Threading;
-using gorilla.utility;
-
-namespace gorilla.infrastructure.threading
-{
-    public class PerThread : Context
-    {
-        readonly IDictionary<int, LocalDataStoreSlot> slots;
-        readonly object mutex = new object();
-
-        public PerThread()
-        {
-            slots = new Dictionary<int, LocalDataStoreSlot>();
-        }
-
-        public bool contains<T>(Key<T> key)
-        {
-            return key.is_found_in(get_items());
-        }
-
-        public void add<T>(Key<T> key, T value)
-        {
-            key.add_value_to(get_items(), value);
-        }
-
-        public T value_for<T>(Key<T> key)
-        {
-            return key.parse_from(get_items());
-        }
-
-        public void remove<T>(Key<T> key)
-        {
-            key.remove_from(get_items());
-        }
-
-        IDictionary get_items()
-        {
-            var id = Thread.CurrentThread.ManagedThreadId;
-            within_lock(() =>
-            {
-                if (!slots.ContainsKey(id))
-                {
-                    var slot = Thread.GetNamedDataSlot(GetType().FullName);
-                    slots.Add(id, slot);
-                    Thread.SetData(slot, new Hashtable());
-                }
-            });
-            return (IDictionary) Thread.GetData(slots[id]);
-        }
-
-        void within_lock(Action action)
-        {
-            lock (mutex) action();
-        }
-    }
-}
\ No newline at end of file
+using System;
+using System.Collections;
+using System.Collections.Generic;
+using System.Threading;
+using jive.utility;
+
+namespace jive.infrastructure.threading
+{
+  public class PerThread : Context
+  {
+    readonly IDictionary<int, LocalDataStoreSlot> slots;
+    readonly object mutex = new object();
+
+    public PerThread()
+    {
+      slots = new Dictionary<int, LocalDataStoreSlot>();
+    }
+
+    public bool contains<T>(Key<T> key)
+    {
+      return key.is_found_in(get_items());
+    }
+
+    public void add<T>(Key<T> key, T value)
+    {
+      key.add_value_to(get_items(), value);
+    }
+
+    public T value_for<T>(Key<T> key)
+    {
+      return key.parse_from(get_items());
+    }
+
+    public void remove<T>(Key<T> key)
+    {
+      key.remove_from(get_items());
+    }
+
+    IDictionary get_items()
+    {
+      var id = Thread.CurrentThread.ManagedThreadId;
+      within_lock(() =>
+          {
+          if (!slots.ContainsKey(id))
+          {
+          var slot = Thread.GetNamedDataSlot(GetType().FullName);
+          slots.Add(id, slot);
+          Thread.SetData(slot, new Hashtable());
+          }
+          });
+      return (IDictionary) Thread.GetData(slots[id]);
+    }
+
+    void within_lock(Action action)
+    {
+      lock (mutex) action();
+    }
+  }
+}

@@ -1,20 +1,20 @@
-using System.Collections;
-using gorilla.utility;
-
-namespace gorilla.infrastructure.threading
+using System.Collections;
+using jive.utility;
+
+namespace jive.infrastructure.threading
 {
-    public class PerThreadScopedStorage : ScopedStorage
-    {
-        readonly ApplicationThread current_thread;
+  public class PerThreadScopedStorage : ScopedStorage
+  {
+    readonly ApplicationThread current_thread;
 
-        public PerThreadScopedStorage(ApplicationThread current_thread)
-        {
-            this.current_thread = current_thread;
-        }
+    public PerThreadScopedStorage(ApplicationThread current_thread)
+    {
+      this.current_thread = current_thread;
+    }
 
-        public IDictionary provide_storage()
-        {
-            return current_thread.provide_slot_for<Hashtable>();
-        }
+    public IDictionary provide_storage()
+    {
+      return current_thread.provide_slot_for<Hashtable>();
     }
-}
\ No newline at end of file
+  }
+}

@@ -1,23 +1,23 @@
-using System.Threading;
-using gorilla.infrastructure.container;
-using gorilla.utility;
-
-namespace gorilla.infrastructure.threading
+using System.Threading;
+using jive.infrastructure.container;
+using jive.utility;
+
+namespace jive.infrastructure.threading
 {
-    public interface ISynchronizationContextFactory : Factory<ISynchronizationContext> {}
+  public interface ISynchronizationContextFactory : Factory<ISynchronizationContext> {}
 
-    public class SynchronizationContextFactory : ISynchronizationContextFactory
-    {
-        readonly DependencyRegistry registry;
+  public class SynchronizationContextFactory : ISynchronizationContextFactory
+  {
+    readonly DependencyRegistry registry;
 
-        public SynchronizationContextFactory(DependencyRegistry registry)
-        {
-            this.registry = registry;
-        }
+    public SynchronizationContextFactory(DependencyRegistry registry)
+    {
+      this.registry = registry;
+    }
 
-        public ISynchronizationContext create()
-        {
-            return new SynchronizedContext(registry.get_a<SynchronizationContext>());
-        }
+    public ISynchronizationContext create()
+    {
+      return new SynchronizedContext(registry.get_a<SynchronizationContext>());
     }
-}
\ No newline at end of file
+  }
+}

@@ -1,28 +1,28 @@
-using System;
-using System.Threading;
-using gorilla.utility;
-
-namespace gorilla.infrastructure.threading
+using System;
+using System.Threading;
+using jive.utility;
+
+namespace jive.infrastructure.threading
 {
-    public interface ISynchronizedCommand : Command<Action>, Command<Command> {}
+  public interface ISynchronizedCommand : Command<Action>, Command<Command> {}
 
-    public class SynchronizedCommand : ISynchronizedCommand
-    {
-        readonly SynchronizationContext context;
+  public class SynchronizedCommand : ISynchronizedCommand
+  {
+    readonly SynchronizationContext context;
 
-        public SynchronizedCommand(SynchronizationContext context)
-        {
-            this.context = context;
-        }
+    public SynchronizedCommand(SynchronizationContext context)
+    {
+      this.context = context;
+    }
 
-        public void run(Action item)
-        {
-            context.Post(x => item(), new object());
-        }
+    public void run(Action item)
+    {
+      context.Post(x => item(), new object());
+    }
 
-        public void run(Command item)
-        {
-            run(item.run);
-        }
+    public void run(Command item)
+    {
+      run(item.run);
     }
-}
\ No newline at end of file
+  }
+}