wanghongfei / gae-das Goto Github PK

/**
* 发送HTTP请求报告自己binlog位置
* @param binlog
* @param pos
* @return true表示自己可成为master, fales表示不可成为master
*/
private boolean sendReport(String binlog, long pos) {
BeatMessage msg = BeatMessage.Builder.buildReport(binlog, pos);

    HttpPost post = new HttpPost("http://" + peerHost + ":" + peerPort);

DemoTableListener
private FileSender store; -----> private DasSender store;

可以考虑一下兼容
EXT_WRITE_ROWS,
/**
* Describes updated rows (within a single table).
* Used in case of RBR (5.1.18+).
/
EXT_UPDATE_ROWS,
/*
* Describes deleted rows (within a single table).
* Used in case of RBR (5.1.18+).
*/
EXT_DELETE_ROWS,