+ {
+ return send(transfer.getId(), EventType.NEW_TRANSFER, NewTransferEvent.ofTransfer(transfer));
+ }
+
+ public CompletableFuture<?> send(Long id, Transfer.State state)
+ {
+ return send(id, EventType.TRANSFER_STATE_CHANGED, new TransferStateChangedEvent(id, state));
+ }
+
+ private CompletableFuture send(Long id, byte eventType, Object payload)