| | |
|---|
| | |
|
|---|
| | | import com.rabbitmq.client.*;
|
|---|
| | |
|
|---|
| | | import java.util.HashMap;
|
|---|
| | | import java.util.Map;
|
|---|
| | |
|
|---|
| | | public class ModuleA {
|
|---|
| | | private final static String QUEUE_NAME = "hangzhoumes";
|
|---|
| | | private static String QUEUE_NAME = "hangzhou2";
|
|---|
| | |
|
|---|
| | | public ModuleA(String QUEUENAME){
|
|---|
| | | QUEUE_NAME=QUEUENAME;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | |
|
|---|
| | |
|
|---|
| | | public static void main(String[] argv) throws Exception {
|
|---|
| | | // 创建连接工厂
|
|---|
| | | ConnectionFactory factory = new ConnectionFactory();
|
|---|
| | | factory.setHost("localhost");
|
|---|
| | | factory.setHost("10.153.19.150");
|
|---|
| | | // factory.setHost("localhost");
|
|---|
| | |
|
|---|
| | | try (Connection connection = factory.newConnection();
|
|---|
| | | //channel 是通过 connection 创建的一个 AMQP 信道对象
|
|---|
| | |
|---|
| | | //4. `false`：指定是否在不再使用时自动删除队列。在这里设置为`false`，表示当没有消费者或者所有消费者断开连接后，队列不会自动删除。
|
|---|
| | | //5. `null`：指定其他队列属性的参数。在这里设置为`null`，表示没有其他属性需要设置。
|
|---|
| | | //执行`channel.queueDeclare()`方法后，如果队列不存在，将会创建一个新的队列，如果队列已经存在，则不做任何操作。
|
|---|
| | | channel.queueDeclare(QUEUE_NAME, false, false, false, null);
|
|---|
| | | Map<String, Object> args = new HashMap<>();
|
|---|
| | | args.put("x-max-length", 10000);
|
|---|
| | | channel.queueDeclare(QUEUE_NAME, true, false, false, args);
|
|---|
| | |
|
|---|
| | |
|
|---|
| | |
|
|---|
| | |
|
|---|
