[rocketmq-connect] branch master updated: [ISSUE #29]Fix error: ActivemqSourceTaskTest build error (#30)

[zhoubo]

This is an automated email from the ASF dual-hosted git repository.

zhoubo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git


The following commit(s) were added to refs/heads/master by this push:
     new b993021  [ISSUE #29]Fix error: ActivemqSourceTaskTest build error (#30)
b993021 is described below

commit b993021ed6985a0446361434f1dc69d33eea0eae
Author: xiaoxin <96671314+doubledim...@users.noreply.github.com>
AuthorDate: Fri Mar 25 17:02:27 2022 +0800

    [ISSUE #29]Fix error: ActivemqSourceTaskTest build error (#30)
---
 .../connect/activemq/connector/ActivemqSourceTaskTest.java   | 12 ++++++------
 .../connect/redis/connector/RedisSourceConnector.java        |  8 ++++++--
 2 files changed, 12 insertions(+), 8 deletions(-)

diff --git 
a/connectors/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceTaskTest.java
 
b/connectors/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceTaskTest.java
index a71050c..049496d 100644
--- 
a/connectors/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceTaskTest.java
+++ 
b/connectors/rocketmq-connect-activemq/src/test/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceTaskTest.java
@@ -129,23 +129,23 @@ public class ActivemqSourceTaskTest {
         ActivemqSourceTask task = new ActivemqSourceTask();
         TextMessage textMessage = new ActiveMQTextMessage();
         textMessage.setText(value);
-        ByteBuffer buffer = task.getMessageConnent(textMessage);
+        ByteBuffer buffer = task.getMessageContent(textMessage);
         Assert.assertEquals(new String(buffer.array()), textMessage.getText());
 
         ObjectMessage objectMessage = new ActiveMQObjectMessage();
         objectMessage.setObject(value);
-        buffer = task.getMessageConnent(objectMessage);
+        buffer = task.getMessageContent(objectMessage);
         Assert.assertEquals(new String(buffer.array()), "\"" + 
objectMessage.getObject().toString() + "\"");
 
         BytesMessage bytes = new ActiveMQBytesMessage();
         bytes.writeBytes(value.getBytes());
         bytes.reset();
-        buffer = task.getMessageConnent(bytes);
+        buffer = task.getMessageContent(bytes);
         Assert.assertEquals(new String(buffer.array()), value);
 
         MapMessage mapMessage = new ActiveMQMapMessage();
         mapMessage.setString("hello", "rocketmq");
-        buffer = task.getMessageConnent(mapMessage);
+        buffer = task.getMessageContent(mapMessage);
         Map<String, String> map = JSON.parseObject(buffer.array(), Map.class);
         Assert.assertEquals(map.get("hello"), "rocketmq");
         Assert.assertEquals(map.size(), 1);
@@ -157,9 +157,9 @@ public class ActivemqSourceTaskTest {
         }
         streamMessage.writeBytes(valueTwo.getBytes());
         streamMessage.reset();
-        buffer = task.getMessageConnent(streamMessage);
+        buffer = task.getMessageContent(streamMessage);
         Assert.assertEquals(new String(buffer.array()), valueTwo);
 
-        task.getMessageConnent(null);
+        task.getMessageContent(null);
     }
 }
diff --git 
a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/connector/RedisSourceConnector.java
 
b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/connector/RedisSourceConnector.java
index fde9f92..aadc585 100644
--- 
a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/connector/RedisSourceConnector.java
+++ 
b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/connector/RedisSourceConnector.java
@@ -19,13 +19,17 @@ package org.apache.rocketmq.connect.redis.connector;
 
 import java.util.ArrayList;
 import java.util.List;
-
 import io.openmessaging.KeyValue;
 import io.openmessaging.connector.api.Task;
 import io.openmessaging.connector.api.source.SourceConnector;
 import org.apache.rocketmq.connect.redis.common.Config;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 public class RedisSourceConnector extends SourceConnector {
+
+    private static final Logger LOGGER = 
LoggerFactory.getLogger(RedisSourceConnector.class);
+
     private KeyValue keyValue;
 
     @Override public String verifyAndSetConfig(KeyValue keyValue) {
@@ -38,7 +42,7 @@ public class RedisSourceConnector extends SourceConnector {
     }
 
     @Override public void start() {
-
+        LOGGER.info("the redis source start...");
     }