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 Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
Map<String,Integer>	argumentOrder()
io.micronaut.core.type.Argument<?>	getBodyArgument()
io.micronaut.core.type.Argument<?>	getKeyArgument()
boolean	hasHeaderList()
boolean	hasHeadersMap()
Map<String,Integer>	headersOrder()
boolean	isMessageWrapper()
int	size()

Methods inherited from class java.lang.Object

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

Constructor Detail

PulsarArgumentHandler

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

Method Detail

getBodyArgument

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

isMessageWrapper

public boolean isMessageWrapper()

getKeyArgument

@Nullable
public 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()