File tree Expand file tree Collapse file tree 2 files changed +3
-7
lines changed
sdks/java/io/solace/src/main/java/org/apache/beam/sdk/io/solace/broker Expand file tree Collapse file tree 2 files changed +3
-7
lines changed Original file line number Diff line number Diff line change @@ -139,10 +139,6 @@ private MessageProducer createXMLMessageProducer(SubmissionMode submissionMode)
139139 }
140140
141141 private MessageReceiver createFlowReceiver () throws JCSMPException , IOException {
142- if (isClosed ()) {
143- connectReadSession ();
144- }
145-
146142 Queue queue = checkStateNotNull (queue (), "SolaceIO.Read: Queue is not set." );
147143
148144 ConsumerFlowProperties flowProperties = new ConsumerFlowProperties ();
Original file line number Diff line number Diff line change @@ -77,7 +77,7 @@ public abstract class SessionServiceFactory implements Serializable {
7777 public abstract SessionService create ();
7878
7979 /**
80- * Do not override. This method is called in the {@link
80+ * This method is called in the {@link
8181 * org.apache.beam.sdk.io.solace.SolaceIO.Read#expand(org.apache.beam.sdk.values.PBegin)} method
8282 * to set the Queue reference based on {@link
8383 * org.apache.beam.sdk.io.solace.SolaceIO.Read#from(Solace.Queue)} or {@link
@@ -90,8 +90,8 @@ public final void setQueue(Queue queue) {
9090 }
9191
9292 /**
93- * Getter for the queue. Do not override. This is nullable, because at the construction time this
94- * reference is null. Once the pipeline is compiled and the {@link
93+ * Getter for the queue. This is nullable, because at the construction time this reference is
94+ * null. Once the pipeline is compiled and the {@link
9595 * org.apache.beam.sdk.io.solace.SolaceIO.Read#expand(org.apache.beam.sdk.values.PBegin)} method
9696 * is called, this reference is valid.
9797 *
You can’t perform that action at this time.
0 commit comments