add LICENSE.

duxinglangzi

2022-09-06 ed3a1614384279b7d3a97e7411b649476a934ddb

 src/main/java/com/duxinglangzi/canal/starter/factory/CanalConnectorFactory.java

@@ -15,6 +15,14 @@


public class CanalConnectorFactory {



    /**

     * 创建 CanalConnector

     *

     * @param destination

     * @param endpointInstance

     * @return CanalConnector

     * @author wuqiong 2022-04-23 20:36

     */

    public static synchronized CanalConnector createConnector(

            String destination, CanalAutoConfigurationProperties.EndpointInstance endpointInstance) {

        Assert.isTrue(StringUtils.hasText(destination), "destination is null , please check ");