added common interfaces for communication with amqp broker