Fix transaction writer thread exit bug (#102)

* transactionWriter exit bug fix

* bind the writerTransaction close into the orlistener close function

Author: buptyzc

databus2-relay/databus2-event-producer-or/src/main/java/com/linkedin/databus2/producers/ORListener.java

@@ -716,9 +716,16 @@ else if (event instanceof TableMapEvent)
     _log.info("ORListener Thread done");
     doShutdownNotify();
   }
-  
-  public TransactionWriter getTransactionWriter() 
+
+  public void shutdownAll()
   {
-	return _transactionWriter;
+    if(this.isAlive())
+    {
+      this.shutdown();
+    }
+    if (_transactionWriter != null && _transactionWriter.isAlive())
+    {
+      _transactionWriter.shutdown();
+    }
   }
 }

databus2-relay/databus2-event-producer-or/src/main/java/com/linkedin/databus2/producers/OpenReplicatorEventProducer.java

@@ -413,10 +413,7 @@ public void run()
           try
           {
             //should stop orListener first to get the final maxScn used for init open replicator.
-            if (_orListener.isAlive())
-            {
-              _orListener.shutdown();
-            }
+            _orListener.shutdownAll();
             long maxScn = _maxSCNReaderWriter.getMaxScn();
             _startPrevScn.set(maxScn);
             initOpenReplicator(maxScn);
@@ -462,14 +459,7 @@ public void run()
           _log.error("failed to stop Open Replicator", e);
         }
       }
-      if (_orListener.isAlive())
-      {
-        _orListener.shutdown();
-      }
-      if (_orListener.getTransactionWriter().isAlive())
-      {
-    	_orListener.getTransactionWriter().shutdown();
-      }
+      _orListener.shutdownAll();
 
       _log.info("Event Producer Thread done");
       doShutdownNotify();

databus2-relay/databus2-event-producer-or/src/main/java/com/linkedin/databus2/producers/TransactionWriter.java

@@ -115,6 +115,8 @@ public void run()
         }
       }
     }
+    log.info("transactionWriter thread done!");
+    doShutdownNotify();
   }
 
 }