[rocketmq-connect] 12/43: Delete ReplicatorTest.java

[zh...@apache.org]

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 <yu...@126.com>
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);
-//    }
-//}