Exposed underlying connection id

Author: shyiko

src/main/java/com/github/shyiko/mysql/binlog/BinaryLogClient.java

@@ -88,6 +88,7 @@ public class BinaryLogClient implements BinaryLogClientMXBean {
     private long serverId = 65535;
     private volatile String binlogFilename;
     private volatile long binlogPosition = 4;
+    private volatile long connectionId;
 
     private GtidSet gtidSet;
     private final Object gtidSetAccessLock = new Object();
@@ -212,6 +213,13 @@ public void setBinlogPosition(long binlogPosition) {
         this.binlogPosition = binlogPosition;
     }
 
+    /**
+     * @return thread id
+     */
+    public long getConnectionId() {
+        return connectionId;
+    }
+
     /**
      * @return GTID set. Note that this value changes with each received GTID event (provided client is in GTID mode).
      * @see #setGtidSet(String)
@@ -359,9 +367,10 @@ public void connect() throws IOException {
             throw e;
         }
         connected = true;
+        connectionId = greetingPacket.getThreadId();
         if (logger.isLoggable(Level.INFO)) {
             logger.info("Connected to " + hostname + ":" + port + " at " + binlogFilename + "/" + binlogPosition +
-                " (sid:" + serverId + ", cid:" + greetingPacket.getThreadId() + ")");
+                " (sid:" + serverId + ", cid:" + connectionId + ")");
         }
         synchronized (lifecycleListeners) {
             for (LifecycleListener lifecycleListener : lifecycleListeners) {