diff --git a/src/Pool.js b/src/Pool.js
index 0d95610a..f34bca9e 100644
--- a/src/Pool.js
+++ b/src/Pool.js
@@ -204,6 +204,9 @@ Pool.prototype._next = function () {
       // get the first task from the queue
       var me = this;
       var task = this.tasks.shift();
+      
+      // assign worker to promise so it can be referred to by the handler
+      task.resolver.promise.worker = worker;
 
       // check if the task is still pending (and not cancelled -> promise rejected)
       if (task.resolver.promise.pending) {
diff --git a/src/Promise.js b/src/Promise.js
index d2d794e3..b56b78f4 100644
--- a/src/Promise.js
+++ b/src/Promise.js
@@ -22,6 +22,9 @@ function Promise(handler, parent) {
   var _onSuccess = [];
   var _onFail = [];
 
+  // empty worker
+  this.worker = null;
+
   // status
   this.resolved = false;
   this.rejected = false;
@@ -141,6 +144,22 @@ function Promise(handler, parent) {
     return me;
   };
 
+/**
+   * Calls a defined worker method with optional parameters
+   * @param {string} methodName Name of the method to be called as defined in the workerpool.worker() function
+   * @param {Array} [methodParameters] Array with optional parameters
+   */
+this.emit = function (methodName, methodParameters) {
+  if (this.worker?.worker && methodName) {
+    const payload = {
+      eventName: methodName,
+      eventParams: methodParameters,
+    };
+    this.worker.worker.postMessage(payload);
+  }
+  return this;
+};
+
   // attach handler passing the resolve and reject functions
   handler(function (result) {
     _resolve(result);
diff --git a/src/generated/embeddedWorker.js b/src/generated/embeddedWorker.js
index eac75849..23802955 100644
--- a/src/generated/embeddedWorker.js
+++ b/src/generated/embeddedWorker.js
@@ -3,4 +3,4 @@
  * This file is automatically generated,
  * changes made in this file will be overwritten.
  */
-module.exports = "!function(){var __webpack_exports__={};!function(){var exports=__webpack_exports__,__webpack_unused_export__;function _typeof(r){return(_typeof=\"function\"==typeof Symbol&&\"symbol\"==typeof Symbol.iterator?function(r){return typeof r}:function(r){return r&&\"function\"==typeof Symbol&&r.constructor===Symbol&&r!==Symbol.prototype?\"symbol\":typeof r})(r)}var requireFoolWebpack=eval(\"typeof require !== 'undefined' ? require : function (module) { throw new Error('Module \\\" + module + \\\" not found.') }\"),TERMINATE_METHOD_ID=\"__workerpool-terminate__\",worker={exit:function(){}},WorkerThreads,parentPort;if(\"undefined\"!=typeof self&&\"function\"==typeof postMessage&&\"function\"==typeof addEventListener)worker.on=function(r,e){addEventListener(r,function(r){e(r.data)})},worker.send=function(r){postMessage(r)};else{if(\"undefined\"==typeof process)throw new Error(\"Script must be executed as a worker\");try{WorkerThreads=requireFoolWebpack(\"worker_threads\")}catch(error){if(\"object\"!==_typeof(error)||null===error||\"MODULE_NOT_FOUND\"!==error.code)throw error}WorkerThreads&&null!==WorkerThreads.parentPort?(parentPort=WorkerThreads.parentPort,worker.send=parentPort.postMessage.bind(parentPort),worker.on=parentPort.on.bind(parentPort)):(worker.on=process.on.bind(process),worker.send=process.send.bind(process),worker.on(\"disconnect\",function(){process.exit(1)}),worker.exit=process.exit.bind(process))}function convertError(o){return Object.getOwnPropertyNames(o).reduce(function(r,e){return Object.defineProperty(r,e,{value:o[e],enumerable:!0})},{})}function isPromise(r){return r&&\"function\"==typeof r.then&&\"function\"==typeof r.catch}worker.methods={},worker.methods.run=function(r,e){r=new Function(\"return (\"+r+\").apply(null, arguments);\");return r.apply(r,e)},worker.methods.methods=function(){return Object.keys(worker.methods)};var currentRequestId=null;worker.on(\"message\",function(e){if(e===TERMINATE_METHOD_ID)return worker.exit(0);try{var r=worker.methods[e.method];if(!r)throw new Error('Unknown method \"'+e.method+'\"');currentRequestId=e.id;var o=r.apply(r,e.params);isPromise(o)?o.then(function(r){worker.send({id:e.id,result:r,error:null}),currentRequestId=null}).catch(function(r){worker.send({id:e.id,result:null,error:convertError(r)}),currentRequestId=null}):(worker.send({id:e.id,result:o,error:null}),currentRequestId=null)}catch(r){worker.send({id:e.id,result:null,error:convertError(r)})}}),worker.register=function(r){if(r)for(var e in r)r.hasOwnProperty(e)&&(worker.methods[e]=r[e]);worker.send(\"ready\")},worker.emit=function(r){currentRequestId&&worker.send({id:currentRequestId,isEvent:!0,payload:r})},__webpack_unused_export__=worker.register,worker.emit}()}();";
+module.exports = "!function(){var __webpack_exports__={};!function(){var exports=__webpack_exports__,__webpack_unused_export__;function _typeof(r){return(_typeof=\"function\"==typeof Symbol&&\"symbol\"==typeof Symbol.iterator?function(r){return typeof r}:function(r){return r&&\"function\"==typeof Symbol&&r.constructor===Symbol&&r!==Symbol.prototype?\"symbol\":typeof r})(r)}var requireFoolWebpack=eval(\"typeof require !== 'undefined' ? require : function (module) { throw new Error('Module \\\" + module + \\\" not found.') }\"),TERMINATE_METHOD_ID=\"__workerpool-terminate__\",worker={exit:function(){}},WorkerThreads,parentPort;if(\"undefined\"!=typeof self&&\"function\"==typeof postMessage&&\"function\"==typeof addEventListener)worker.on=function(r,e){addEventListener(r,function(r){e(r.data)})},worker.send=function(r){postMessage(r)};else{if(\"undefined\"==typeof process)throw new Error(\"Script must be executed as a worker\");try{WorkerThreads=requireFoolWebpack(\"worker_threads\")}catch(error){if(\"object\"!==_typeof(error)||null===error||\"MODULE_NOT_FOUND\"!==error.code)throw error}WorkerThreads&&null!==WorkerThreads.parentPort?(parentPort=WorkerThreads.parentPort,worker.send=parentPort.postMessage.bind(parentPort),worker.on=parentPort.on.bind(parentPort)):(worker.on=process.on.bind(process),worker.send=process.send.bind(process),worker.on(\"disconnect\",function(){process.exit(1)}),worker.exit=process.exit.bind(process))}function convertError(o){return Object.getOwnPropertyNames(o).reduce(function(r,e){return Object.defineProperty(r,e,{value:o[e],enumerable:!0})},{})}function isPromise(r){return r&&\"function\"==typeof r.then&&\"function\"==typeof r.catch}worker.methods={},worker.methods.run=function(r,e){r=new Function(\"return (\"+r+\").apply(null, arguments);\");return r.apply(r,e)},worker.methods.methods=function(){return Object.keys(worker.methods)};var currentRequestId=null;worker.on(\"message\",function(e){if(e===TERMINATE_METHOD_ID)return worker.exit(0);try{var r=worker.methods[e.method];if(!r)throw new Error('Unknown method \"'+e.method+'\"');currentRequestId=e.id;var o=r.apply(r,e.params);isPromise(o)?o.then(function(r){worker.send({id:e.id,result:r,error:null}),currentRequestId=null}).catch(function(r){worker.send({id:e.id,result:null,error:convertError(r)}),currentRequestId=null}):(worker.send({id:e.id,result:o,error:null}),currentRequestId=null)}catch(r){worker.send({id:e.id,result:null,error:convertError(r)})}}),worker.register=function(r){if(r)for(var e in r)r.hasOwnProperty(e)&&(worker.methods[e]=r[e]);worker.send(\"ready\")},worker.emit=function(r){currentRequestId&&worker.send({id:currentRequestId,isEvent:!0,payload:r})},worker.onEvents=function(t){for(var r=0,e=Object.keys(t);r<e.length;r++)!function(){var o=e[r];worker.on(\"message\",function(r){var e=r.eventName,r=r.eventParams;e===o&&(r&&!Array.isArray(r)&&(r=[r]),t[o].apply(worker,r))})}()},__webpack_unused_export__=worker.register,__webpack_unused_export__=worker.emit,worker.onEvents}()}();";
diff --git a/src/index.js b/src/index.js
index 051bbf14..455293e8 100644
--- a/src/index.js
+++ b/src/index.js
@@ -16,9 +16,10 @@ exports.pool = function pool(script, options) {
  * Create a worker and optionally register a set of methods to the worker.
  * @param {Object} [methods]
  */
-exports.worker = function worker(methods) {
+exports.worker = function worker(methods, events) {
   var worker = require('./worker');
   worker.add(methods);
+  if (events) worker.addOnEvents(events);
 };
 
 /**
@@ -38,4 +39,4 @@ exports.Promise = require('./Promise');
 
 exports.platform = environment.platform;
 exports.isMainThread = environment.isMainThread;
-exports.cpus = environment.cpus;
\ No newline at end of file
+exports.cpus = environment.cpus;
diff --git a/src/worker.js b/src/worker.js
index 493ceb2d..4bf8fdaa 100644
--- a/src/worker.js
+++ b/src/worker.js
@@ -120,7 +120,7 @@ worker.on('message', function (request) {
 
     if (method) {
       currentRequestId = request.id;
-      
+
       // execute the function
       var result = method.apply(method, request.params);
 
@@ -196,7 +196,21 @@ worker.emit = function (payload) {
   }
 };
 
+worker.onEvents = function(events) {
+  for (const eventKey of Object.keys(events)) {
+    worker.on('message', function({eventName, eventParams}) {
+      if (eventName === eventKey) {
+        if (eventParams && !Array.isArray(eventParams)) {
+          eventParams = [eventParams];
+        }
+        events[eventKey].apply(worker, eventParams);
+      }
+    });
+  }
+}
+
 if (typeof exports !== 'undefined') {
   exports.add = worker.register;
   exports.emit = worker.emit;
+  exports.addOnEvents = worker.onEvents;
 }
diff --git a/test/CallMethod.test.js b/test/CallMethod.test.js
new file mode 100644
index 00000000..4879aea1
--- /dev/null
+++ b/test/CallMethod.test.js
@@ -0,0 +1,42 @@
+var assert = require('assert');
+var Pool = require('../src/Pool');
+
+it('creates a worker pool with event callbacks', function (done) {
+  const pool = new Pool(__dirname + "/workers/waitForMessage.js");
+  
+  const handler = pool.exec('fibonacci', [15]);
+
+  handler
+  .then(function (result) {
+    assert.strictEqual(result, 610);
+  })
+  .catch(function (err) {
+    console.error(err);
+  })
+  .then(function () {
+    pool.terminate(); // terminate all workers when done
+    done();
+  })
+  .catch(done);
+});
+
+it('creates a worker pool and sends a message', function (done) {
+  const pool = new Pool(__dirname + "/workers/waitForMessage.js");
+  
+  const handler = pool.exec('fibonacci', [15]);
+
+  handler
+  .then(function (result) {
+    assert.strictEqual(result, 610);
+  })
+  .catch(function (err) {
+    assert.strictEqual(err.toString().includes('exitCode: `99`'), true);
+  })
+  .then(function () {
+    pool.terminate(); // terminate all workers when done
+    done();
+  })
+  .catch(done);
+  
+  handler.emit('killme', 99); // forces the worker to exit with exitcode 99
+});
diff --git a/test/workers/waitForMessage.js b/test/workers/waitForMessage.js
new file mode 100644
index 00000000..aee3896b
--- /dev/null
+++ b/test/workers/waitForMessage.js
@@ -0,0 +1,18 @@
+// a simple worker that just sits there and receives messages
+
+// load workerpool
+var workerpool = require('../../');
+
+function fibonacci(n) {
+  if (n < 2) return n;
+  return fibonacci(n - 2) + fibonacci(n - 1);
+}
+
+// create a worker and register public functions
+workerpool.worker({
+  fibonacci: fibonacci,
+}, {
+  killme: function (payload) {
+    process.exit(payload);
+  }
+});