wie legen Sie die grundlegenden Eigenschaften Nachricht für Nachricht in Rabbitmq?

ich bin mit Rabbitmq-Java-client-API.ich möchte legen Sie die Grundlegenden Eigenschaften für die Nachricht und auch die Nachricht-Id der Nachricht.wenn möglich bitte etwas code, um die Dinge verstehen.

Dank

InformationsquelleAutor Sameek Mishra | 2010-11-11
  1. 2

    Beim senden einer Nachricht über den java-client in der Regel ist es zu veröffentlichen, um einen Kanal wie 

     CHANNEL.basicPublish(EXCHANGE_NAME, QUEUE_ROUTING_KEY, MessageProperties.PERSISTENT_TEXT_PLAIN, "message".getBytes)

    Hier können Sie eine Nachricht Eigenschaften

    Können Sie Holen Sie sich die msg von einer Lieferung per agent
    Sie müssen zuerst binden Sie die Warteschlange, wie dies 

     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);

    Dann verwenden delivey zu bekommen msg 

    QueueingConsumer.Delivery delivery;
            try {
               delivery = consumer.nextDelivery();

            } catch (InterruptedException ie) {
               continue;
            }
    InformationsquelleAutor Sagar Varpe
  2. 0

    Hier ist, wie es getan werden kann:

    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();
    InformationsquelleAutor Integration
Schreibe einen Kommentar