public void wrapMultiDispatch(final MessageExtBrokerInner msg) {

        String multiDispatchQueue = msg.getProperty(MessageConst.PROPERTY_INNER_MULTI_DISPATCH);
        String[] queues = multiDispatchQueue.split(MixAll.MULTI_DISPATCH_QUEUE_SPLITTER);
        Long[] queueOffsets = new Long[queues.length];
        if (messageStore.getMessageStoreConfig().isEnableLmq()) {
            for (int i = 0; i < queues.length; i++) {
                String key = queueKey(queues[i], msg);
                if (MixAll.isLmq(key)) {
                    queueOffsets[i] = messageStore.getQueueStore().getLmqQueueOffset(key);
                }
            }
        }
        MessageAccessor.putProperty(msg, MessageConst.PROPERTY_INNER_MULTI_QUEUE_OFFSET,
                StringUtils.join(queueOffsets, MixAll.MULTI_DISPATCH_QUEUE_SPLITTER));
        msg.removeWaitStorePropertyString();
    }
@Test
    public void wrapMultiDispatch() throws RocksDBException {
        MessageExtBrokerInner messageExtBrokerInner = buildMessageMultiQueue();
        multiDispatch.wrapMultiDispatch(messageExtBrokerInner);
        assertEquals(messageExtBrokerInner.getProperty(MessageConst.PROPERTY_INNER_MULTI_QUEUE_OFFSET), "0,0");
    }