| | |
|---|
| | |
|
|---|
| | | import com.mes.common.RabbitMQUtils;
|
|---|
| | |
|
|---|
| | | import java.util.List;
|
|---|
| | |
|
|---|
| | | public class ModuleB {
|
|---|
| | | private final static String QUEUE_NAME = "hangzhou2";
|
|---|
| | |
|
|---|
| | |
|---|
| | |
|
|---|
| | | try {
|
|---|
| | |
|
|---|
| | | receiver.consumeMessageById("2",QUEUE_NAME);
|
|---|
| | | //receiver.consumeMessageById("5",QUEUE_NAME);
|
|---|
| | |
|
|---|
| | | // String receivedMessage = receiver.consumeSelectedMessage(1,QUEUE_NAME);
|
|---|
| | | // String receivedMessage = String.valueOf(receiver.readMessages(QUEUE_NAME,false));
|
|---|
| | | // System.out.println("Received message: " + receivedMessage);
|
|---|
| | | List<String> receivedMessage = RabbitMQUtils.browseMessages(QUEUE_NAME);
|
|---|
| | | System.out.println("Received message: " + receivedMessage);
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | e.printStackTrace();
|
|---|
| | | }
|
|---|
