added amqp spout