function MessengerFactory(config, injector) {
    var messenger = config.get('taskgraph-messenger', 'AMQP');
    switch(messenger) {
        case 'AMQP':
            return injector.get('Task.Messengers.AMQP');