From 77c116d7f9c553f52275a871910c7901b74fe1bc Mon Sep 17 00:00:00 2001 From: Yu Zhao 00540916 Date: Wed, 22 Sep 2021 13:55:07 -0400 Subject: [PATCH] fix build and add createtopic method to standalone module --- .../rocketmq/producer/RocketMQProducerImplTest.java | 12 +++++------- .../producer/StandaloneMeshMQProducerAdaptor.java | 8 ++++++++ 2 files changed, 13 insertions(+), 7 deletions(-) diff --git a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/producer/RocketMQProducerImplTest.java b/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/producer/RocketMQProducerImplTest.java index 99b3b11e15..ae436527a3 100644 --- a/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/producer/RocketMQProducerImplTest.java +++ b/eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/producer/RocketMQProducerImplTest.java @@ -17,17 +17,15 @@ package org.apache.rocketmq.producer; -import static org.junit.Assert.assertTrue; import io.openmessaging.api.exception.OMSRuntimeException; import org.apache.eventmesh.api.producer.MeshMQProducer; import org.apache.eventmesh.connector.rocketmq.producer.RocketMQProducerImpl; import org.junit.After; +import org.junit.Assert; import org.junit.Before; import org.junit.Test; -import org.junit.runner.RunWith; -import org.mockito.junit.MockitoJUnitRunner; -@RunWith(MockitoJUnitRunner.class) + public class RocketMQProducerImplTest { private String topicName = "test-it"; @@ -46,10 +44,10 @@ public void testCreate_OK() { MeshMQProducer meshMQProducer = new RocketMQProducerImpl(); try { - meshMQProducer.createTopic(topicName); - assertTrue("Topic was created successfully", true); + meshMQProducer.createTopic(topicName); + Assert.assertTrue("Topic was created successfully", true); } catch (OMSRuntimeException e) { - assertTrue(e.getMessage(), false); + Assert.assertTrue(e.getMessage(), false); } } diff --git a/eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/producer/StandaloneMeshMQProducerAdaptor.java b/eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/producer/StandaloneMeshMQProducerAdaptor.java index fb632c7c5c..b6318ae28d 100644 --- a/eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/producer/StandaloneMeshMQProducerAdaptor.java +++ b/eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/producer/StandaloneMeshMQProducerAdaptor.java @@ -21,6 +21,8 @@ import io.openmessaging.api.MessageBuilder; import io.openmessaging.api.SendCallback; import io.openmessaging.api.SendResult; +import io.openmessaging.api.exception.OMSRuntimeException; + import org.apache.eventmesh.api.RRCallback; import org.apache.eventmesh.api.producer.MeshMQProducer; import org.apache.eventmesh.connector.standalone.MessagingAccessPointImpl; @@ -122,4 +124,10 @@ public void shutdown() { public MessageBuilder messageBuilder() { return null; } + + @Override + public void createTopic(String topicName) throws OMSRuntimeException { + // TODO Auto-generated method stub + + } }