Philipp

Поскольку обработчик сообщения получается громоздким, его можно легко вынести в отдельный модуль и импортировать примерно так.

const messageProcessor = require('path/to/message/processor');
// ваш код идет здесь ...
// далее навешиваем наш обработчик на шину сообщений
messageBus.on('end', messageProcessor);

Так же вы можете автоматическую регистрацию внутри обработчика.

// в вашем основном файле
messageProcessor.register(messageBus);

Внутри процессора сообщений

function messageProcessor() {
 // ...
}

module.exports.register = function(messageBus) {
   messageBus.on('end', messageProcessor);
};