@Override
    public TransactionSendResult sendMessageInTransaction(Message msg,
        Object arg) throws MQClientException {
        throw new RuntimeException("sendMessageInTransaction not implement, please use TransactionMQProducer class");
    }
@Test(expected = RuntimeException.class)
    public void assertSendMessageInTransaction() throws MQClientException {
        TransactionSendResult result = producer.sendMessageInTransaction(message, 1);
        assertNull(result);
    }