public PutMessageResult putMessageReturnResult(MessageExtBrokerInner messageInner) {
        LOGGER.debug("[BUG-TO-FIX] Thread:{} msgID:{}", Thread.currentThread().getName(), messageInner.getMsgId());
        PutMessageResult result = store.putMessage(messageInner);
        if (result != null && result.getPutMessageStatus() == PutMessageStatus.PUT_OK) {
            this.brokerController.getBrokerStatsManager().incTopicPutNums(messageInner.getTopic());
            this.brokerController.getBrokerStatsManager().incTopicPutSize(messageInner.getTopic(),
                    result.getAppendMessageResult().getWroteBytes());
            this.brokerController.getBrokerStatsManager().incBrokerPutNums();
        }
        return result;
    }
@Test
    public void testPutMessageReturnResult() {
        when(messageStore.putMessage(any(MessageExtBrokerInner.class)))
                .thenReturn(new PutMessageResult(PutMessageStatus.PUT_OK, new AppendMessageResult(AppendMessageStatus.PUT_OK)));
        PutMessageResult result = transactionBridge.putMessageReturnResult(createMessageBrokerInner());
        assertThat(result.getPutMessageStatus()).isEqualTo(PutMessageStatus.PUT_OK);
    }