You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2015/04/03 16:38:12 UTC
[08/13] storm git commit: Code cleanup in mocking storm-starter tests
Code cleanup in mocking storm-starter tests
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/401ebebd
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/401ebebd
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/401ebebd
Branch: refs/heads/master
Commit: 401ebebdf8b201b87ff944cc3c2217cc30acd1fc
Parents: 4e7a7e1
Author: Niels Basjes <ni...@basjes.nl>
Authored: Tue Dec 9 14:00:33 2014 +0100
Committer: Niels Basjes <ni...@basjes.nl>
Committed: Tue Dec 9 14:00:33 2014 +0100
----------------------------------------------------------------------
.../test/jvm/storm/starter/tools/MockTupleHelpers.java | 5 ++---
1 file changed, 2 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/401ebebd/examples/storm-starter/test/jvm/storm/starter/tools/MockTupleHelpers.java
----------------------------------------------------------------------
diff --git a/examples/storm-starter/test/jvm/storm/starter/tools/MockTupleHelpers.java b/examples/storm-starter/test/jvm/storm/starter/tools/MockTupleHelpers.java
index 374288e..9e8629c 100644
--- a/examples/storm-starter/test/jvm/storm/starter/tools/MockTupleHelpers.java
+++ b/examples/storm-starter/test/jvm/storm/starter/tools/MockTupleHelpers.java
@@ -19,7 +19,6 @@ package storm.starter.tools;
import backtype.storm.Constants;
import backtype.storm.tuple.Tuple;
-import backtype.storm.tuple.TupleImpl;
import static org.mockito.Mockito.*;
@@ -39,9 +38,9 @@ public final class MockTupleHelpers {
when(tuple.isTick()).thenReturn(isTick(componentId, streamId));
return tuple;
}
-
+
private static boolean isTick(String componentId, String streamId) {
- return componentId.equals(Constants.SYSTEM_COMPONENT_ID) &&
+ return componentId.equals(Constants.SYSTEM_COMPONENT_ID) &&
streamId.equals(Constants.SYSTEM_TICK_STREAM_ID);
}