TransactionManager (reactor-rabbitmq-streams 0.0.9 API)

public class TransactionManager<T,R extends Transaction<T>>
extends Object

Constructors
Constructor and Description
`TransactionManager(String name)`

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`Function<T,R>`	`newTransaction()`
`R`	`newTransaction(T object)`
`R`	`newTransaction(T object, CompletableFuture<T> future)`
`R`	`putTransaction(R tx)`
`Function<reactor.rabbitmq.OutboundMessageResult,R>`	`remove()`
`R`	`remove(reactor.rabbitmq.OutboundMessageResult message)`
`R`	`remove(Transactional.Identifier id)`
`Function<reactor.rabbitmq.OutboundMessageResult,T>`	`removeAndGet()`

public TransactionManager(String name)

public R newTransaction(T object,
                        CompletableFuture<T> future)

public R remove(Transactional.Identifier id)

public R remove(reactor.rabbitmq.OutboundMessageResult message)

public Function<reactor.rabbitmq.OutboundMessageResult,R> remove()

public Function<reactor.rabbitmq.OutboundMessageResult,T> removeAndGet()

Class TransactionManager<T,R extends Transaction<T>>