From fed6a0c40fb80a51d419d36c90bf4165780e9a71 Mon Sep 17 00:00:00 2001 From: Chris Bono Date: Sat, 22 Oct 2022 11:18:01 -0500 Subject: [PATCH] Add package-info.java setting all things @NonNull - Adjusted producer pieces to get rid of warnings - Other areas to be updated as we encounter the warnings --- .../src/main/java/app1/package-info.java | 9 +++++ .../src/main/java/app2/package-info.java | 9 +++++ .../pulsar/autoconfigure/package-info.java | 11 +++++++ .../pulsar/annotation/package-info.java | 9 +++++ .../config/PulsarClientFactoryBean.java | 3 +- .../pulsar/config/package-info.java | 9 +++++ .../core/CachingPulsarProducerFactory.java | 17 +++++----- .../core/DefaultPulsarProducerFactory.java | 21 ++++++------ .../pulsar/core/ProducerUtils.java | 3 +- .../pulsar/core/PulsarOperations.java | 6 ++-- .../pulsar/core/PulsarProducerFactory.java | 8 +++-- .../pulsar/core/PulsarTemplate.java | 33 ++++++++++++------- .../pulsar/core/package-info.java | 9 +++++ .../pulsar/event/package-info.java | 9 +++++ .../pulsar/listener/adapter/package-info.java | 9 +++++ .../pulsar/listener/package-info.java | 9 +++++ .../pulsar/observation/package-info.java | 9 +++++ .../springframework/pulsar/package-info.java | 9 +++++ .../PulsarRecordMessageConverter.java | 2 -- .../support/converter/package-info.java | 9 +++++ .../pulsar/support/package-info.java | 9 +++++ 21 files changed, 174 insertions(+), 38 deletions(-) create mode 100644 spring-pulsar-sample-apps/src/main/java/app1/package-info.java create mode 100644 spring-pulsar-sample-apps/src/main/java/app2/package-info.java create mode 100644 spring-pulsar-spring-boot-autoconfigure/src/main/java/org/springframework/pulsar/autoconfigure/package-info.java create mode 100644 spring-pulsar/src/main/java/org/springframework/pulsar/annotation/package-info.java create mode 100644 spring-pulsar/src/main/java/org/springframework/pulsar/config/package-info.java create mode 100644 spring-pulsar/src/main/java/org/springframework/pulsar/core/package-info.java create mode 100644 spring-pulsar/src/main/java/org/springframework/pulsar/event/package-info.java create mode 100644 spring-pulsar/src/main/java/org/springframework/pulsar/listener/adapter/package-info.java create mode 100644 spring-pulsar/src/main/java/org/springframework/pulsar/listener/package-info.java create mode 100644 spring-pulsar/src/main/java/org/springframework/pulsar/observation/package-info.java create mode 100644 spring-pulsar/src/main/java/org/springframework/pulsar/package-info.java create mode 100644 spring-pulsar/src/main/java/org/springframework/pulsar/support/converter/package-info.java create mode 100644 spring-pulsar/src/main/java/org/springframework/pulsar/support/package-info.java diff --git a/spring-pulsar-sample-apps/src/main/java/app1/package-info.java b/spring-pulsar-sample-apps/src/main/java/app1/package-info.java new file mode 100644 index 00000000..4bf428b5 --- /dev/null +++ b/spring-pulsar-sample-apps/src/main/java/app1/package-info.java @@ -0,0 +1,9 @@ +/** + * Package containing sample app for the framework. + */ +@NonNullApi +@NonNullFields +package app1; + +import org.springframework.lang.NonNullApi; +import org.springframework.lang.NonNullFields; diff --git a/spring-pulsar-sample-apps/src/main/java/app2/package-info.java b/spring-pulsar-sample-apps/src/main/java/app2/package-info.java new file mode 100644 index 00000000..552340e1 --- /dev/null +++ b/spring-pulsar-sample-apps/src/main/java/app2/package-info.java @@ -0,0 +1,9 @@ +/** + * Package containing sample app for the framework. + */ +@NonNullApi +@NonNullFields +package app2; + +import org.springframework.lang.NonNullApi; +import org.springframework.lang.NonNullFields; diff --git a/spring-pulsar-spring-boot-autoconfigure/src/main/java/org/springframework/pulsar/autoconfigure/package-info.java b/spring-pulsar-spring-boot-autoconfigure/src/main/java/org/springframework/pulsar/autoconfigure/package-info.java new file mode 100644 index 00000000..89928137 --- /dev/null +++ b/spring-pulsar-spring-boot-autoconfigure/src/main/java/org/springframework/pulsar/autoconfigure/package-info.java @@ -0,0 +1,11 @@ +/** + * Package containing the Spring Boot + * {@link org.springframework.boot.autoconfigure.AutoConfiguration} for the Spring for + * Apache Pulsar framework. + */ +@NonNullApi +@NonNullFields +package org.springframework.pulsar.autoconfigure; + +import org.springframework.lang.NonNullApi; +import org.springframework.lang.NonNullFields; diff --git a/spring-pulsar/src/main/java/org/springframework/pulsar/annotation/package-info.java b/spring-pulsar/src/main/java/org/springframework/pulsar/annotation/package-info.java new file mode 100644 index 00000000..65dd29a2 --- /dev/null +++ b/spring-pulsar/src/main/java/org/springframework/pulsar/annotation/package-info.java @@ -0,0 +1,9 @@ +/** + * Package containing annotations used by the framework. + */ +@NonNullApi +@NonNullFields +package org.springframework.pulsar.annotation; + +import org.springframework.lang.NonNullApi; +import org.springframework.lang.NonNullFields; diff --git a/spring-pulsar/src/main/java/org/springframework/pulsar/config/PulsarClientFactoryBean.java b/spring-pulsar/src/main/java/org/springframework/pulsar/config/PulsarClientFactoryBean.java index c65c874d..0cf31261 100644 --- a/spring-pulsar/src/main/java/org/springframework/pulsar/config/PulsarClientFactoryBean.java +++ b/spring-pulsar/src/main/java/org/springframework/pulsar/config/PulsarClientFactoryBean.java @@ -22,6 +22,7 @@ import org.apache.pulsar.client.api.PulsarClient; import org.springframework.beans.factory.FactoryBean; import org.springframework.beans.factory.config.AbstractFactoryBean; import org.springframework.core.log.LogAccessor; +import org.springframework.lang.Nullable; /** * {@link FactoryBean} implementation for the {@link PulsarClient}. @@ -50,7 +51,7 @@ public class PulsarClientFactoryBean extends AbstractFactoryBean { } @Override - protected void destroyInstance(PulsarClient instance) throws Exception { + protected void destroyInstance(@Nullable PulsarClient instance) throws Exception { if (instance != null) { this.logger.info(() -> "Closing client " + instance); instance.close(); diff --git a/spring-pulsar/src/main/java/org/springframework/pulsar/config/package-info.java b/spring-pulsar/src/main/java/org/springframework/pulsar/config/package-info.java new file mode 100644 index 00000000..374487e9 --- /dev/null +++ b/spring-pulsar/src/main/java/org/springframework/pulsar/config/package-info.java @@ -0,0 +1,9 @@ +/** + * Package containing Spring configuration classes for the framework. + */ +@NonNullApi +@NonNullFields +package org.springframework.pulsar.config; + +import org.springframework.lang.NonNullApi; +import org.springframework.lang.NonNullFields; diff --git a/spring-pulsar/src/main/java/org/springframework/pulsar/core/CachingPulsarProducerFactory.java b/spring-pulsar/src/main/java/org/springframework/pulsar/core/CachingPulsarProducerFactory.java index a34427c3..d3a3696b 100644 --- a/spring-pulsar/src/main/java/org/springframework/pulsar/core/CachingPulsarProducerFactory.java +++ b/spring-pulsar/src/main/java/org/springframework/pulsar/core/CachingPulsarProducerFactory.java @@ -38,7 +38,6 @@ import org.springframework.aop.framework.AopProxyUtils; import org.springframework.aop.framework.ProxyFactory; import org.springframework.beans.factory.DisposableBean; import org.springframework.core.log.LogAccessor; -import org.springframework.lang.NonNull; import org.springframework.lang.Nullable; import org.springframework.util.Assert; @@ -92,9 +91,9 @@ public class CachingPulsarProducerFactory extends DefaultPulsarProducerFactor } @Override - protected Producer doCreateProducer(String topic, Schema schema, MessageRouter messageRouter, - List producerInterceptors, - List> producerBuilderCustomizers) { + protected Producer doCreateProducer(@Nullable String topic, Schema schema, + @Nullable MessageRouter messageRouter, @Nullable List producerInterceptors, + @Nullable List> producerBuilderCustomizers) { final String topicName = ProducerUtils.resolveTopicName(topic, this); ProducerCacheKey producerCacheKey = new ProducerCacheKey<>(schema, topicName, messageRouter, producerInterceptors); @@ -102,9 +101,9 @@ public class CachingPulsarProducerFactory extends DefaultPulsarProducerFactor st.interceptors, producerBuilderCustomizers)); } - private Producer createCacheableProducer(String topic, Schema schema, MessageRouter messageRouter, - List producerInterceptors, - List> producerBuilderCustomizers) { + private Producer createCacheableProducer(String topic, Schema schema, @Nullable MessageRouter messageRouter, + @Nullable List producerInterceptors, + @Nullable List> producerBuilderCustomizers) { try { Producer producer = super.doCreateProducer(topic, schema, messageRouter, producerInterceptors, producerBuilderCustomizers); @@ -124,7 +123,7 @@ public class CachingPulsarProducerFactory extends DefaultPulsarProducerFactor factory.addAdvice(new MethodInterceptor() { @Nullable @Override - public Object invoke(@NonNull MethodInvocation invocation) throws Throwable { + public Object invoke(MethodInvocation invocation) throws Throwable { if (invocation.getMethod().getName().equals("close")) { closeCallback.accept((Producer) invocation.getThis()); return null; @@ -171,8 +170,10 @@ public class CachingPulsarProducerFactory extends DefaultPulsarProducerFactor private final String topic; + @Nullable private final MessageRouter router; + @Nullable private final List interceptors; /** diff --git a/spring-pulsar/src/main/java/org/springframework/pulsar/core/DefaultPulsarProducerFactory.java b/spring-pulsar/src/main/java/org/springframework/pulsar/core/DefaultPulsarProducerFactory.java index 417e82d7..cec12be9 100644 --- a/spring-pulsar/src/main/java/org/springframework/pulsar/core/DefaultPulsarProducerFactory.java +++ b/spring-pulsar/src/main/java/org/springframework/pulsar/core/DefaultPulsarProducerFactory.java @@ -30,6 +30,7 @@ import org.apache.pulsar.client.api.Schema; import org.apache.pulsar.client.api.interceptor.ProducerInterceptor; import org.springframework.core.log.LogAccessor; +import org.springframework.lang.Nullable; import org.springframework.util.CollectionUtils; /** @@ -56,26 +57,26 @@ public class DefaultPulsarProducerFactory implements PulsarProducerFactory } @Override - public Producer createProducer(String topic, Schema schema) throws PulsarClientException { + public Producer createProducer(@Nullable String topic, Schema schema) throws PulsarClientException { return doCreateProducer(topic, schema, null, null, null); } @Override - public Producer createProducer(String topic, Schema schema, MessageRouter messageRouter) + public Producer createProducer(@Nullable String topic, Schema schema, @Nullable MessageRouter messageRouter) throws PulsarClientException { return doCreateProducer(topic, schema, messageRouter, null, null); } @Override - public Producer createProducer(String topic, Schema schema, MessageRouter messageRouter, - List producerInterceptors) throws PulsarClientException { + public Producer createProducer(@Nullable String topic, Schema schema, @Nullable MessageRouter messageRouter, + @Nullable List producerInterceptors) throws PulsarClientException { return doCreateProducer(topic, schema, messageRouter, producerInterceptors, null); } @Override - public Producer createProducer(String topic, Schema schema, MessageRouter messageRouter, - List producerInterceptors, - List> producerBuilderCustomizers) throws PulsarClientException { + public Producer createProducer(@Nullable String topic, Schema schema, @Nullable MessageRouter messageRouter, + @Nullable List producerInterceptors, + @Nullable List> producerBuilderCustomizers) throws PulsarClientException { return doCreateProducer(topic, schema, messageRouter, producerInterceptors, producerBuilderCustomizers); } @@ -91,9 +92,9 @@ public class DefaultPulsarProducerFactory implements PulsarProducerFactory * @return the created producer * @throws PulsarClientException if any error occurs */ - protected Producer doCreateProducer(String topic, Schema schema, MessageRouter messageRouter, - List producerInterceptors, - List> producerBuilderCustomizers) throws PulsarClientException { + protected Producer doCreateProducer(@Nullable String topic, Schema schema, + @Nullable MessageRouter messageRouter, @Nullable List producerInterceptors, + @Nullable List> producerBuilderCustomizers) throws PulsarClientException { final String resolvedTopic = ProducerUtils.resolveTopicName(topic, this); this.logger.trace(() -> String.format("Creating producer for '%s' topic", resolvedTopic)); final ProducerBuilder producerBuilder = this.pulsarClient.newProducer(schema); diff --git a/spring-pulsar/src/main/java/org/springframework/pulsar/core/ProducerUtils.java b/spring-pulsar/src/main/java/org/springframework/pulsar/core/ProducerUtils.java index 02d6712c..1612177d 100644 --- a/spring-pulsar/src/main/java/org/springframework/pulsar/core/ProducerUtils.java +++ b/spring-pulsar/src/main/java/org/springframework/pulsar/core/ProducerUtils.java @@ -21,6 +21,7 @@ import java.util.Optional; import org.apache.pulsar.client.api.Producer; import org.springframework.core.log.LogAccessor; +import org.springframework.lang.Nullable; import org.springframework.util.StringUtils; /** @@ -37,7 +38,7 @@ final class ProducerUtils { return String.format("(%s:%s)", producer.getProducerName(), producer.getTopic()); } - static String resolveTopicName(String userSpecifiedTopic, PulsarProducerFactory producerFactory) { + static String resolveTopicName(@Nullable String userSpecifiedTopic, PulsarProducerFactory producerFactory) { if (StringUtils.hasText(userSpecifiedTopic)) { return userSpecifiedTopic; } diff --git a/spring-pulsar/src/main/java/org/springframework/pulsar/core/PulsarOperations.java b/spring-pulsar/src/main/java/org/springframework/pulsar/core/PulsarOperations.java index 432eeb87..56ee2c35 100644 --- a/spring-pulsar/src/main/java/org/springframework/pulsar/core/PulsarOperations.java +++ b/spring-pulsar/src/main/java/org/springframework/pulsar/core/PulsarOperations.java @@ -22,6 +22,8 @@ import org.apache.pulsar.client.api.MessageId; import org.apache.pulsar.client.api.MessageRouter; import org.apache.pulsar.client.api.PulsarClientException; +import org.springframework.lang.Nullable; + /** * The basic Pulsar operations contract. * @@ -47,7 +49,7 @@ public interface PulsarOperations { * @return the id assigned by the broker to the published message * @throws PulsarClientException if an error occurs */ - MessageId send(String topic, T message) throws PulsarClientException; + MessageId send(@Nullable String topic, T message) throws PulsarClientException; /** * Sends a message to the default topic in a non-blocking manner. @@ -65,7 +67,7 @@ public interface PulsarOperations { * @return a future that holds the id assigned by the broker to the published message * @throws PulsarClientException if an error occurs */ - CompletableFuture sendAsync(String topic, T message) throws PulsarClientException; + CompletableFuture sendAsync(@Nullable String topic, T message) throws PulsarClientException; /** * Create a {@link SendMessageBuilder builder} for configuring and sending a message. diff --git a/spring-pulsar/src/main/java/org/springframework/pulsar/core/PulsarProducerFactory.java b/spring-pulsar/src/main/java/org/springframework/pulsar/core/PulsarProducerFactory.java index 4dcd2911..d46d7b82 100644 --- a/spring-pulsar/src/main/java/org/springframework/pulsar/core/PulsarProducerFactory.java +++ b/spring-pulsar/src/main/java/org/springframework/pulsar/core/PulsarProducerFactory.java @@ -25,6 +25,8 @@ import org.apache.pulsar.client.api.PulsarClientException; import org.apache.pulsar.client.api.Schema; import org.apache.pulsar.client.api.interceptor.ProducerInterceptor; +import org.springframework.lang.Nullable; + /** * The strategy to create a {@link Producer} instance(s). * @@ -82,9 +84,9 @@ public interface PulsarProducerFactory { * @return the producer * @throws PulsarClientException if any error occurs */ - Producer createProducer(String topic, Schema schema, MessageRouter messageRouter, - List producerInterceptors, - List> producerBuilderCustomizers) throws PulsarClientException; + Producer createProducer(@Nullable String topic, Schema schema, @Nullable MessageRouter messageRouter, + @Nullable List producerInterceptors, + @Nullable List> producerBuilderCustomizers) throws PulsarClientException; /** * Return a map of configuration options to use when creating producers. diff --git a/spring-pulsar/src/main/java/org/springframework/pulsar/core/PulsarTemplate.java b/spring-pulsar/src/main/java/org/springframework/pulsar/core/PulsarTemplate.java index 01eeda30..2e418111 100644 --- a/spring-pulsar/src/main/java/org/springframework/pulsar/core/PulsarTemplate.java +++ b/spring-pulsar/src/main/java/org/springframework/pulsar/core/PulsarTemplate.java @@ -53,14 +53,18 @@ public class PulsarTemplate implements PulsarOperations, BeanNameAware { private final PulsarProducerFactory producerFactory; + @Nullable private final List interceptors; + @Nullable private final ObservationRegistry observationRegistry; + @Nullable private final PulsarTemplateObservationConvention observationConvention; - private String beanName; + private String beanName = ""; + @Nullable private Schema schema; /** @@ -76,7 +80,7 @@ public class PulsarTemplate implements PulsarOperations, BeanNameAware { * @param producerFactory the factory used to create the backing Pulsar producers. * @param interceptors the interceptors to add to the producer. */ - public PulsarTemplate(PulsarProducerFactory producerFactory, List interceptors) { + public PulsarTemplate(PulsarProducerFactory producerFactory, @Nullable List interceptors) { this(producerFactory, interceptors, null, null); } @@ -105,7 +109,7 @@ public class PulsarTemplate implements PulsarOperations, BeanNameAware { } @Override - public MessageId send(String topic, T message) throws PulsarClientException { + public MessageId send(@Nullable String topic, T message) throws PulsarClientException { return doSend(topic, message, null, null, null); } @@ -115,7 +119,7 @@ public class PulsarTemplate implements PulsarOperations, BeanNameAware { } @Override - public CompletableFuture sendAsync(String topic, T message) throws PulsarClientException { + public CompletableFuture sendAsync(@Nullable String topic, T message) throws PulsarClientException { return doSendAsync(topic, message, null, null, null); } @@ -137,8 +141,10 @@ public class PulsarTemplate implements PulsarOperations, BeanNameAware { this.schema = schema; } - private MessageId doSend(String topic, T message, TypedMessageBuilderCustomizer typedMessageBuilderCustomizer, - MessageRouter messageRouter, ProducerBuilderCustomizer producerCustomizer) throws PulsarClientException { + private MessageId doSend(@Nullable String topic, T message, + @Nullable TypedMessageBuilderCustomizer typedMessageBuilderCustomizer, + @Nullable MessageRouter messageRouter, @Nullable ProducerBuilderCustomizer producerCustomizer) + throws PulsarClientException { try { return doSendAsync(topic, message, typedMessageBuilderCustomizer, messageRouter, producerCustomizer).get(); } @@ -147,9 +153,10 @@ public class PulsarTemplate implements PulsarOperations, BeanNameAware { } } - private CompletableFuture doSendAsync(String topic, T message, - TypedMessageBuilderCustomizer typedMessageBuilderCustomizer, MessageRouter messageRouter, - ProducerBuilderCustomizer producerCustomizer) throws PulsarClientException { + private CompletableFuture doSendAsync(@Nullable String topic, T message, + @Nullable TypedMessageBuilderCustomizer typedMessageBuilderCustomizer, + @Nullable MessageRouter messageRouter, @Nullable ProducerBuilderCustomizer producerCustomizer) + throws PulsarClientException { final String topicName = ProducerUtils.resolveTopicName(topic, this.producerFactory); this.logger.trace(() -> String.format("Sending msg to '%s' topic", topicName)); @@ -193,8 +200,8 @@ public class PulsarTemplate implements PulsarOperations, BeanNameAware { DefaultPulsarTemplateObservationConvention.INSTANCE, () -> senderContext, this.observationRegistry); } - private Producer prepareProducerForSend(String topic, T message, MessageRouter messageRouter, - ProducerBuilderCustomizer producerCustomizer) throws PulsarClientException { + private Producer prepareProducerForSend(@Nullable String topic, T message, @Nullable MessageRouter messageRouter, + @Nullable ProducerBuilderCustomizer producerCustomizer) throws PulsarClientException { Schema schema = this.schema != null ? this.schema : SchemaUtils.getSchema(message); return this.producerFactory.createProducer(topic, schema, messageRouter, this.interceptors, producerCustomizer == null ? Collections.emptyList() : Collections.singletonList(producerCustomizer)); @@ -206,12 +213,16 @@ public class PulsarTemplate implements PulsarOperations, BeanNameAware { private final T message; + @Nullable private String topic; + @Nullable private TypedMessageBuilderCustomizer messageCustomizer; + @Nullable private MessageRouter messageRouter; + @Nullable private ProducerBuilderCustomizer producerCustomizer; SendMessageBuilderImpl(PulsarTemplate template, T message) { diff --git a/spring-pulsar/src/main/java/org/springframework/pulsar/core/package-info.java b/spring-pulsar/src/main/java/org/springframework/pulsar/core/package-info.java new file mode 100644 index 00000000..3a1fece9 --- /dev/null +++ b/spring-pulsar/src/main/java/org/springframework/pulsar/core/package-info.java @@ -0,0 +1,9 @@ +/** + * Package containing the core components of the framework. + */ +@NonNullApi +@NonNullFields +package org.springframework.pulsar.core; + +import org.springframework.lang.NonNullApi; +import org.springframework.lang.NonNullFields; diff --git a/spring-pulsar/src/main/java/org/springframework/pulsar/event/package-info.java b/spring-pulsar/src/main/java/org/springframework/pulsar/event/package-info.java new file mode 100644 index 00000000..3858ec05 --- /dev/null +++ b/spring-pulsar/src/main/java/org/springframework/pulsar/event/package-info.java @@ -0,0 +1,9 @@ +/** + * Package containing events produced by the framework. + */ +@NonNullApi +@NonNullFields +package org.springframework.pulsar.event; + +import org.springframework.lang.NonNullApi; +import org.springframework.lang.NonNullFields; diff --git a/spring-pulsar/src/main/java/org/springframework/pulsar/listener/adapter/package-info.java b/spring-pulsar/src/main/java/org/springframework/pulsar/listener/adapter/package-info.java new file mode 100644 index 00000000..b24b86d1 --- /dev/null +++ b/spring-pulsar/src/main/java/org/springframework/pulsar/listener/adapter/package-info.java @@ -0,0 +1,9 @@ +/** + * Package containing components for adapting Pulsar messages to message listeners. + */ +@NonNullApi +@NonNullFields +package org.springframework.pulsar.listener.adapter; + +import org.springframework.lang.NonNullApi; +import org.springframework.lang.NonNullFields; diff --git a/spring-pulsar/src/main/java/org/springframework/pulsar/listener/package-info.java b/spring-pulsar/src/main/java/org/springframework/pulsar/listener/package-info.java new file mode 100644 index 00000000..d8ccedb1 --- /dev/null +++ b/spring-pulsar/src/main/java/org/springframework/pulsar/listener/package-info.java @@ -0,0 +1,9 @@ +/** + * Package containing listener components for receiving Pulsar messages. + */ +@NonNullApi +@NonNullFields +package org.springframework.pulsar.listener; + +import org.springframework.lang.NonNullApi; +import org.springframework.lang.NonNullFields; diff --git a/spring-pulsar/src/main/java/org/springframework/pulsar/observation/package-info.java b/spring-pulsar/src/main/java/org/springframework/pulsar/observation/package-info.java new file mode 100644 index 00000000..32e5a2d4 --- /dev/null +++ b/spring-pulsar/src/main/java/org/springframework/pulsar/observation/package-info.java @@ -0,0 +1,9 @@ +/** + * Package containing components that provide support for the Observation API. + */ +@NonNullApi +@NonNullFields +package org.springframework.pulsar.observation; + +import org.springframework.lang.NonNullApi; +import org.springframework.lang.NonNullFields; diff --git a/spring-pulsar/src/main/java/org/springframework/pulsar/package-info.java b/spring-pulsar/src/main/java/org/springframework/pulsar/package-info.java new file mode 100644 index 00000000..8eaceb3d --- /dev/null +++ b/spring-pulsar/src/main/java/org/springframework/pulsar/package-info.java @@ -0,0 +1,9 @@ +/** + * Package containing the Spring for Apache Pulsar framework classes. + */ +@NonNullApi +@NonNullFields +package org.springframework.pulsar; + +import org.springframework.lang.NonNullApi; +import org.springframework.lang.NonNullFields; diff --git a/spring-pulsar/src/main/java/org/springframework/pulsar/support/converter/PulsarRecordMessageConverter.java b/spring-pulsar/src/main/java/org/springframework/pulsar/support/converter/PulsarRecordMessageConverter.java index a4907032..71d8ed9f 100644 --- a/spring-pulsar/src/main/java/org/springframework/pulsar/support/converter/PulsarRecordMessageConverter.java +++ b/spring-pulsar/src/main/java/org/springframework/pulsar/support/converter/PulsarRecordMessageConverter.java @@ -20,7 +20,6 @@ import java.lang.reflect.Type; import org.apache.pulsar.client.api.Consumer; -import org.springframework.lang.NonNull; import org.springframework.messaging.Message; import org.springframework.pulsar.support.MessageConverter; @@ -32,7 +31,6 @@ import org.springframework.pulsar.support.MessageConverter; */ public interface PulsarRecordMessageConverter extends MessageConverter { - @NonNull Message toMessage(org.apache.pulsar.client.api.Message record, Consumer consumer, Type payloadType); T fromMessage(Message message, String defaultTopic); diff --git a/spring-pulsar/src/main/java/org/springframework/pulsar/support/converter/package-info.java b/spring-pulsar/src/main/java/org/springframework/pulsar/support/converter/package-info.java new file mode 100644 index 00000000..dfe46f8d --- /dev/null +++ b/spring-pulsar/src/main/java/org/springframework/pulsar/support/converter/package-info.java @@ -0,0 +1,9 @@ +/** + * Package containing message converters. + */ +@NonNullApi +@NonNullFields +package org.springframework.pulsar.support.converter; + +import org.springframework.lang.NonNullApi; +import org.springframework.lang.NonNullFields; diff --git a/spring-pulsar/src/main/java/org/springframework/pulsar/support/package-info.java b/spring-pulsar/src/main/java/org/springframework/pulsar/support/package-info.java new file mode 100644 index 00000000..58cb3aa8 --- /dev/null +++ b/spring-pulsar/src/main/java/org/springframework/pulsar/support/package-info.java @@ -0,0 +1,9 @@ +/** + * Package containing general support components. + */ +@NonNullApi +@NonNullFields +package org.springframework.pulsar.support; + +import org.springframework.lang.NonNullApi; +import org.springframework.lang.NonNullFields;