Spring/spring-pulsar
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Make PulsarClientProxy package protected (#459)

Browse Source
This commit is contained in:
Chris Bono
2023-09-26 17:35:20 -05:00
committed by GitHub
parent 776a7c0da8
commit 857af9b9cb
2 changed files with 4 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
spring-pulsar-reactive/src/main/java/org/springframework/pulsar/reactive/core/DefaultReactivePulsarSenderFactory.java
View File

@@ -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<T>
/**
* Return the phase that this lifecycle object is supposed to run in.
* <p>
* 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 &quot;0&quot; and &quot;max&quot;, 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 &quot;0&quot; and &quot;max&quot;, respectively.
* @return a phase that is after the restartable client and before other default
* components.
* @see PulsarClientProxy#getPhase()
*/
@Override
public int getPhase() {

2
spring-pulsar/src/main/java/org/springframework/pulsar/core/PulsarClientProxy.java
View File

@@ -44,7 +44,7 @@ import org.springframework.util.Assert;
*
* @author Chris Bono
*/
public final class PulsarClientProxy extends RestartableSingletonFactory<PulsarClient> implements PulsarClient {
final class PulsarClientProxy extends RestartableSingletonFactory<PulsarClient> implements PulsarClient {
private static final int LIFECYCLE_PHASE = (Integer.MIN_VALUE / 2) - 200;