diff --git a/lib/workers/socketioworker.js b/lib/workers/socketioworker.js
index 3831330..37e9f6d 100644
--- a/lib/workers/socketioworker.js
+++ b/lib/workers/socketioworker.js
@@ -15,7 +15,8 @@ util.inherits(SocketIOWorker, BaseWorker);
 
 SocketIOWorker.prototype.createClient = function (callback) {
   var self = this;
-  var client = io.connect(this.server, { 'force new connection' : true});
+
+  var client = io(this.server, {forceNew: true});
 
   client.on('connect', function () {
     callback(false, client);
diff --git a/package.json b/package.json
index f6c8182..e30dd10 100644
--- a/package.json
+++ b/package.json
@@ -16,14 +16,14 @@
   "author": "",
   "license": "BSD",
   "dependencies": {
-    "socket.io-client": "~1.3.5",
+    "socket.io-client": "~2.0.3",
     "engine.io-client": "~0.9.0",
     "commander": "~1.1.1",
     "colors": "~0.6",
     "cli-table": "~0.3.0",
     "faye": "~0.8.9",
     "winston": "~0.7.1",
-    "socket.io": "~1.3.5",
+    "socket.io": "~2.0.3",
     "primus": "~1.5.2",
     "autobahn": "~0.9.5"
   },