Package io.smallrye.reactive.messaging.providers.helpers

Class KeyMultiUtils

java.lang.Object
io.smallrye.reactive.messaging.providers.helpers.KeyMultiUtils
public class KeyMultiUtils extends Object

  • Method Summary

    Modifier and Type
    Method
    Description
    static io.smallrye.mutiny.Multi<io.smallrye.reactive.messaging.keyed.KeyedMulti<?,?>>
    convertToKeyedMulti(io.smallrye.mutiny.Multi<? extends org.eclipse.microprofile.reactive.messaging.Message<?>> multi, jakarta.enterprise.inject.Instance<io.smallrye.reactive.messaging.keyed.KeyValueExtractor> extractors, io.smallrye.reactive.messaging.MediatorConfiguration configuration)
     
    static io.smallrye.mutiny.Multi<io.smallrye.reactive.messaging.keyed.KeyedMulti<?,org.eclipse.microprofile.reactive.messaging.Message<?>>>
    convertToKeyedMultiMessage(io.smallrye.mutiny.Multi<? extends org.eclipse.microprofile.reactive.messaging.Message<?>> multi, jakarta.enterprise.inject.Instance<io.smallrye.reactive.messaging.keyed.KeyValueExtractor> extractors, io.smallrye.reactive.messaging.MediatorConfiguration configuration)
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Method Details

    • convertToKeyedMulti

      public static io.smallrye.mutiny.Multi<io.smallrye.reactive.messaging.keyed.KeyedMulti<?,?>> convertToKeyedMulti(io.smallrye.mutiny.Multi<? extends org.eclipse.microprofile.reactive.messaging.Message<?>> multi, jakarta.enterprise.inject.Instance<io.smallrye.reactive.messaging.keyed.KeyValueExtractor> extractors, io.smallrye.reactive.messaging.MediatorConfiguration configuration)

    • convertToKeyedMultiMessage

      public static io.smallrye.mutiny.Multi<io.smallrye.reactive.messaging.keyed.KeyedMulti<?,org.eclipse.microprofile.reactive.messaging.Message<?>>> convertToKeyedMultiMessage(io.smallrye.mutiny.Multi<? extends org.eclipse.microprofile.reactive.messaging.Message<?>> multi, jakarta.enterprise.inject.Instance<io.smallrye.reactive.messaging.keyed.KeyValueExtractor> extractors, io.smallrye.reactive.messaging.MediatorConfiguration configuration)