From aa5ae98eebb87dedb2f6f1fc8b3d258ac1c9a80b Mon Sep 17 00:00:00 2001
From: Julien Ammous <j.ammous@gmail.com>
Date: Sat, 13 Nov 2010 18:28:39 +0100
Subject: [PATCH] zeromq plugin: cleanup

---
 src/zeromq.c | 43 +------------------------------------------
 1 file changed, 1 insertion(+), 42 deletions(-)

diff --git a/src/zeromq.c b/src/zeromq.c
index 8408abee..69c1e26b 100644
--- a/src/zeromq.c
+++ b/src/zeromq.c
@@ -38,8 +38,6 @@
 #include <pthread.h>
 #include <zmq.h>
 
-// config data
-static char *zmq_send_to = NULL;
 struct cmq_socket_s
 {
 	void *socket;
@@ -57,7 +55,6 @@ static int        sending_sockets_num = 0;
 // private data
 static int thread_running = 1;
 static pthread_t listen_thread_id;
-static void *push_socket = NULL;
 
 static void cmq_close_callback (void *socket) /* {{{ */
 {
@@ -382,45 +379,7 @@ static int plugin_init (void)
 {
   int major, minor, patch;
   zmq_version (&major, &minor, &patch);
-  
-  /* init zeromq (1 I/O thread) */
-  if (cmq_context == NULL)
-    cmq_context = zmq_init(1);
-
-  if( cmq_context == NULL ) {
-    ERROR("zmq_init : %s", zmq_strerror(errno));
-    return 1;
-  }
-  
-  // start send socket
-  if( zmq_send_to != NULL ) {
-    push_socket = zmq_socket(cmq_context, ZMQ_PUSH);
-    
-    if( push_socket == NULL ) {
-      ERROR("zmq_socket : %s", zmq_strerror(errno));
-      return 1;
-    }
-    
-    // and connect to remote host
-    if( zmq_connect(push_socket, zmq_send_to) != 0 ) {
-      ERROR("zmq_connect : %s", zmq_strerror(errno));
-      return 1;
-    }
-    
-    INFO("ZeroMQ pushing to %s", zmq_send_to);
-  }
-  
-  
-  
-  INFO("ZeroMQ plugin initialized (zeromq v%d.%d.%d).", major, minor, patch);
-  return 0;
-}
-
-
-
-static int write_notification (const notification_t *n, user_data_t __attribute__((unused)) *user_data)
-{
-  DEBUG("ZeroMQ: received notification, not implemented yet");
+  INFO("ZeroMQ plugin loaded (zeromq v%d.%d.%d).", major, minor, patch);
   return 0;
 }
 
-- 
2.11.0