FilesExpand file tree

master

/

Main.java

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

35 lines (30 loc) · 940 Bytes

master

/

Main.java

Copy path

Top

File metadata and controls

• Code
• Blame

35 lines (30 loc) · 940 Bytes

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

package canal_qbus;

import java.lang.Thread;

import java.util.ArrayList;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

public class Main {

private static Logger logger;

private static MysqlQueue q;

public static void main(String args[]) {

String cfgFile = "./conf/canal-qbus.json";

try {

Config.init(cfgFile);

Log.init();

} catch (Exception e) {

System.out.println("[" + cfgFile + "], failed to load config file, error:" + e.getMessage());

return;

}

Router.init();

q = new MysqlQueue();

logger = LoggerFactory.getLogger(Main.class);

Runtime.getRuntime().addShutdownHook(new Thread() {

public void run() {

logger.info("shut down by KILL ....");

//q.Stop();

}

});

q.Start();

logger.info("here we go");

}

}