the aim of this is to allow the end user to implement a backpresure system if need be
for instance using broadway / dets / persistent_ets / gen_stage ...
Taking broadway as example:
message_middleware would publish events directly to SQS or cast to an SQS publisher
the broadway consumer would receive the message and invoke WalEx.Replication.Publisher.process_message_sync himself
the aim of this is to allow the end user to implement a backpresure system if need be for instance using broadway / dets / persistent_ets / gen_stage ...
Taking broadway as example: