Package org.springframework.pulsar.autoconfigure

Class PulsarReactiveProperties.Listener

java.lang.Object

org.springframework.pulsar.autoconfigure.PulsarReactiveProperties.Listener

Enclosing class:

PulsarReactiveProperties

public static class PulsarReactiveProperties.Listener
extends Object

Constructor Summary

Constructors

Constructor	Description
Listener()

Method Summary

Modifier and Type	Method	Description
Duration	getHandlingTimeout()
org.apache.pulsar.common.schema.SchemaType	getSchemaType()
Boolean	getUseKeyOrderedProcessing()
void	setHandlingTimeout(Duration handlingTimeout)
void	setSchemaType(org.apache.pulsar.common.schema.SchemaType schemaType)
void	setUseKeyOrderedProcessing(Boolean useKeyOrderedProcessing)

Methods inherited from class java.lang.Object

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

Constructor Details

Listener

public Listener()

Method Details

getSchemaType

public org.apache.pulsar.common.schema.SchemaType getSchemaType()

setSchemaType

public void setSchemaType(org.apache.pulsar.common.schema.SchemaType schemaType)

getHandlingTimeout

public Duration getHandlingTimeout()

setHandlingTimeout

public void setHandlingTimeout(Duration handlingTimeout)

getUseKeyOrderedProcessing

public Boolean getUseKeyOrderedProcessing()

setUseKeyOrderedProcessing

public void setUseKeyOrderedProcessing(Boolean useKeyOrderedProcessing)