content: package com.alibaba.otter.canal.server.embedded;
  
  import java.net.InetSocketAddress;
  import java.util.Arrays;
  
  import org.I0Itec.zkclient.ZkClient;
  import org.junit.Before;
  
  import com.alibaba.otter.canal.common.zookeeper.ZookeeperPathUtils;
  import com.alibaba.otter.canal.instance.manager.model.Canal;
  import com.alibaba.otter.canal.instance.manager.model.CanalParameter;
  import com.alibaba.otter.canal.instance.manager.model.CanalParameter.HAMode;
  import com.alibaba.otter.canal.instance.manager.model.CanalParameter.IndexMode;
  import com.alibaba.otter.canal.instance.manager.model.CanalParameter.MetaMode;
  import com.alibaba.otter.canal.instance.manager.model.CanalParameter.SourcingType;
  import com.alibaba.otter.canal.instance.manager.model.CanalParameter.StorageMode;
  import org.junit.Ignore;
  
  @Ignore
  public class CanalServerWithEmbedded_StandbyTest extends BaseCanalServerWithEmbededTest {
  
      private ZkClient zkClient = new ZkClient(cluster1);
  
      @Before
      public void setUp() {
          zkClient.deleteRecursive(ZookeeperPathUtils.CANAL_ROOT_NODE);
          super.setUp();
      }
  
      protected Canal buildCanal() {
          Canal canal = new Canal();
          canal.setId(1L);
          canal.setName(DESTINATION);
          canal.setDesc("test");
  
          CanalParameter parameter = new CanalParameter();
  
          parameter.setZkClusters(Arrays.asList("127.0.0.1:2188"));
          parameter.setMetaMode(MetaMode.MIXED); // 冷备，可选择混合模式
          parameter.setHaMode(HAMode.HEARTBEAT);
          parameter.setIndexMode(IndexMode.META);// 内存版store，需要选择meta做为index
  
          parameter.setStorageMode(StorageMode.MEMORY);
          parameter.setMemoryStorageBufferSize(32 * 1024);
  
          parameter.setSourcingType(SourcingType.MYSQL);
          parameter.setDbAddresses(Arrays.asList(new InetSocketAddress(MYSQL_ADDRESS, 3306),
              new InetSocketAddress(MYSQL_ADDRESS, 3306)));
          parameter.setDbUsername(USERNAME);
          parameter.setDbPassword(PASSWORD);
          parameter.setPositions(Arrays.asList("{\"journalName\":\"mysql-bin.000001\",\"position\":6163L,\"timestamp\":1322803601000L}",
              "{\"journalName\":\"mysql-bin.000001\",\"position\":6163L,\"timestamp\":1322803601000L}"));
  
          parameter.setSlaveId(1234L);
  
          parameter.setDefaultConnectionTimeoutInSeconds(30);
          parameter.setConnectionCharset("UTF-8");
          parameter.setReceiveBufferSize(8 * 1024);
          parameter.setSendBufferSize(8 * 1024);
  
          parameter.setDetectingEnable(false);
          parameter.setDetectingIntervalInSeconds(10);
          parameter.setDetectingRetryTimes(3);
          parameter.setDetectingSQL(DETECTING_SQL);
  
          canal.setCanalParameter(parameter);
          return canal;
      }
  }
  