diff --git a/setup.py b/setup.py
index 9c63748..f14eadb 100755
--- a/setup.py
+++ b/setup.py
@@ -52,7 +52,7 @@ except:
 
 setuptools.setup(
         name='warcprox',
-        version='2.3.1b4.dev133',
+        version='2.3.1b4.dev134',
         description='WARC writing MITM HTTP/S proxy',
         url='https://github.com/internetarchive/warcprox',
         author='Noah Levitt',
diff --git a/tests/test_warcprox.py b/tests/test_warcprox.py
index db6a657..ad96903 100755
--- a/tests/test_warcprox.py
+++ b/tests/test_warcprox.py
@@ -1308,7 +1308,9 @@ def test_status_api(warcprox_):
     status = json.loads(response.content.decode('ascii'))
     assert set(status.keys()) == {
             'role', 'version', 'host', 'address', 'port', 'pid', 'load',
-            'queued_urls', 'queue_max_size', 'seconds_behind', 'threads'}
+            'queued_urls', 'queue_max_size', 'seconds_behind', 'threads',
+            'rates_5min', 'rates_1min', 'unaccepted_requests', 'rates_15min',
+            'active_requests',}
     assert status['role'] == 'warcprox'
     assert status['version'] == warcprox.__version__
     assert status['port'] == warcprox_.proxy.server_port
@@ -1361,6 +1363,7 @@ def test_controller_with_defaults():
     assert controller.proxy.recorded_url_q
     assert controller.proxy.server_address == ('127.0.0.1', 8000)
     assert controller.proxy.server_port == 8000
+    assert controller.proxy.running_stats
     for wwt in controller.warc_writer_threads:
         assert wwt
         assert wwt.recorded_url_q
diff --git a/warcprox/controller.py b/warcprox/controller.py
index 2b0c8a8..0bf8a4f 100644
--- a/warcprox/controller.py
+++ b/warcprox/controller.py
@@ -62,7 +62,7 @@ class WarcproxController(object):
                     warcprox.writerthread.WarcWriterThread(
                         name='WarcWriterThread%03d' % i,
                         recorded_url_q=self.proxy.recorded_url_q,
-                        options=options)
+                        listeners=[self.proxy.running_stats], options=options)
                     for i in range(int(self.proxy.max_threads ** 0.5))]
 
         self.proxy_thread = None
diff --git a/warcprox/warcproxy.py b/warcprox/warcproxy.py
index eec5e50..6f7dd34 100644
--- a/warcprox/warcproxy.py
+++ b/warcprox/warcproxy.py
@@ -376,7 +376,7 @@ class SingleThreadedWarcProxy(http_server.HTTPServer, object):
 
     def __init__(
             self, ca=None, recorded_url_q=None, stats_db=None,
-            running_stats=None, options=warcprox.Options()):
+            options=warcprox.Options()):
         server_address = (
                 options.address or 'localhost',
                 options.port if options.port is not None else 8000)
@@ -410,9 +410,10 @@ class SingleThreadedWarcProxy(http_server.HTTPServer, object):
                     maxsize=options.queue_size or 1000)
 
         self.stats_db = stats_db
-        self.running_stats = running_stats
         self.options = options
 
+        self.running_stats = warcprox.stats.RunningStats()
+
     def status(self):
         if hasattr(super(), 'status'):
             result = super().status()
@@ -458,7 +459,7 @@ class WarcProxy(SingleThreadedWarcProxy, warcprox.mitmproxy.PooledMitmProxy):
         warcprox.mitmproxy.PooledMitmProxy.__init__(
                 self, options.max_threads, options)
         SingleThreadedWarcProxy.__init__(
-                self, ca, recorded_url_q, stats_db, running_stats, options)
+                self, ca, recorded_url_q, stats_db, options)
 
     def server_activate(self):
         http_server.HTTPServer.server_activate(self)