2
A
回答
2
雖然發送通過Java客戶端的消息通常是publich像
CHANNEL.basicPublish(EXCHANGE_NAME, QUEUE_ROUTING_KEY, MessageProperties.PERSISTENT_TEXT_PLAIN, "message".getBytes)
這裏u能設置消息屬性的信道
ü麪包車通過使用遞送得到MSG代理 你必須先像這樣綁定隊列
Channel channel = conn.createChannel();
String exchangeName = "myExchange";
String queueName = "myQueue";
String routingKey = "testRoute";
boolean durable = true;
channel.exchangeDeclare(exchangeName, "direct", durable);
channel.queueDeclare(queueName, durable,false,false,durable, null);
channel.queueBind(queueName, exchangeName, routingKey);
boolean noAck = false;
QueueingConsumer consumer = new QueueingConsumer(channel);
channel.basicConsume(queueName, noAck, consumer);
然後使用delivey獲得味精
QueueingConsumer.Delivery delivery;
try {
delivery = consumer.nextDelivery();
} catch (InterruptedException ie) {
continue;
}
0
這裏是如何可以做到:
int PERSISTENCE_MESSAGE = 2; // Persist message
String TEXT_MESSAGE = "text/plain";
String queueName = "QUE-1";
Channel channel = this.connection.createChannel();
channel.queueDeclare(queueName, true, false, false, null);
// Build message properties
Map messageProps = new HashMap();
//messageProps.put("TIME_MSG_RECEIVED", time);
messageProps.put("SOURCE_SYS", "SRC1");
messageProps.put("DESTINATION_SYS", "DST1");
// Set message properties
AMQP.BasicProperties.Builder basicProperties = new AMQP.BasicProperties.Builder();
basicProperties.contentType(TEXT_MESSAGE).deliveryMode(PERSISTENCE_MESSAGE)
.priority(1).headers(messageProps);
channel.basicPublish("", queueName, basicProperties.build(), message.getBytes());
System.out.println(" Sent message to RabbitMQ: '" + message + "'");
channel.close();
相關問題
- 1. 消息屬性和負載在RabbitMQ
- 2. 如何使用WSO2 ESB將消息屬性填充爲RabbitMQ消息生成器
- 3. 在w/boto的SQS隊列中設置消息的消息屬性?
- 4. 如何在Ruby中設置異常變量的消息屬性?
- 5. Rabbitmq消息與基於Java API的消息ID進行區分
- 6. 是否可以在傳出消息中設置AMQP消息屬性?
- 7. RabbitMQ中的延遲消息
- 8. RabbitMQ中的消息丟失
- 9. 如何刪除rabbitmq中的消息(pika)
- 10. RabbitMQ重排消息
- 11. RabbitMQ消息交換
- 12. RabbitMQ消息加密
- 13. RabbitMQ將消息分組爲一個消息,即合併消息
- 14. 如何只讀取基於消息頭屬性的特定隊列消息
- 15. RabbitMQ正在丟失消息
- 16. RabbitMQ消息中間件
- 17. 如何在Yii2中設置Flash消息?
- 18. 如何設置spring-rabbitmq收聽消息的速率
- 19. 帶RabbitMQ的計劃消息
- 20. 基於位置的消息
- 21. jQuery驗證 - 如何title屬性設置爲錯誤消息
- 22. 在Node.JS中的RabbitMQ消息傳遞?
- 23. 在RabbitMQ中接收消息的方式
- 24. RabbitMQ後續消息原子性
- 25. RabbitMQ消息消費者不再使用消息
- 26. 如何在使用Rabbitmq時設置消息自動重試並設置ttl = 0?
- 27. Nack當前消息和Ack當前消息(rabbitmq,java)之前的所有消息
- 28. 消耗在本地託管的rabbitmq消息
- 29. 如何從RabbitMQ獲取舊消息?
- 30. 如何使用Java確認RabbitMQ消息?