Constructor Detail

• UnitOfWorkRouter

  public UnitOfWorkRouter()

Method Detail

• route

  public UnitOfWorkRouter route(Specification<UnitOfWorkDomainEventsValue> specification,
                       Receiver<UnitOfWorkDomainEventsValue,T> receiver)

• defaultReceiver

  public UnitOfWorkRouter defaultReceiver(Receiver<UnitOfWorkDomainEventsValue,T> defaultReceiver)

• receiveFrom

  public <SenderThrowableType extends Throwable> void receiveFrom(Sender<? extends UnitOfWorkDomainEventsValue,SenderThrowableType> sender)
                   throws T extends Throwable,
                          SenderThrowableType extends Throwable

  Description copied from interface: Output
  This initiates a transfer from an Input. Implementations should open any resources to be written to and then call sender.sendTo() when it is ready to receive data. When sendTo() returns the resource should be closed properly. Make sure to handle any exceptions from sendTo.

  Specified by:

  receiveFrom in interface Output<UnitOfWorkDomainEventsValue,T extends Throwable>

  Type Parameters:

  SenderThrowableType - the exception that sendTo can throw

  Parameters:

  sender - the sender of data to this output

  Throws:

  SenderThrowableType - the exception that the sender can throw

  T extends Throwable