diff --git a/capture.cc b/capture.cc
index 8d8567a..cb7511e 100644
--- a/capture.cc
+++ b/capture.cc
@@ -36,13 +36,13 @@ capture::capture(int camera_index, int zmq_port, int width_set, int height_set,
     }
 
     context = new zmq::context_t(1);
-    socket = new zmq::socket_t(*context, ZMQ_PUB);
-    int hwm = 10;
-    socket->setsockopt(ZMQ_SNDHWM, &hwm, sizeof(hwm));
+    socket = new zmq::socket_t(*context, ZMQ_REP);
+    // int hwm = 10;
+    // socket->setsockopt(ZMQ_SNDHWM, &hwm, sizeof(hwm));
     char zmq_bind_port[10] = {0};
     sprintf(zmq_bind_port, "%d", port);
     strcat(zmq_bind_addr, zmq_bind_port);
-    log_info("set camera %d zmq address %s", index, zmq_bind_addr);
+    log_info("set camera %d zmq address test %s", index, zmq_bind_addr);
     socket->bind(zmq_bind_addr);
 }
 
@@ -64,6 +64,8 @@ void capture::run(void)
     cv::Mat dst;
     while (1)
     {
+        zmq::message_t msg_temp;
+        socket->recv(&msg_temp);
         *cap >> frame;
         if (frame.empty())
         {