[incubator-inlong] branch master updated: [INLONG-3099][Agent] Duplicate send message when agent receive data (#3103)

[dockerzhang]

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 4b148df  [INLONG-3099][Agent] Duplicate send message when agent 
receive data (#3103)
4b148df is described below

commit 4b148dfa3c79e26fed1da5838b2aa44bb952baa3
Author: ziruipeng <zpen...@connect.ust.hk>
AuthorDate: Sun Mar 13 20:44:33 2022 +0800

    [INLONG-3099][Agent] Duplicate send message when agent receive data (#3103)
---
 .../java/org/apache/inlong/agent/plugin/message/PackProxyMessage.java    | 1 -
 1 file changed, 1 deletion(-)

diff --git 
a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/message/PackProxyMessage.java
 
b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/message/PackProxyMessage.java
index 1cb7d02..8c0944f 100644
--- 
a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/message/PackProxyMessage.java
+++ 
b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/message/PackProxyMessage.java
@@ -101,7 +101,6 @@ public class PackProxyMessage {
         } catch (Exception ex) {
             LOGGER.error("exception caught", ex);
         }
-        messageQueue.offer(message);
     }
 
     /**