fix build issue

apache · Nov 27, 2021 · 6e1f934 · 6e1f934
1 parent 77c116d
commit 6e1f934
Showing 1 changed file with 12 additions and 7 deletions.
diff --git a/...nnector-rocketmq/src/test/java/org/apache/rocketmq/producer/RocketMQProducerImplTest.java b/...nnector-rocketmq/src/test/java/org/apache/rocketmq/producer/RocketMQProducerImplTest.java
@@ -27,8 +27,6 @@
 
 
 public class RocketMQProducerImplTest {
-
-	private String topicName = "test-it";
 
     @Before
     public void before() {}
@@ -41,13 +39,20 @@ public void after() {
 
     @Test
     public void testCreate_OK() {
-
-    	MeshMQProducer meshMQProducer = new RocketMQProducerImpl(); 
+            	    	
+    	MeshMQProducer meshMQProducer = new RocketMQProducerImpl();
     	try {    		
-    		meshMQProducer.createTopic(topicName);    		
-    		Assert.assertTrue("Topic was created successfully", true);
+    		meshMQProducer.createTopic("");    		
+    		Assert.assertTrue("Failed to detect empty topic", false);
     	} catch (OMSRuntimeException e) { 
-    		Assert.assertTrue(e.getMessage(), false);
+    		Assert.assertTrue("Successfully detected empty topic", true);
+    	}
+
+    	try {    		
+    		meshMQProducer.createTopic(null);    		
+    		Assert.assertTrue("Failed to detect null topic", false);
+    	} catch (OMSRuntimeException e) { 
+    		Assert.assertTrue("Successfully detected null topic", true);
     	}
 
     }