switched back to process backed simulator

qsim/core.py

@@ -153,7 +153,7 @@ class ThreadSimulator(SimulatorBase):
 class ProcessSimulator(SimulatorBase):        
     
     def __init__(self, sources, transforms, client, feed=None, merge=None):
-        SimlulatorBase.__init__(self, sources, transforms, client, feed, merge)
+        SimulatorBase.__init__(self, sources, transforms, client, feed, merge)
     
     def launch_component(self, name, component):
         qutil.LOGGER.info("starting {name}".format(name=name))

qsim/test/test_messaging.py

@@ -7,7 +7,7 @@ import unittest2 as unittest
 import multiprocessing
 import time
 
-from qsim.core import ThreadSimulator, DataFeed
+from qsim.core import ThreadSimulator, ProcessSimulator, DataFeed
 from qsim.transforms.technical import MovingAverage
 from qsim.sources import RandomEquityTrades
 import qsim.util as qutil

setup.cfg

@@ -8,6 +8,7 @@ cover-erase=1
 cover-html=1
 cover-html-dir=docs/_build/html/cover
 with-xunit=1 
+#processes=2
 
 
 # Drop into debugger on failure