Uses of Interface
com.pivotal.rabbitmq.stream.Transaction

Packages that use Transaction

Package	Description
com.pivotal.rabbitmq
com.pivotal.rabbitmq.source
com.pivotal.rabbitmq.stream

Uses of Transaction in com.pivotal.rabbitmq

Methods in com.pivotal.rabbitmq that return types with arguments of type Transaction

Modifier and Type	Method and Description
static <T> Function<reactor.core.publisher.Flux<Transaction<T>>,reactor.core.publisher.Flux<Transaction<T>>>	ReactiveRabbit.commitElseRejectAndDiscard(Predicate<T> commitPredicate)
static <T> Function<reactor.core.publisher.Flux<Transaction<T>>,reactor.core.publisher.Flux<Transaction<T>>>	ReactiveRabbit.commitElseRejectAndDiscard(Predicate<T> commitPredicate)
static <T> Function<reactor.core.publisher.Flux<Transaction<T>>,reactor.core.publisher.Flux<Transaction<T>>>	ReactiveRabbit.commitElseTerminate()
static <T> Function<reactor.core.publisher.Flux<Transaction<T>>,reactor.core.publisher.Flux<Transaction<T>>>	ReactiveRabbit.commitElseTerminate()
Function<reactor.core.publisher.Flux<Transaction<T>>,reactor.core.publisher.Flux<Transaction<T>>>	TransactionRollbackStrategy.elseCommit()
Function<reactor.core.publisher.Flux<Transaction<T>>,reactor.core.publisher.Flux<Transaction<T>>>	TransactionRollbackStrategy.elseCommit()

Uses of Transaction in com.pivotal.rabbitmq.source

Methods in com.pivotal.rabbitmq.source that return types with arguments of type Transaction

Modifier and Type	Method and Description
reactor.core.publisher.Flux<Transaction<T>>	Source.source()
reactor.core.publisher.Flux<Transaction<T>>	OnDemandSource.source()

Uses of Transaction in com.pivotal.rabbitmq.stream

Classes in com.pivotal.rabbitmq.stream with type parameters of type Transaction

Modifier and Type	Class and Description
class	TransactionManager<T,R extends Transaction<T>>

Classes in com.pivotal.rabbitmq.stream that implement Transaction

Modifier and Type	Class and Description
class	Transactional<T>

Methods in com.pivotal.rabbitmq.stream with type parameters of type Transaction

Modifier and Type	Method and Description
<R extends Transaction<T>> reactor.core.publisher.Flux<R>	TransactionalProducerStream.send(reactor.core.publisher.Flux<R> stream)
protected <R extends Transaction<T>> reactor.core.publisher.Flux<R>	TransactionalProducerStream.send(reactor.core.publisher.Flux<R> stream, reactor.rabbitmq.SendOptions sendOptions)

Methods in com.pivotal.rabbitmq.stream that return Transaction

Modifier and Type	Method and Description
<R> Transaction<R>	Transaction.map(R object) Every Transaction carries a business event however this event may be transformed onto another business event.
<R> Transaction<R>	Transaction.spawn(R value) Every Transaction carries a business event however we can span or split a single Transaction into two or many children Transactions all linked to the parent.

Methods in com.pivotal.rabbitmq.stream that return types with arguments of type Transaction

Modifier and Type	Method and Description
protected reactor.core.publisher.Flux<Transaction<T>>	TransactionalConsumerStream.receiveFromPartitionedQueue(Collection<reactor.rabbitmq.QueueSpecification> queuePartitions)
protected reactor.core.publisher.Flux<Transaction<T>>	TransactionalConsumerStream.receiveFromSingleQueue()

Constructor parameters in com.pivotal.rabbitmq.stream with type arguments of type Transaction

Constructor and Description
IllegalTransactionalEventHandler(P parent, Consumer<Transaction<?>> reject, Consumer<Transaction<?>> terminate)
IllegalTransactionalEventHandler(P parent, Consumer<Transaction<?>> reject, Consumer<Transaction<?>> terminate)