From 857af9b9cbddbb7b876ea7f956d5308aefb34240 Mon Sep 17 00:00:00 2001 From: Chris Bono Date: Tue, 26 Sep 2023 17:35:20 -0500 Subject: [PATCH] Make PulsarClientProxy package protected (#459) --- .../reactive/core/DefaultReactivePulsarSenderFactory.java | 8 +++----- .../springframework/pulsar/core/PulsarClientProxy.java | 2 +- 2 files changed, 4 insertions(+), 6 deletions(-) diff --git a/spring-pulsar-reactive/src/main/java/org/springframework/pulsar/reactive/core/DefaultReactivePulsarSenderFactory.java b/spring-pulsar-reactive/src/main/java/org/springframework/pulsar/reactive/core/DefaultReactivePulsarSenderFactory.java index a58f10eb..a349bbca 100644 --- a/spring-pulsar-reactive/src/main/java/org/springframework/pulsar/reactive/core/DefaultReactivePulsarSenderFactory.java +++ b/spring-pulsar-reactive/src/main/java/org/springframework/pulsar/reactive/core/DefaultReactivePulsarSenderFactory.java @@ -32,7 +32,6 @@ import org.apache.pulsar.reactive.client.api.ReactivePulsarClient; import org.springframework.core.log.LogAccessor; import org.springframework.lang.Nullable; import org.springframework.pulsar.core.DefaultTopicResolver; -import org.springframework.pulsar.core.PulsarClientProxy; import org.springframework.pulsar.core.TopicResolver; import org.springframework.util.Assert; import org.springframework.util.CollectionUtils; @@ -149,12 +148,11 @@ public final class DefaultReactivePulsarSenderFactory /** * Return the phase that this lifecycle object is supposed to run in. *

- * This component has a phase that comes after the {@link PulsarClientProxy - * restartable client} but before other lifecycle and smart lifecycle components whose - * phase values are "0" and "max", respectively. + * This component has a phase that comes after the restartable client + * ({@code PulsarClientProxy}) but before other lifecycle and smart lifecycle + * components whose phase values are "0" and "max", respectively. * @return a phase that is after the restartable client and before other default * components. - * @see PulsarClientProxy#getPhase() */ @Override public int getPhase() { diff --git a/spring-pulsar/src/main/java/org/springframework/pulsar/core/PulsarClientProxy.java b/spring-pulsar/src/main/java/org/springframework/pulsar/core/PulsarClientProxy.java index ad087810..85227b7b 100644 --- a/spring-pulsar/src/main/java/org/springframework/pulsar/core/PulsarClientProxy.java +++ b/spring-pulsar/src/main/java/org/springframework/pulsar/core/PulsarClientProxy.java @@ -44,7 +44,7 @@ import org.springframework.util.Assert; * * @author Chris Bono */ -public final class PulsarClientProxy extends RestartableSingletonFactory implements PulsarClient { +final class PulsarClientProxy extends RestartableSingletonFactory implements PulsarClient { private static final int LIFECYCLE_PHASE = (Integer.MIN_VALUE / 2) - 200;