@Override
    public SendResult send(final Message message) {
        return send(message, this.rocketmqProducer.getSendMsgTimeout());
    }
@Test
    public void testSend_OK() throws InterruptedException, RemotingException, MQClientException, MQBrokerException {
        SendResult sendResult = new SendResult();
        sendResult.setMsgId("TestMsgID");
        sendResult.setSendStatus(SendStatus.SEND_OK);
        when(rocketmqProducer.send(any(Message.class), anyLong())).thenReturn(sendResult);
        io.openmessaging.producer.SendResult omsResult =
            producer.send(producer.createBytesMessage("HELLO_TOPIC", new byte[] {'a'}));

        assertThat(omsResult.messageId()).isEqualTo("TestMsgID");
    }