YiWuProject.git

			@@ -2,6 +2,8 @@

			import com.mes.common.RabbitMQUtils;

			import java.util.List;

			public class ModuleB {
			private final static String QUEUE_NAME = "hangzhou2";

			@@ -12,8 +14,12 @@
			RabbitMQUtils receiver = new RabbitMQUtils();

			try {
			String receivedMessage = String.valueOf(receiver.readMessages(QUEUE_NAME,false));
			System.out.println("Received message: " + receivedMessage);

			//receiver.consumeMessageById("5",QUEUE_NAME);

			// String receivedMessage = receiver.consumeSelectedMessage(1,QUEUE_NAME);
			List<String> receivedMessage = RabbitMQUtils.browseMessages(QUEUE_NAME);
			System.out.println("Received message: " + receivedMessage);
			} catch (Exception e) {
			e.printStackTrace();
			}