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/17 21:45:45 UTC
[02/15] git commit: STREAMS-83 | Updated test providers with new
mehtod
STREAMS-83 | Updated test providers with new mehtod
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/a8ae1937
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/a8ae1937
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/a8ae1937
Branch: refs/heads/master
Commit: a8ae1937f921549ed69b11d644ee3157185495c0
Parents: 92d8d86
Author: mfranklin <mf...@apache.org>
Authored: Thu Jun 12 10:50:35 2014 -0500
Committer: mfranklin <mf...@apache.org>
Committed: Thu Jun 12 10:50:35 2014 -0500
----------------------------------------------------------------------
.../streams/local/test/providers/EmptyResultSetProvider.java | 5 +++++
.../streams/local/test/providers/NumericMessageProvider.java | 5 +++++
.../org/apache/streams/test/component/FileReaderProvider.java | 5 +++++
3 files changed, 15 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/a8ae1937/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/providers/EmptyResultSetProvider.java
----------------------------------------------------------------------
diff --git a/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/providers/EmptyResultSetProvider.java b/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/providers/EmptyResultSetProvider.java
index d8dc4eb..fe60295 100644
--- a/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/providers/EmptyResultSetProvider.java
+++ b/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/providers/EmptyResultSetProvider.java
@@ -52,6 +52,11 @@ public class EmptyResultSetProvider implements StreamsProvider {
}
@Override
+ public boolean isRunning() {
+ return false;
+ }
+
+ @Override
public void prepare(Object configurationObject) {
//NOP
}
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/a8ae1937/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/providers/NumericMessageProvider.java
----------------------------------------------------------------------
diff --git a/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/providers/NumericMessageProvider.java b/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/providers/NumericMessageProvider.java
index 987c680..159355d 100644
--- a/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/providers/NumericMessageProvider.java
+++ b/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/local/test/providers/NumericMessageProvider.java
@@ -59,6 +59,11 @@ public class NumericMessageProvider implements StreamsProvider {
}
@Override
+ public boolean isRunning() {
+ return false;
+ }
+
+ @Override
public void prepare(Object configurationObject) {
}
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/a8ae1937/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/test/component/FileReaderProvider.java
----------------------------------------------------------------------
diff --git a/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/test/component/FileReaderProvider.java b/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/test/component/FileReaderProvider.java
index 3f84c81..9c1ae97 100644
--- a/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/test/component/FileReaderProvider.java
+++ b/streams-runtimes/streams-runtime-local/src/test/java/org/apache/streams/test/component/FileReaderProvider.java
@@ -72,6 +72,11 @@ public class FileReaderProvider implements StreamsProvider {
}
@Override
+ public boolean isRunning() {
+ return this.scanner.hasNextLine();
+ }
+
+ @Override
public void prepare(Object configurationObject) {
this.scanner = new Scanner(FileReaderProvider.class.getResourceAsStream(this.fileName));
}