Rebus.SqlServer
Rebus.SqlServer copied to clipboard
rebus-org
:bus: Microsoft SQL Server transport and persistence for Rebus
For Sagas, I configure with syntax like this: ``` rebusConfigurer.Sagas(configurer => { configurer.EnforceExclusiveAccess(); configurer.StoreInSqlServer( config.RebusConfig.PersistenceConnectionFactory, config.RebusConfig.SagaDataDbTable, config.RebusConfig.SagaIndexDbTable); }); ``` For Timeouts, I configure with syntax like this: ``` rebusConfigurer.Timeouts(configurer =>...
Right now, there is no implementation for the periodic outbox cleaner. It simply logs a message like so: ``` async Task RunCleaner() { _logger.Debug("Checking outbox storage for messages to be...
The current Outbox implementation requires both an SqlConnection as well as an SqlTransaction as shown on https://github.com/rebus-org/Rebus/wiki/Outbox : ``` using var connection = GetSqlConnection(); using var transaction = connection.BeginTransaction(); using...
I have a use case where two systems are using rebus as two-way clients with sql server as the transport, each with their own queue name. System1 defers messages to...
Hi, my question is simple - Let's assume I want to send 10000 messages, while being in a message handler already. Can I do optimization in any way? I see...
I just opened #49 and was thinking it'd be good to open up a discussion about this as it's something that's affected us before and I'm sure we're not the...
Because [column sizes are tricky when they are `NVARCHAR`s and they are used in an index](http://dba.stackexchange.com/questions/122000/why-sql-server-has-900-byte-index-size-limit), it should be possible to configure the sizes. It could look like this: Configure.With(...)...
We are still using Rebus 4 and its single message table database schema as transport accross a decent amount of systems. Migrating to the "new" table per queue database schema...
When Rebus.SqlServer is initialized, the following exception occurs in background (although it does not stop the initialization). ``` Microsoft.CSharp.RuntimeBinder.BinderException: ''System.Dynamic.ExpandoObject' does not contain a definition for 'TABLE_SCHEMA'' ``` followed by...
Currently, the interval for forwarding messages from the outbox table to the bus transport is hardcoded to 1 second: ```csharp _forwarder = asyncTaskFactory.Create("OutboxForwarder", RunForwarder, intervalSeconds: 1); ``` To make this...
