renyansongno1 opened a new pull request, #210:
URL: https://github.com/apache/skywalking-go/pull/210

   ## Interception Point Modification
   
   Since the Consumer function of AMQP091 returns a read-only chan structure, 
the previous agent logic reads this chan, causing the normal business logic to 
miss messages.
   
   Therefore, after my consideration, interception can be performed before the 
message enters this chan to process the message for tracing.
   
   ## Other Modification Points
   
   Due to the definition of the AMQP protocol itself, after the client and 
broker establish a connection, communication is conducted using channels. 
Throughout the entire communication process, the message does not contain queue 
name information. Hence, it is necessary to obtain the relationship between 
ConsumerTag and queue when the Consumer function is called. In subsequent 
message bodies, the Queue can be mapped out through ConsumerTag.
   


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