Package | Description |
---|---|
com.pivotal.rabbitmq.stream |
Modifier and Type | Method and Description |
---|---|
static Transactional.Identifier |
Transactional.Identifier.from(reactor.rabbitmq.OutboundMessage messageResult) |
static Transactional.Identifier |
Transactional.Identifier.from(String name,
reactor.rabbitmq.AcknowledgableDelivery delivery) |
static Transactional.Identifier |
Transactional.Identifier.from(String name,
long id) |
Transactional.Identifier |
Transaction.id()
Every Transaction has an identifier
|
Transactional.Identifier |
Transactional.id() |
static Transactional.Identifier |
Transactional.Identifier.parse(String value) |
Modifier and Type | Method and Description |
---|---|
R |
TransactionManager.remove(Transactional.Identifier id) |
Constructor and Description |
---|
Identifier(Transactional.Identifier parent,
long id) |
Transactional(Transactional.Identifier id,
T businessObject,
Consumer<Transactional.Identifier> ackHandler,
Consumer<Transactional.Identifier> rejectHandler,
Consumer<Transactional.Identifier> requeueHandler)
For root transaction
|
Constructor and Description |
---|
Transactional(Transactional.Identifier id,
T businessObject,
Consumer<Transactional.Identifier> ackHandler,
Consumer<Transactional.Identifier> rejectHandler,
Consumer<Transactional.Identifier> requeueHandler)
For root transaction
|
Transactional(Transactional.Identifier id,
T businessObject,
Consumer<Transactional.Identifier> ackHandler,
Consumer<Transactional.Identifier> rejectHandler,
Consumer<Transactional.Identifier> requeueHandler)
For root transaction
|
Transactional(Transactional.Identifier id,
T businessObject,
Consumer<Transactional.Identifier> ackHandler,
Consumer<Transactional.Identifier> rejectHandler,
Consumer<Transactional.Identifier> requeueHandler)
For root transaction
|
Copyright © 2021. All rights reserved.