diff --git a/lib/appenders/tcp-server.js b/lib/appenders/tcp-server.js
index 83553cb..222fe5c 100644
--- a/lib/appenders/tcp-server.js
+++ b/lib/appenders/tcp-server.js
@@ -7,46 +7,41 @@ const DELIMITER = '__LOG4JS__';
 
 exports.configure = (config) => {
   debug('configure called with ', config);
-  // dummy shutdown if we're not master
-  let shutdown = (cb) => { cb(); };
 
-  clustering.onlyOnMaster(() => {
-    const server = net.createServer((socket) => {
-      let dataSoFar = '';
-      const send = (data) => {
-        if (data) {
-          dataSoFar += data;
-          if (dataSoFar.indexOf(DELIMITER)) {
-            const events = dataSoFar.split(DELIMITER);
-            if (!dataSoFar.endsWith(DELIMITER)) {
-              dataSoFar = events.pop();
-            } else {
-              dataSoFar = '';
-            }
-            events.filter(e => e.length).forEach((e) => {
-              clustering.send(LoggingEvent.deserialise(e));
-            });
+  const server = net.createServer((socket) => {
+    let dataSoFar = '';
+    const send = (data) => {
+      if (data) {
+        dataSoFar += data;
+        if (dataSoFar.indexOf(DELIMITER)) {
+          const events = dataSoFar.split(DELIMITER);
+          if (!dataSoFar.endsWith(DELIMITER)) {
+            dataSoFar = events.pop();
+          } else {
+            dataSoFar = '';
           }
+          events.filter(e => e.length).forEach((e) => {
+            clustering.send(LoggingEvent.deserialise(e));
+          });
+        } else {
+          dataSoFar = '';
         }
-      };
-
-      socket.setEncoding('utf8');
-      socket.on('data', send);
-      socket.on('end', send);
-    });
-
-    server.listen(config.port || 5000, config.host || 'localhost', () => {
-      debug(`listening on ${config.host || 'localhost'}:${config.port || 5000}`);
-      server.unref();
-    });
-
-    shutdown = (cb) => {
-      debug('shutdown called.');
-      server.close(cb);
+      }
     };
+    socket.setEncoding('utf8');
+    socket.on('data', send);
+    socket.on('end', send);
+  });
+
+  server.listen(config.port || 5000, config.host || 'localhost', () => {
+    debug(`listening on ${config.host || 'localhost'}:${config.port || 5000}`);
+    server.unref();
   });
 
   return {
-    shutdown
+    shutdown: (cb) => {
+      debug('shutdown called.');
+      server.close(cb);
+    }
   };
 };