Added message producer and message consumer code.