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
commit a1d120018304316e170a37d9fd2c7506a977ab68 Author: Yuchen Li <[email protected]> AuthorDate: Fri Aug 2 00:31:12 2019 +0800 Delete ReplicatorTest.java --- .../rocketmq/connect/jdbc/ReplicatorTest.java | 74 ---------------------- 1 file changed, 74 deletions(-) diff --git a/src/test/java/org/apache/rocketmq/connect/jdbc/ReplicatorTest.java b/src/test/java/org/apache/rocketmq/connect/jdbc/ReplicatorTest.java deleted file mode 100644 index 88d5586..0000000 --- a/src/test/java/org/apache/rocketmq/connect/jdbc/ReplicatorTest.java +++ /dev/null @@ -1,74 +0,0 @@ -///* -// * Licensed to the Apache Software Foundation (ASF) under one or more -// * contributor license agreements. See the NOTICE file distributed with -// * this work for additional information regarding copyright ownership. -// * The ASF licenses this file to You under the Apache License, Version 2.0 -// * (the "License"); you may not use this file except in compliance with -// * the License. You may obtain a copy of the License at -// * -// * http://www.apache.org/licenses/LICENSE-2.0 -// * -// * Unless required by applicable law or agreed to in writing, software -// * distributed under the License is distributed on an "AS IS" BASIS, -// * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -// * See the License for the specific language governing permissions and -// * limitations under the License. -// */ -// -//package org.apache.rocketmq.connect.jms; -// -//import java.lang.reflect.Field; -// -//import javax.jms.Message; -// -//import org.apache.activemq.command.ActiveMQTextMessage; -//import org.apache.rocketmq.connect.jms.pattern.PatternProcessor; -//import org.junit.Before; -//import org.junit.Test; -//import org.mockito.Mockito; -// -//import org.junit.Assert; -// -//public class ReplicatorTest { -// -// Replicator replicator; -// -// PatternProcessor patternProcessor; -// -// Config config; -// -// @Before -// public void before() throws IllegalArgumentException, IllegalAccessException, NoSuchFieldException, SecurityException { -// config = new Config(); -// replicator = new Replicator(config,null); -// -// patternProcessor = Mockito.mock(PatternProcessor.class); -// -// Field processor = Replicator.class.getDeclaredField("processor"); -// processor.setAccessible(true); -// processor.set(replicator, patternProcessor); -// } -// -// @Test(expected = RuntimeException.class) -// public void startTest() throws Exception { -// replicator.start(); -// } -// -// @Test -// public void stop() throws Exception { -// replicator.stop(); -// Mockito.verify(patternProcessor, Mockito.times(1)).stop(); -// } -// -// @Test -// public void commitAddGetQueueTest() { -// Message message = new ActiveMQTextMessage(); -// replicator.commit(message, false); -// Assert.assertEquals(replicator.getQueue().poll(), message); -// } -// -// @Test -// public void getConfigTest() { -// Assert.assertEquals(replicator.getConfig(), config); -// } -//}
