Merge pull request #56 from andyqzb/master

override isRunning and isPaused method to fixbug shutdown open replicator

Author: chavdar

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

@@ -510,6 +510,23 @@ protected ReadEventCycleSummary readEventsFromAllSources(long sinceSCN) throws D
     throw new RuntimeException("Not supported !!");
   }
 
+  /* (non-Javadoc)
+   * @see com.linkedin.databus2.producers.AbstractEventProducer#isPaused()
+   */
+  @Override
+  public synchronized boolean isPaused()
+  {
+    return _producerThread.isPauseRequested();
+  }
+
+  /* (non-Javadoc)
+   * @see com.linkedin.databus2.producers.AbstractEventProducer#isRunning()
+   */
+  @Override
+  public synchronized boolean isRunning()
+  {
+    return !_producerThread.isShutdownRequested() && !_producerThread.isPauseRequested();
+  }
 
   /* (non-Javadoc)
    * @see com.linkedin.databus2.producers.AbstractEventProducer#unpause()