Adjust timing; clean up suppresswarnings

Author: Abacn

sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsReadSchemaTransformProvider.java

@@ -41,9 +41,6 @@
 import org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.base.Preconditions;
 import org.joda.time.Duration;
 
-@SuppressWarnings({
-  "nullness" // TODO(https://github.com/apache/beam/issues/20497)
-})
 @AutoService(SchemaTransformProvider.class)
 public class JmsReadSchemaTransformProvider
     extends TypedSchemaTransformProvider<ReadConfiguration> {

sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsWriteSchemaTransformProvider.java

@@ -41,9 +41,6 @@
 import org.apache.beam.sdk.values.Row;
 import org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.base.Preconditions;
 
-@SuppressWarnings({
-  "nullness" // TODO(https://github.com/apache/beam/issues/20497)
-})
 @AutoService(SchemaTransformProvider.class)
 public class JmsWriteSchemaTransformProvider
     extends TypedSchemaTransformProvider<WriteConfiguration> {

sdks/python/apache_beam/io/external/xlang_jmsio_it_test.py

@@ -197,8 +197,8 @@ def subscribe():
               connection_configuration=self._connection_configuration(
                   connection_param),
               queue=sink_queue))
-      result = p.run()
       publisher.start()
+      result = p.run()
       subscriber.start()
       try:
         subscriber.join(timeout=90)  # 1.5 min