public class UnitOfWorkRouter<T extends Throwable> extends Object implements Output<UnitOfWorkDomainEventsValue,T>
Constructor and Description |
---|
UnitOfWorkRouter() |
Modifier and Type | Method and Description |
---|---|
UnitOfWorkRouter |
defaultReceiver(Receiver<UnitOfWorkDomainEventsValue,T> defaultReceiver) |
<SenderThrowableType extends Throwable> |
receiveFrom(Sender<? extends UnitOfWorkDomainEventsValue,SenderThrowableType> sender)
This initiates a transfer from an Input.
|
UnitOfWorkRouter |
route(Specification<UnitOfWorkDomainEventsValue> specification,
Receiver<UnitOfWorkDomainEventsValue,T> receiver) |
public UnitOfWorkRouter route(Specification<UnitOfWorkDomainEventsValue> specification, Receiver<UnitOfWorkDomainEventsValue,T> receiver)
public UnitOfWorkRouter defaultReceiver(Receiver<UnitOfWorkDomainEventsValue,T> defaultReceiver)
public <SenderThrowableType extends Throwable> void receiveFrom(Sender<? extends UnitOfWorkDomainEventsValue,SenderThrowableType> sender) throws T extends Throwable, SenderThrowableType extends Throwable
Output
receiveFrom
in interface Output<UnitOfWorkDomainEventsValue,T extends Throwable>
SenderThrowableType
- the exception that sendTo can throwsender
- the sender of data to this outputSenderThrowableType
- the exception that the sender can throwT extends Throwable