java/e2e-v4/src/main/java/org/apache/rocketmq/client/rmq/RMQNormalProducer.java [122:135]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
            SendResult sendResult = null;
            try {
                sendResult = producer.send(message);
            } catch (MQClientException e) {
                e.printStackTrace();
            } catch (RemotingException e) {
                e.printStackTrace();
            } catch (MQBrokerException e) {
                e.printStackTrace();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            logger.info(sendResult.toString());
            this.enqueueMessages.addData((MessageExt)message);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



java/e2e-v4/src/main/java/org/apache/rocketmq/client/rmq/RMQNormalProducer.java [387:400]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        SendResult sendResult = null;
        try {
            sendResult = producer.send(message);
        } catch (MQClientException e) {
            e.printStackTrace();
        } catch (RemotingException e) {
            e.printStackTrace();
        } catch (MQBrokerException e) {
            e.printStackTrace();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        logger.info(sendResult.toString());
        this.enqueueMessages.addData((MessageExt)message);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -