added data models for amqp messages that were sent into AMQP broker.