Repository: incubator-beam Updated Branches: refs/heads/master 92451d071 -> 33d747efa
[BEAM-569] Define maxNumRecords default value to Long.MAX_VALUE in JmsIO Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/800c0987 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/800c0987 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/800c0987 Branch: refs/heads/master Commit: 800c09870a732a71c897705fbecdedec4a961804 Parents: 92451d0 Author: Jean-Baptiste Onofré <[email protected]> Authored: Sat Aug 27 14:01:34 2016 +0200 Committer: Jean-Baptiste Onofré <[email protected]> Committed: Tue Aug 30 21:46:33 2016 +0200 ---------------------------------------------------------------------- .../jms/src/main/java/org/apache/beam/sdk/io/jms/JmsIO.java | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/800c0987/sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsIO.java ---------------------------------------------------------------------- diff --git a/sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsIO.java b/sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsIO.java index 29d0c5f..3107aab 100644 --- a/sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsIO.java +++ b/sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsIO.java @@ -101,11 +101,11 @@ public class JmsIO { private static final Logger LOG = LoggerFactory.getLogger(JmsIO.class); public static Read read() { - return new Read(); + return new Read(null, null, null, Long.MAX_VALUE, null); } public static Write write() { - return new Write(); + return new Write(null, null, null); } /** @@ -185,8 +185,6 @@ public class JmsIO { protected long maxNumRecords; protected Duration maxReadTime; - private Read() {} - private Read( ConnectionFactory connectionFactory, String queue, @@ -428,8 +426,6 @@ public class JmsIO { return new Write(connectionFactory, queue, topic); } - private Write() {} - private Write(ConnectionFactory connectionFactory, String queue, String topic) { this.connectionFactory = connectionFactory; this.queue = queue;
