Remove unnecessary Serializable annotation.

apache · Sep 16, 2024 · e545ec9 · e545ec9
1 parent 0389117
commit e545ec9
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 5 deletions.
diff --git a/...lace/src/main/java/org/apache/beam/sdk/io/solace/broker/BasicAuthJcsmpSessionService.java b/...lace/src/main/java/org/apache/beam/sdk/io/solace/broker/BasicAuthJcsmpSessionService.java
@@ -80,9 +80,9 @@ public abstract static class Builder {
     public abstract BasicAuthJcsmpSessionService build();
   }
 
-  @Nullable private JCSMPSession jcsmpSession;
-  @Nullable private MessageReceiver messageReceiver;
-  @Nullable private MessageProducer messageProducer;
+  @Nullable private transient JCSMPSession jcsmpSession;
+  @Nullable private transient MessageReceiver messageReceiver;
+  @Nullable private transient MessageProducer messageProducer;
   private final RetryCallableManager retryCallableManager = RetryCallableManager.create();
 
   @Override

diff --git a/sdks/java/io/solace/src/main/java/org/apache/beam/sdk/io/solace/broker/MessageReceiver.java b/sdks/java/io/solace/src/main/java/org/apache/beam/sdk/io/solace/broker/MessageReceiver.java
@@ -19,15 +19,14 @@
 
 import com.solacesystems.jcsmp.BytesXMLMessage;
 import java.io.IOException;
-import java.io.Serializable;
 
 /**
  * Interface for receiving messages from a Solace broker.
  *
  * <p>Implementations of this interface are responsible for managing the connection to the broker
  * and for receiving messages from the broker.
  */
-public interface MessageReceiver extends Serializable {
+public interface MessageReceiver {
   /**
    * Starts the message receiver.
    *