Package io.micronaut.pulsar.processor

Class PulsarArgumentHandler

java.lang.Object
io.micronaut.pulsar.processor.PulsarArgumentHandler
@Internal public final class PulsarArgumentHandler extends Object
Helper processor class for arguments and headers on Pulsar consumers / processors.
Since:
1.1
Author:
Haris Secic

  • Constructor Details

    • PulsarArgumentHandler

      public PulsarArgumentHandler(io.micronaut.core.type.Argument<?>[] methodArguments, String methodPath)

  • Method Details

    • getBodyArgument

      public io.micronaut.core.type.Argument<?> getBodyArgument()

    • isMessageWrapper

      public boolean isMessageWrapper()

    • getKeyArgument

      @Nullable public @Nullable io.micronaut.core.type.Argument<?> getKeyArgument()

    • hasHeaderList

      public boolean hasHeaderList()

    • hasHeadersMap

      public boolean hasHeadersMap()

    • argumentOrder

      public Map<String,Integer> argumentOrder()

    • headersOrder

      public Map<String,Integer> headersOrder()

    • size

      public int size()