diff --git a/ch.psi.imagej.zeromq/src/main/java/ch/psi/zmq/imagej/ZeroMQViewer.java b/ch.psi.imagej.zeromq/src/main/java/ch/psi/zmq/imagej/ZeroMQViewer.java
index e8bbd75..3de682b 100644
--- a/ch.psi.imagej.zeromq/src/main/java/ch/psi/zmq/imagej/ZeroMQViewer.java
+++ b/ch.psi.imagej.zeromq/src/main/java/ch/psi/zmq/imagej/ZeroMQViewer.java
@@ -114,6 +114,7 @@ public class ZeroMQViewer implements PlugIn {
 					}
 					else if(method.equals("SUB")){
 						socket = context.socket(ZMQ.SUB);
+						socket.subscribe(""); // Subscribe to all topics
 					}
 					else{
 						logger.severe("Method not supported");
@@ -139,8 +140,10 @@ public class ZeroMQViewer implements PlugIn {
 				}
 				finally{
 					try{
+						logger.info("Close connection");
 						socket.close();
 						context.term();
+						logger.info("Connection closed");
 					}
 					catch(Exception e){
 					}