diff --git a/dap/worker.py b/dap/worker.py
index 23a4de5..84fa595 100644
--- a/dap/worker.py
+++ b/dap/worker.py
@@ -7,7 +7,7 @@ from algos import (
     calc_radial_integration, calc_roi, calc_spi_analysis, calc_streakfinder_analysis, JFData
 )
 from utils import Aggregator, BufferedJSON, randskip, read_bit
-from zmqsocks import ZMQSockets
+from zmqsocks import ZMQSocketsWorker
 
 
 def main():
@@ -43,7 +43,7 @@ def work(backend_address, accumulator_host, accumulator_port, visualisation_host
 
     jfdata = JFData()
 
-    zmq_socks = ZMQSockets(backend_address, accumulator_host, accumulator_port, visualisation_host, visualisation_port)
+    zmq_socks = ZMQSocketsWorker(backend_address, accumulator_host, accumulator_port, visualisation_host, visualisation_port)
 
     aggregator = Aggregator()
 
diff --git a/dap/zmqsocks.py b/dap/zmqsocks.py
index be25cc8..0d134d2 100644
--- a/dap/zmqsocks.py
+++ b/dap/zmqsocks.py
@@ -5,7 +5,7 @@ import zmq
 FLAGS = 0
 
 
-class ZMQSockets:
+class ZMQSocketsWorker:
 
     def __init__(self, backend_address, accumulator_host, accumulator_port, visualisation_host, visualisation_port):
         zmq_context = zmq.Context(io_threads=4)