private LinkedBlockingQueue<ProxyMessage> makeSureQueueExist(String streamId) {
        LinkedBlockingQueue<ProxyMessage> messageQueue = messageQueueMap.get(streamId);
        if (messageQueue == null) {
            messageQueue = new LinkedBlockingQueue<>();
            messageQueueMap.put(streamId, messageQueue);
        }
        return messageQueue;
    }
Add proxy message to cache, proxy message should belong to the same stream id.
inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/message/file/ProxyMessageCache.java