Package org.springframework.pulsar.listener

Class PulsarContainerProperties.TransactionSettings

java.lang.Object

org.springframework.pulsar.core.TransactionProperties

org.springframework.pulsar.listener.PulsarContainerProperties.TransactionSettings

Enclosing class:

PulsarContainerProperties

public static class PulsarContainerProperties.TransactionSettings
extends TransactionProperties

Transaction related settings.

Since:

1.1.0

Constructor Summary

Constructors

Constructor	Description
TransactionSettings()

Method Summary

Modifier and Type	Method	Description
TransactionDefinition	determineTransactionDefinition()	Determines the transaction definition to use by respecting any user configured timeout property.
TransactionDefinition	getTransactionDefinition()	Get the transaction definition.
PulsarAwareTransactionManager	getTransactionManager()	Gets the transaction manager used to start transactions.
void	setTransactionDefinition(TransactionDefinition transactionDefinition)	Set a transaction definition with properties (e.g.
void	setTransactionManager(PulsarAwareTransactionManager transactionManager)	Set the transaction manager to start a transaction.

Methods inherited from class org.springframework.pulsar.core.TransactionProperties

getTimeout, isEnabled, isRequired, setEnabled, setRequired, setTimeout

Methods inherited from class java.lang.Object

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

Constructor Details

TransactionSettings

public TransactionSettings()

Method Details

getTransactionDefinition

@Nullable
public TransactionDefinition getTransactionDefinition()

Get the transaction definition.

Returns:

the definition

setTransactionDefinition

public void setTransactionDefinition(@Nullable
 TransactionDefinition transactionDefinition)

Set a transaction definition with properties (e.g. timeout) that will be copied to the container's transaction template.

Parameters:

transactionDefinition - the definition

determineTransactionDefinition

public TransactionDefinition determineTransactionDefinition()

Determines the transaction definition to use by respecting any user configured timeout property.

Returns:

the transaction definition to use including any user specified timeout setting

getTransactionManager

@Nullable
public PulsarAwareTransactionManager getTransactionManager()

Gets the transaction manager used to start transactions.

Returns:

the transaction manager

setTransactionManager

public void setTransactionManager(@Nullable
 PulsarAwareTransactionManager transactionManager)

Set the transaction manager to start a transaction.

Parameters:

transactionManager - the transaction manager