leizhiyuan opened a new pull request, #381:
URL: https://github.com/apache/rocketmq-clients/pull/381

   after produce 
   
   add a simple consumer which can run basicly, there is an  tasecase user can 
run to test
   
   ```
   response: [MessageView { body: [84, 104, 105, 115, 32, 105, 115, 32, 97, 32, 
110, 111, 114, 109, 97, 108, 32, 109, 101, 115, 115, 97, 103, 101, 32, 102, 
111, 114, 32, 65, 112, 97, 99, 104, 101, 32, 82, 111, 99, 107, 101, 116, 77, 
81], message_id: "01CEFCE69B8006C97E0411B33200000012", topic: "TopicTest", 
consume_group: "xxx", endpoint: "127.0.0.1:8081", receipt_handle: "2303 
1677739894909 120000 1 0 broker-a 2 2303 2308538" }]
   ack_result: Ok(AckMessageResponse { status: Some(Status { code: Ok, message: 
"OK" }), entries: [AckMessageResultEntry { message_id: 
"01CEFCE69B8006C97E0411B33200000012", receipt_handle: "2303 1677739894909 
120000 1 0 broker-a 2 2303 2308538", status: Some(Status { code: Ok, message: 
"OK" }) }] })
   
   ```


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to