diff --git a/dap/accumulator.py b/dap/accumulator.py
index c3723e9..b3ec3b8 100644
--- a/dap/accumulator.py
+++ b/dap/accumulator.py
@@ -14,21 +14,22 @@ def main():
     parser.add_argument("--accumulator_port", type=int, default=13000)
     parser.add_argument("--bsread_host", default="*")
     parser.add_argument("--bsread_port", type=int, default=None)
+    parser.add_argument("--bsread_window", type=int, default=1000)
 
     clargs = parser.parse_args()
 
     accumulator_addr = make_address(clargs.accumulator_host, clargs.accumulator_port)
 
-    accumulate(accumulator_addr, clargs.bsread_host, clargs.bsread_port)
+    accumulate(accumulator_addr, clargs.bsread_host, clargs.bsread_port, clargs.bsread_window)
 
 
 
-def accumulate(accumulator_addr, bsread_host, bsread_port):
+def accumulate(accumulator_addr, bsread_host, bsread_port, bsread_window):
     zmq_socks = ZMQSocketsAccumulator(accumulator_addr)
 
     output = FileHandler()
 
-    sorter = Sorter()
+    sorter = Sorter(window=bsread_window)
 
     sender = make_bsread_sender(bsread_host, bsread_port)