Skip to content

4.3.0
Compare
Choose a tag to compare
@ozangunalp ozangunalp released this 07 Feb 15:19
· 1203 commits to main since this release
4.3.0
f002c16
This commit was signed with the committer’s verified signature.
ozangunalp Ozan Gunalp
GPG key ID: D2934811B90CB810
Learn about vigilant mode.

Changelog

  • #2078 - Bump kafka.version from 3.3.2 to 3.4.0
  • #2077 - Bump artemis.version from 2.20.0 to 2.28.0
  • #2075 - Split package resolution for io.smallrye.reactive.messaging.providers.connectors
  • #2073 - Merge Jakarta namespace migration to the main branch
  • #1896 - Mutiny 2.0 with Flow support

Breaking Changes

  • method org.reactivestreams.Publisher<? extends org.eclipse.microprofile.reactive.messaging.Message<?>> io.smallrye.reactive.messaging.kafka.KafkaConnector::getPublisher(org.eclipse.microprofile.config.Config) updated to method java.util.concurrent.Flow.Publisher<? extends org.eclipse.microprofile.reactive.messaging.Message<?>> io.smallrye.reactive.messaging.kafka.KafkaConnector::getPublisher(org.eclipse.microprofile.config.Config): Switch from the legacy Reactive Streams APIs to java.util.concurrent.Flow
  • method org.reactivestreams.Subscriber<? extends org.eclipse.microprofile.reactive.messaging.Message<?>> io.smallrye.reactive.messaging.kafka.KafkaConnector::getSubscriber(org.eclipse.microprofile.config.Config) updated to method java.util.concurrent.Flow.Subscriber<? extends org.eclipse.microprofile.reactive.messaging.Message<?>> io.smallrye.reactive.messaging.kafka.KafkaConnector::getSubscriber(org.eclipse.microprofile.config.Config): Switch from the legacy Reactive Streams APIs to java.util.concurrent.Flow
  • method org.reactivestreams.Subscriber<? extends org.eclipse.microprofile.reactive.messaging.Message<?>> io.smallrye.reactive.messaging.kafka.impl.KafkaSink::getSink() updated to method java.util.concurrent.Flow.Subscriber<? extends org.eclipse.microprofile.reactive.messaging.Message<?>> io.smallrye.reactive.messaging.kafka.impl.KafkaSink::getSink(): Switch from the legacy Reactive Streams APIs to java.util.concurrent.Flow
  • class io.smallrye.reactive.messaging.providers.connectors.InMemoryConnector has been removed: Split package resolution: moved to package io.smallrye.reactive.messaging.memory
  • interface io.smallrye.reactive.messaging.providers.connectors.InMemorySink<T> has been removed: Split package resolution: moved to package io.smallrye.reactive.messaging.memory
  • interface io.smallrye.reactive.messaging.providers.connectors.InMemorySource<T> has been removed: Split package resolution: moved to package io.smallrye.reactive.messaging.memory
  • interface io.smallrye.reactive.messaging.providers.connectors.i18n.InMemoryExceptions has been removed: Split package resolution: moved to package io.smallrye.reactive.messaging.memory
  • class io.smallrye.reactive.messaging.providers.connectors.i18n.InMemoryExceptions_$bundle has been removed: Split package resolution: moved to package io.smallrye.reactive.messaging.memory
  • interface io.smallrye.reactive.messaging.providers.connectors.i18n.InMemoryLogging has been removed: Split package resolution: moved to package io.smallrye.reactive.messaging.memory
  • class io.smallrye.reactive.messaging.providers.connectors.i18n.InMemoryLogging_$logger has been removed: Split package resolution: moved to package io.smallrye.reactive.messaging.memory
  • interface io.smallrye.reactive.messaging.providers.connectors.i18n.InMemoryMessages has been removed: Split package resolution: moved to package io.smallrye.reactive.messaging.memory
  • class io.smallrye.reactive.messaging.providers.connectors.i18n.InMemoryMessages_$bundle has been removed: Split package resolution: moved to package io.smallrye.reactive.messaging.memory
  • method <M extends org.eclipse.microprofile.reactive.messaging.Message<? extends T>> io.smallrye.mutiny.Uni<java.lang.Void> io.smallrye.reactive.messaging.MutinyEmitter<T>::sendMessage(M) has been introduced: Added to the MutinyEmitter interface
  • method <M extends org.eclipse.microprofile.reactive.messaging.Message<? extends T>> void io.smallrye.reactive.messaging.MutinyEmitter<T>::sendMessageAndAwait(M) has been introduced: Added to the MutinyEmitter interface
  • method <M extends org.eclipse.microprofile.reactive.messaging.Message<? extends T>> io.smallrye.mutiny.subscription.Cancellable io.smallrye.reactive.messaging.MutinyEmitter<T>::sendMessageAndForget(M) has been introduced: Added to the MutinyEmitter interface
  • method java.util.List<org.reactivestreams.Publisher<? extends org.eclipse.microprofile.reactive.messaging.Message<?>>> io.smallrye.reactive.messaging.ChannelRegistry::getPublishers(java.lang.String) updated to method java.util.List<java.util.concurrent.Flow.Publisher<? extends org.eclipse.microprofile.reactive.messaging.Message<?>>> io.smallrye.reactive.messaging.ChannelRegistry::getPublishers(java.lang.String): Switch from the legacy Reactive Streams APIs to java.util.concurrent.Flow
  • method java.util.List<org.reactivestreams.Subscriber<? extends org.eclipse.microprofile.reactive.messaging.Message<?>>> io.smallrye.reactive.messaging.ChannelRegistry::getSubscribers(java.lang.String) updated to method java.util.List<java.util.concurrent.Flow.Subscriber<? extends org.eclipse.microprofile.reactive.messaging.Message<?>>> io.smallrye.reactive.messaging.ChannelRegistry::getSubscribers(java.lang.String): Switch from the legacy Reactive Streams APIs to java.util.concurrent.Flow
  • parameter org.reactivestreams.Publisher<? extends org.eclipse.microprofile.reactive.messaging.Message<?>> io.smallrye.reactive.messaging.ChannelRegistry::register(java.lang.String, ===org.reactivestreams.Publisher<? extends org.eclipse.microprofile.reactive.messaging.Message<?>>===, boolean) updated to parameter java.util.concurrent.Flow.Publisher<? extends org.eclipse.microprofile.reactive.messaging.Message<?>> io.smallrye.reactive.messaging.ChannelRegistry::register(java.lang.String, ===java.util.concurrent.Flow.Publisher<? extends org.eclipse.microprofile.reactive.messaging.Message<?>>===, boolean): Switch from the legacy Reactive Streams APIs to java.util.concurrent.Flow
  • method org.reactivestreams.Publisher<? extends org.eclipse.microprofile.reactive.messaging.Message<?>> io.smallrye.reactive.messaging.ChannelRegistry::register(java.lang.String, org.reactivestreams.Publisher<? extends org.eclipse.microprofile.reactive.messaging.Message<?>>, boolean) updated to method java.util.concurrent.Flow.Publisher<? extends org.eclipse.microprofile.reactive.messaging.Message<?>> io.smallrye.reactive.messaging.ChannelRegistry::register(java.lang.String, java.util.concurrent.Flow.Publisher<? extends org.eclipse.microprofile.reactive.messaging.Message<?>>, boolean): Switch from the legacy Reactive Streams APIs to java.util.concurrent.Flow
  • parameter org.reactivestreams.Subscriber<? extends org.eclipse.microprofile.reactive.messaging.Message<?>> io.smallrye.reactive.messaging.ChannelRegistry::register(java.lang.String, ===org.reactivestreams.Subscriber<? extends org.eclipse.microprofile.reactive.messaging.Message<?>>===, boolean) updated to parameter java.util.concurrent.Flow.Subscriber<? extends org.eclipse.microprofile.reactive.messaging.Message<?>> io.smallrye.reactive.messaging.ChannelRegistry::register(java.lang.String, ===java.util.concurrent.Flow.Subscriber<? extends org.eclipse.microprofile.reactive.messaging.Message<?>>===, boolean): Switch from the legacy Reactive Streams APIs to java.util.concurrent.Flow
  • method org.reactivestreams.Subscriber<? extends org.eclipse.microprofile.reactive.messaging.Message<?>> io.smallrye.reactive.messaging.ChannelRegistry::register(java.lang.String, org.reactivestreams.Subscriber<? extends org.eclipse.microprofile.reactive.messaging.Message<?>>, boolean) updated to method java.util.concurrent.Flow.Subscriber<? extends org.eclipse.microprofile.reactive.messaging.Message<?>> io.smallrye.reactive.messaging.ChannelRegistry::register(java.lang.String, java.util.concurrent.Flow.Subscriber<? extends org.eclipse.microprofile.reactive.messaging.Message<?>>, boolean): Switch from the legacy Reactive Streams APIs to java.util.concurrent.Flow
  • method org.reactivestreams.Publisher<org.eclipse.microprofile.reactive.messaging.Message<? extends T>> io.smallrye.reactive.messaging.MessagePublisherProvider<T>::getPublisher() updated to method java.util.concurrent.Flow.Publisher<org.eclipse.microprofile.reactive.messaging.Message<? extends T>> io.smallrye.reactive.messaging.MessagePublisherProvider<T>::getPublisher(): Switch from the legacy Reactive Streams APIs to java.util.concurrent.Flow
  • method org.reactivestreams.Publisher<? extends org.eclipse.microprofile.reactive.messaging.Message<?>> io.smallrye.reactive.messaging.connector.InboundConnector::getPublisher(org.eclipse.microprofile.config.Config) updated to method java.util.concurrent.Flow.Publisher<? extends org.eclipse.microprofile.reactive.messaging.Message<?>> io.smallrye.reactive.messaging.connector.InboundConnector::getPublisher(org.eclipse.microprofile.config.Config): Switch from the legacy Reactive Streams APIs to java.util.concurrent.Flow
  • method org.reactivestreams.Subscriber<? extends org.eclipse.microprofile.reactive.messaging.Message<?>> io.smallrye.reactive.messaging.connector.OutboundConnector::getSubscriber(org.eclipse.microprofile.config.Config) updated to method java.util.concurrent.Flow.Subscriber<? extends org.eclipse.microprofile.reactive.messaging.Message<?>> io.smallrye.reactive.messaging.connector.OutboundConnector::getSubscriber(org.eclipse.microprofile.config.Config): Switch from the legacy Reactive Streams APIs to java.util.concurrent.Flow
  • method boolean io.smallrye.reactive.messaging.MediatorConfiguration::usesReactiveStreams() has been introduced: Switch from the legacy Reactive Streams APIs to java.util.concurrent.Flow
Assets 2
Loading