mock test

Bughue · Mar 1, 2024 · 30bef40 · 30bef40
1 parent 345baad
commit 30bef40
Showing 1 changed file with 13 additions and 3 deletions.
diff --git a/test/src/test/java/org/apache/seata/rocketmq/SeataMQProducerSendTest.java b/test/src/test/java/org/apache/seata/rocketmq/SeataMQProducerSendTest.java
@@ -55,15 +55,25 @@ public static void after() {
     }
 
     @Test
-    public void testSend() throws MQBrokerException, RemotingException, InterruptedException, MQClientException, TransactionException {
+    public void testSendCommit() throws MQBrokerException, RemotingException, InterruptedException, MQClientException, TransactionException {
         TransactionManager tm = TmClientTest.getTm();
 
-        SeataMQProducer producer = SeataMQProducerFactory.createSingle("10.213.3.25:9876", "test");
-        producer.send(new Message("Topic--AA", "testMessage".getBytes(StandardCharsets.UTF_8)));
+        SeataMQProducer producer = SeataMQProducerFactory.createSingle("yourIp:9876", "test");
+        producer.send(new Message("yourTopic", "testMessage".getBytes(StandardCharsets.UTF_8)));
 
         tm.commit(RootContext.getXID());
     }
 
+    @Test
+    public void testSendRollback() throws MQBrokerException, RemotingException, InterruptedException, MQClientException, TransactionException {
+        TransactionManager tm = TmClientTest.getTm();
+
+        SeataMQProducer producer = SeataMQProducerFactory.createSingle("yourIp:9876", "test");
+        producer.send(new Message("yourTopic", "testMessage".getBytes(StandardCharsets.UTF_8)));
+
+        tm.rollback(RootContext.getXID());
+    }
+
 
     private static TransactionManager getTmAndBegin() throws TransactionException {
         String app = ProtocolTestConstants.APPLICATION_ID;