You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by mf...@apache.org on 2014/07/14 15:03:17 UTC

git commit: STREAMS-131 | Fixed incorrect closing of Sysomos reader task

Repository: incubator-streams
Updated Branches:
  refs/heads/STREAMS-131 d41890d9a -> c343a1b00


STREAMS-131 | Fixed incorrect closing of Sysomos reader task


Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/c343a1b0
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/c343a1b0
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/c343a1b0

Branch: refs/heads/STREAMS-131
Commit: c343a1b0063eeaac8f08ee84cc4fafcc5923d266
Parents: d41890d
Author: mfranklin <mf...@apache.org>
Authored: Mon Jul 14 09:02:46 2014 -0400
Committer: mfranklin <mf...@apache.org>
Committed: Mon Jul 14 09:02:46 2014 -0400

----------------------------------------------------------------------
 .../org/apache/streams/sysomos/provider/SysomosHeartbeatStream.java | 1 -
 1 file changed, 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/c343a1b0/streams-contrib/streams-provider-sysomos/src/main/java/org/apache/streams/sysomos/provider/SysomosHeartbeatStream.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-provider-sysomos/src/main/java/org/apache/streams/sysomos/provider/SysomosHeartbeatStream.java b/streams-contrib/streams-provider-sysomos/src/main/java/org/apache/streams/sysomos/provider/SysomosHeartbeatStream.java
index 1dde4fa..3478671 100644
--- a/streams-contrib/streams-provider-sysomos/src/main/java/org/apache/streams/sysomos/provider/SysomosHeartbeatStream.java
+++ b/streams-contrib/streams-provider-sysomos/src/main/java/org/apache/streams/sysomos/provider/SysomosHeartbeatStream.java
@@ -79,7 +79,6 @@ public class SysomosHeartbeatStream implements Runnable {
             executeRun();
         } catch (Exception e) {
             LOGGER.error("Error executing heartbeat stream", e);
-        } finally {
             shutdown();
         }
     }