diff --git a/lib/socket.ts b/lib/socket.ts
index c66e6c7..7d6199c 100644
--- a/lib/socket.ts
+++ b/lib/socket.ts
@@ -252,6 +252,10 @@ export const Socket = (
         await (<any>queue).obliterate();
         respond(msg.id);
         break;
+      case "clean":
+        await (<any>queue).clean(data.grace, data.status, data.limit);
+        respond(msg.id);
+        break;
       default:
         console.error(
           `Missing command ${data.cmd}. Too old version of taskforce-connector?`