public class EventRouter<T extends Throwable> extends Object implements Output<DomainEventValue,T>, Receiver<UnitOfWorkDomainEventsValue,T>
Constructor and Description |
---|
EventRouter() |
Modifier and Type | Method and Description |
---|---|
EventRouter |
defaultReceiver(Receiver<DomainEventValue,T> defaultReceiver) |
void |
receive(UnitOfWorkDomainEventsValue item)
Receive a single item of the given type.
|
<SenderThrowableType extends Throwable> |
receiveFrom(Sender<? extends DomainEventValue,SenderThrowableType> sender)
This initiates a transfer from an Input.
|
EventRouter |
route(Specification<DomainEventValue> specification,
Receiver<DomainEventValue,T> receiver) |
public EventRouter route(Specification<DomainEventValue> specification, Receiver<DomainEventValue,T> receiver)
public EventRouter defaultReceiver(Receiver<DomainEventValue,T> defaultReceiver)
public <SenderThrowableType extends Throwable> void receiveFrom(Sender<? extends DomainEventValue,SenderThrowableType> sender) throws T extends Throwable, SenderThrowableType extends Throwable
Output
receiveFrom
in interface Output<DomainEventValue,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
public void receive(UnitOfWorkDomainEventsValue item) throws T extends Throwable
Receiver