SlimMessageBus
SlimMessageBus copied to clipboard
zarusz
Lightweight message bus interface for .NET (pub/sub and request-response) with transport plugins for popular message brokers.
Sample: https://github.com/Azure/azure-sdk-for-net/blob/main/sdk/servicebus/Azure.Messaging.ServiceBus/samples/Sample06_Transactions.md#transactions-across-entities
Signed-off-by: krivchenko_kv modified: src/SlimMessageBus.Host.Outbox.Sql/SqlOutboxMessageRepository.cs modified: src/SlimMessageBus.Host.Outbox/Services/OutboxSendingTask.cs modified: src/SlimMessageBus.Host/RequestResponse/IPendingRequestStore.cs modified: src/SlimMessageBus.Host/RequestResponse/InMemoryPendingRequestStore.cs modified: src/SlimMessageBus.Host/RequestResponse/PendingRequestManager.cs
Is it often the case that the bus is unavailable? if the sequence of messages is not of particular interest. Maybe we should provide for writing to the outbox only...
From @EtherZa : ``` ... the current implementation could be vastly improved if the message processing were to be partitioned by path (and subscription for ASB). Processing by partition (round-robin,...
I want to create outbox repository for Postgres, and I need the following features to create tables as PARTITION: - generate monotonically increasing PK - choose type for PK (...
It is necessary to add the ability to configure the number of connection attempts (including infinite) and the delay between them. This is required because the connection is established when...
The docker-compose file uses an old Kafka version for our integration tests. We need to use latest and preferably use the confluent community distro [confluentinc/cp-kafka:7.3.10](https://hub.docker.com/layers/confluentinc/cp-kafka/7.3.10/images/sha256-812a9df1d01cb0eadf7035a38d1d5a0e56f15c8aa3dd8e52c0bcd619609c53d2?context=explore). Right now is uses the...