Skip to content

Commit c7a873c

Browse files
committed
Remove 'serializable'
1 parent eba116e commit c7a873c

File tree

3 files changed

+3
-4
lines changed

3 files changed

+3
-4
lines changed

sdks/java/io/solace/src/main/java/org/apache/beam/sdk/io/solace/broker/SempBasicAuthClientExecutor.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -56,7 +56,7 @@
5656
* response is 401 Unauthorized, the client will execute an additional request with Basic Auth
5757
* header to refresh the token.
5858
*/
59-
public class SempBasicAuthClientExecutor implements Serializable {
59+
public class SempBasicAuthClientExecutor {
6060
// Every request will be repeated 2 times in case of abnormal connection failures.
6161
private static final int REQUEST_NUM_RETRIES = 2;
6262
private static final Map<CookieManagerKey, CookieManager> COOKIE_MANAGER_MAP =

sdks/java/io/solace/src/main/java/org/apache/beam/sdk/io/solace/broker/SempClient.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,14 +19,13 @@
1919

2020
import com.solacesystems.jcsmp.Queue;
2121
import java.io.IOException;
22-
import java.io.Serializable;
2322

2423
/**
2524
* This interface defines methods for interacting with a Solace message broker using the Solace
2625
* Element Management Protocol (SEMP). SEMP provides a way to manage and monitor various aspects of
2726
* the broker, including queues and topics.
2827
*/
29-
public interface SempClient extends Serializable {
28+
public interface SempClient {
3029

3130
/**
3231
* Determines if the specified queue is non-exclusive. In Solace, non-exclusive queues allow

sdks/java/io/solace/src/test/java/org/apache/beam/sdk/io/solace/it/BasicAuthMultipleSempClient.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@
2929
* Example class showing how the {@link BasicAuthSempClient} can be extended or have functionalities
3030
* overridden. In this case, the modified method is {@link
3131
* BasicAuthSempClient#getBacklogBytes(String)}, which queries multiple SEMP endpoints to collect
32-
* acurrate backlog metrics. For usage, see {@link SolaceIOMultipleSempIT}.
32+
* accurate backlog metrics. For usage, see {@link SolaceIOMultipleSempIT}.
3333
*/
3434
public class BasicAuthMultipleSempClient extends BasicAuthSempClient {
3535
private final List<SempBasicAuthClientExecutor> sempBacklogBasicAuthClientExecutors;

0 commit comments

Comments
 (0)