public boolean add(ProxyMessage message) {
        String streamId = message.getInlongStreamId();
        LinkedBlockingQueue<ProxyMessage> messageQueue = makeSureQueueExist(streamId);
        try {
            if (queueIsFull(messageQueue)) {
                printQueueFull();
                return false;
            }
            messageQueue.put(message);
            return true;
        } catch (Exception ex) {
            LOGGER.error("exception caught", ex);
        }
        return false;
    }
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