Renaming ListenerEndpointRegistry
ListenerEndpointRegistry -> GenericListenerEndpointRegistry
This commit is contained in:
@@ -1,5 +1,5 @@
|
||||
/*
|
||||
* Copyright 2022 the original author or authors.
|
||||
* Copyright 2022-2023 the original author or authors.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
@@ -16,7 +16,7 @@
|
||||
|
||||
package org.springframework.pulsar.reactive.config;
|
||||
|
||||
import org.springframework.pulsar.config.ListenerEndpointRegistry;
|
||||
import org.springframework.pulsar.config.GenericListenerEndpointRegistry;
|
||||
import org.springframework.pulsar.reactive.listener.ReactivePulsarMessageListenerContainer;
|
||||
|
||||
/**
|
||||
@@ -36,8 +36,8 @@ import org.springframework.pulsar.reactive.listener.ReactivePulsarMessageListene
|
||||
* @param <T> Message payload type.
|
||||
* @author Christophe Bornet
|
||||
*/
|
||||
public class ReactivePulsarListenerEndpointRegistry<T>
|
||||
extends ListenerEndpointRegistry<ReactivePulsarMessageListenerContainer<T>, ReactivePulsarListenerEndpoint<T>> {
|
||||
public class ReactivePulsarListenerEndpointRegistry<T> extends
|
||||
GenericListenerEndpointRegistry<ReactivePulsarMessageListenerContainer<T>, ReactivePulsarListenerEndpoint<T>> {
|
||||
|
||||
public ReactivePulsarListenerEndpointRegistry() {
|
||||
super(ReactivePulsarMessageListenerContainer.class);
|
||||
|
||||
@@ -58,7 +58,7 @@ import org.springframework.util.Assert;
|
||||
* @author Soby Chacko
|
||||
* @author Christophe Bornet
|
||||
*/
|
||||
public class ListenerEndpointRegistry<C extends MessageListenerContainer, E extends ListenerEndpoint<C>>
|
||||
public class GenericListenerEndpointRegistry<C extends MessageListenerContainer, E extends ListenerEndpoint<C>>
|
||||
implements PulsarListenerContainerRegistry, DisposableBean, SmartLifecycle, ApplicationContextAware,
|
||||
ApplicationListener<ContextRefreshedEvent> {
|
||||
|
||||
@@ -75,7 +75,7 @@ public class ListenerEndpointRegistry<C extends MessageListenerContainer, E exte
|
||||
private volatile boolean running;
|
||||
|
||||
@SuppressWarnings("unchecked")
|
||||
protected ListenerEndpointRegistry(Class<?> type) {
|
||||
protected GenericListenerEndpointRegistry(Class<?> type) {
|
||||
this.type = (Class<? extends C>) type;
|
||||
}
|
||||
|
||||
@@ -1,5 +1,5 @@
|
||||
/*
|
||||
* Copyright 2022 the original author or authors.
|
||||
* Copyright 2022-2023 the original author or authors.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
@@ -27,7 +27,7 @@ import org.springframework.util.Assert;
|
||||
|
||||
/**
|
||||
* Helper bean for registering {@link ListenerEndpoint} with a
|
||||
* {@link ListenerEndpointRegistry}.
|
||||
* {@link GenericListenerEndpointRegistry}.
|
||||
*
|
||||
* @author Soby Chacko
|
||||
* @author Christophe Bornet
|
||||
@@ -39,7 +39,7 @@ public class PulsarListenerEndpointRegistrar implements BeanFactoryAware, Initia
|
||||
|
||||
private final List<PulsarListenerEndpointDescriptor> endpointDescriptors = new ArrayList<>();
|
||||
|
||||
private ListenerEndpointRegistry endpointRegistry;
|
||||
private GenericListenerEndpointRegistry endpointRegistry;
|
||||
|
||||
private ListenerContainerFactory<?, ?> containerFactory;
|
||||
|
||||
@@ -53,12 +53,12 @@ public class PulsarListenerEndpointRegistrar implements BeanFactoryAware, Initia
|
||||
this.type = type;
|
||||
}
|
||||
|
||||
public void setEndpointRegistry(ListenerEndpointRegistry endpointRegistry) {
|
||||
public void setEndpointRegistry(GenericListenerEndpointRegistry endpointRegistry) {
|
||||
this.endpointRegistry = endpointRegistry;
|
||||
}
|
||||
|
||||
@Nullable
|
||||
public ListenerEndpointRegistry getEndpointRegistry() {
|
||||
public GenericListenerEndpointRegistry getEndpointRegistry() {
|
||||
return this.endpointRegistry;
|
||||
}
|
||||
|
||||
|
||||
@@ -1,5 +1,5 @@
|
||||
/*
|
||||
* Copyright 2022 the original author or authors.
|
||||
* Copyright 2022-2023 the original author or authors.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
@@ -35,7 +35,7 @@ import org.springframework.pulsar.listener.PulsarMessageListenerContainer;
|
||||
* @author Christophe Bornet
|
||||
*/
|
||||
public class PulsarListenerEndpointRegistry
|
||||
extends ListenerEndpointRegistry<PulsarMessageListenerContainer, PulsarListenerEndpoint> {
|
||||
extends GenericListenerEndpointRegistry<PulsarMessageListenerContainer, PulsarListenerEndpoint> {
|
||||
|
||||
public PulsarListenerEndpointRegistry() {
|
||||
super(PulsarMessageListenerContainer.class);
|
||||
|
||||
Reference in New Issue
Block a user