You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by dh...@apache.org on 2016/09/13 00:40:42 UTC
[11/50] [abbrv] incubator-beam git commit: [BEAM-569] Define
maxNumRecords default value to Long.MAX_VALUE in JmsIO
[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/8007bdf5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8007bdf5
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/8007bdf5
Branch: refs/heads/gearpump-runner
Commit: 8007bdf5c3e1d3ee0c2c697e049549e9742442aa
Parents: 00b4e95
Author: Jean-Baptiste Onofr� <jb...@apache.org>
Authored: Sat Aug 27 14:01:34 2016 +0200
Committer: Dan Halperin <dh...@google.com>
Committed: Mon Sep 12 17:40:11 2016 -0700
----------------------------------------------------------------------
.../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/8007bdf5/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;