partially implemented rabbitmq spout