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/06/26 21:02:48 UTC
git commit: Removed extra sleep
Repository: incubator-streams
Updated Branches:
refs/heads/master 0705b261d -> 34c95a686
Removed extra sleep
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/34c95a68
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/34c95a68
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/34c95a68
Branch: refs/heads/master
Commit: 34c95a6863d59e7628a7017d38ec5d40f8528c46
Parents: 0705b26
Author: mfranklin <mf...@apache.org>
Authored: Thu Jun 26 15:02:22 2014 -0400
Committer: mfranklin <mf...@apache.org>
Committed: Thu Jun 26 15:02:22 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/34c95a68/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 6bb30f8..946572a 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
@@ -88,7 +88,6 @@ public class SysomosHeartbeatStream implements Runnable {
mostCurrentId = result.getCurrentId();
}
updateOffset(result);
- sleep();
} while (offsetCount > 0);
updateState(result, mostCurrentId);