Fork Sync: Update from parent repository #4

…anges. May cause a PRECONDITION-FAILURE if specified with previous versions due to an exchange type change to FANOUT.

…onary.

…ngs (#5103) * fix: migrate postgres tests to their own file * fix: add function to handle @ in postgres user names * fix: revert dot settings * fix: revert dot settings

…ngs (#5103)

…pace check

…s scope, causing failing unit test.

…olved it by calling the proper method to create the topology

… Delivery service to scale up properly, Reworked the request rate algorithm to support delayed cancellation of in-flight requests.

…emory is stupid fast, most brokers are slower) so that request

…ut for request clients created from the container.

…ssages were processed, ensuring rapido delivery.

…ble schema caching when using multiple DbContext's

…L when a concurrent update is not allowed.

…cenarios

…vice Bus to check if the context is a service bus context.

… hub, and the SQL transport

…st projects.

… ICredentialsRefresher (RabbitMQ).

…ional connection string parameters

…EF-style optimistic concurrency checking.

… wrapped in an SNS envelope when deserializing using System.Text.Json only.

…ched

…ed access to the QueueInfo when adding subscriptions to reduce race condition.

…rameter, fixed some topology bugs in publish/consume

… parameter type (object vs Guid?) for schedulingTokenId.

…not properly specifying the delay parameter

…n be canceled

…llow MultiBus with separate settings.

…urable on each bus instance instead of overwriting the default bus instance.

…ach server URI for ActiveMQ connection

… to process the scheduled message job.

…Type parameter is available

…ed to the ConsumerAgent for processing.

Let's be correct here.

* Bump Azure.Identity GHSA-m5vv-6r4h-3vj9 * Bump Npgsql GHSA-x9vc-6hfv-hg8c

…d/or ports

…n copying raw message body

…s ignored on Get, but wasn't ignored on Set)

…iddleware...` Resolves > System.InvalidOperationException: 'EndpointRoutingMiddleware matches endpoints setup by EndpointMiddleware and so must be added to the request execution pipeline before EndpointMiddleware. Please add EndpointRoutingMiddleware by calling 'IApplicationBuilder.UseRouting' inside the call to 'Configure(...)' in the application startup code.'

…nitial feedback (see #2788)

…stead of the create database, since it's required to exist.

…g a RabbitMQ stream

…y to ensure additional patterns are added only to a valid condition/statement/etc.

… JsonSerializerOptions to exclude messages from the default serialization overrides.

…ssage with RabbitMQ

… request is forwarded to another consumer for handling.

…lly stopping the bus after being restarted.

…d higher performance suitable for most scenarios.

…edHangfireScheduledMessageData The HashCleanup doesn't work with the HangfireScheduledMessageData type because it does not implement the IHashedScheduleId interface. As a result, the hashId key is not removed from Redis database after job is executed. This commit fixes this issue.

…rameters (all optional)

…t an existing database

… test timeout

…rrent version adsf

…ons to increase it if necessary

@phatboyg

…#5375) * SqlTransport -> Use configured schema when listening to notifications Hi @phatboyg I found an issue with the Listen (postgres) notifications part where the schema is hardcoded to be "transport" Since it is allowed to have a different schema that is passed via options and the PostgresDatabaseMigrator uses it for creating the trigger script, we should have it aligned in the C# code. * Sanitize schema name to fit postgres channel requirements

* remove promotion of Quartz's Newtonsoft based Quartz.Serialization.Json * remove unused Quartz.Plugins.TimeZoneConverter * fix XML doc comments * remove unnecessary compiler warnings suppression * remove usage of obsolete UseMicrosoftDependencyInjectionJobFactory

@phatboyg

* SqlTransport -> Use configured schema when listening to notifications Hi @phatboyg I found an issue with the Listen (postgres) notifications part where the schema is hardcoded to be "transport" Since it is allowed to have a different schema that is passed via options and the PostgresDatabaseMigrator uses it for creating the trigger script, we should have it aligned in the C# code. * Sanitize schema name to fit postgres channel requirements * Surround schema name with double quotes to prevent dbMigrator failures

…ion denied

…h concurrent readers the way SQL can

…es should now work properly.

…ransport with job saga endpoints. Also added inline endpoint configuration ability.

…ed from the batch. Empty batches should be "ignored."

…th other frameworks.

…hen not found.

…nerable package.json packages.

… now)

…gned underlying MongoDB driver.

This reverts commit fbf5956.

…nnections, and also allow passing a data source instead of a connection string.

…5482) * update host config * use dataSource from injection

…me error with the service collection configuration

…r saga repository to replace the implementation

…a the request client or publish endpoint

…nd disposable, added default schema, unit test to ensure it all works.

… or error queue which can be called from any query tool

…s and seems to be a relic from the past

…g messages and fault responses/notifications Co-authored-by: WilliamBZA <WilliamBZA@users.noreply.github.com>

…type in documentation

…unt, and ForwardTo when an Azure Service Bus subscription is changed.

…h other platform-related errors

… OutboxState, to aid with deletion/cleanup.

…t not handled in state errors when a timeout is received after the request has faulted.

…ntations for missing contact interfaces, changed IDictionary to Dictionary (performance)

…comparison logic

…5538) * #5534 - Use sequence number for batch order where available * use TryGetPayload instead of routing through MessageHeaders * rename to Index * add DeliveryMessageId as sequence for SqlTransport * handle null payload * use ReceiveContext directly

… no longer creating a subscription on the instance. Also, made it so that jobs canceled when an instance was stopped are automatically rescheduled for the next available job consumer instance.

…a maps as well.

…en no messages are present to avoid deletion of the queue

Co-authored-by: WilliamBZA <WilliamBZA@users.noreply.github.com>

…column order/names

…mn tweak

…n a job was canceled or faulted.

…wed by entity names for RabbitMQ.

Co-authored-by: WilliamBZA <WilliamBZA@users.noreply.github.com>

…ng job/instance properties that can be used by the strategy to allocate job slots. Also added global concurrent job limit across all instances (optional).

…ting key and partition key

fix typo

…the same node, and to avoid extensive delays during the polling interval when messages are handled.

…ed the new method separately.

… to allow better differentiation when building job distribution strategies.

…b consumers

…port for RabbitMQ direct REPLY-TO request client using SetRabbitMqReplyToRequestClientFactory

…control of MaxConcurrentSessions (#5548) * batching for session enabled ASB entities with better control over max concurrency * add docs, encapsulate defaults, better naming * add documentation for discovery * align SDK default for SessionIdleTimeout * ensure if Prefetch is enabled it is at least enough to fill the session batch

…Service Bus

Add header MT-Activity-Propagation that configures how remote activity is treated. Either: 1. Link the remote activity 2. Use as parent activity (default) 3. Create new activity without reference to remote activity

… parameters (#5568) * Fixed failover parameters. Added priorityBackup and priorityURIs parameters * fixed activemq failover transport test

…bus - quickstart

Enabled nullable throughout MassTransit.MessagePack & moved InternalJsonExtensions.cs into MassTransit.Internals namespace. Project cleanup

…lly exist.

…method locations.

…entation

…rom O(n) to O(1), where 'n' is the number of registered type mappers.

…e next activity in the behavior chain.

…ing message schedules

Fix typo in 13.job-consumers.md where the RetryJob code example was calling the wrong method

Minor typo from 77682d61e2707d1d415

…nges after a consumer completes, produce a typed Fault<T>

* Fix requeue_message PostgreSQL routine, RequeueMessage MSSQL procedure locks, requeue_messages MSSQL message count, requeue_messages order for all SQL transports

…posed exception

…to clear the RequestId on faulted state machine requests

…ny unsuspected logic errors

…on method to set the RabbitMQ stream filter value

Commits on May 25, 2024

Add CosmosDB test

NooNameR authored and phatboyg committed May 25, 2024

Configuration menu

View commit details

Copy full SHA for fbf5956

Browse repository at this point

Copy the full SHA

fbf5956 View commit details

Browse the repository at this point in the history

Commits on Jul 30, 2024

Added some missing documentation content.

phatboyg committed Jul 30, 2024

Configuration menu

View commit details

Copy full SHA for 41ea46f

Browse repository at this point

Copy the full SHA

41ea46f View commit details

Browse the repository at this point in the history

Commits on Sep 12, 2024

Adding recurring job consumers

phatboyg committed Sep 12, 2024

Configuration menu

View commit details

Copy full SHA for f5dc4b2

Browse repository at this point

Copy the full SHA

f5dc4b2 View commit details

Browse the repository at this point in the history

Fork Sync: Update from parent repository #4

Are you sure you want to change the base?

Fork Sync: Update from parent repository #4

Commits on Apr 15, 2024

Commits on Apr 16, 2024

Commits on Apr 17, 2024

Commits on Apr 18, 2024

Commits on Apr 19, 2024

Commits on Apr 20, 2024

Commits on Apr 21, 2024

Commits on Apr 25, 2024

Commits on Apr 26, 2024

Commits on Apr 27, 2024

Commits on May 1, 2024

Commits on May 2, 2024

Commits on May 3, 2024

Commits on May 8, 2024

Commits on May 15, 2024

Commits on May 17, 2024

Commits on May 18, 2024

Commits on May 24, 2024

Commits on May 25, 2024

Commits on May 28, 2024

Commits on May 30, 2024

Commits on Jun 6, 2024

Commits on Jun 7, 2024

Commits on Jun 10, 2024

Commits on Jun 11, 2024

Commits on Jun 13, 2024

Commits on Jun 14, 2024

Commits on Jun 15, 2024

Commits on Jun 16, 2024

Commits on Jun 26, 2024

Commits on Jun 27, 2024

Commits on Jul 1, 2024

Commits on Jul 2, 2024

Commits on Jul 3, 2024

Commits on Jul 10, 2024

Commits on Jul 11, 2024

Commits on Jul 12, 2024

Commits on Jul 16, 2024

Commits on Jul 18, 2024

Commits on Jul 21, 2024

Commits on Jul 22, 2024

Commits on Jul 27, 2024

Commits on Jul 28, 2024

Commits on Jul 30, 2024

Commits on Aug 2, 2024

Commits on Aug 3, 2024

Commits on Aug 5, 2024

Commits on Aug 6, 2024

Commits on Aug 7, 2024

Commits on Aug 8, 2024

Commits on Aug 12, 2024

Commits on Aug 13, 2024

Commits on Aug 14, 2024

Commits on Aug 18, 2024

Commits on Aug 20, 2024

Commits on Aug 22, 2024

Commits on Aug 26, 2024

Commits on Aug 29, 2024

Commits on Sep 3, 2024

Commits on Sep 9, 2024

Commits on Sep 10, 2024

Commits on Sep 11, 2024

Commits on Sep 12, 2024

Commits on Sep 13, 2024

Commits on Sep 17, 2024

Commits on Sep 19, 2024

Commits on Sep 20, 2024

Commits on Sep 22, 2024

Commits on Sep 23, 2024

Commits on Sep 24, 2024

Commits on Sep 25, 2024

Commits on Sep 26, 2024

Commits on Sep 27, 2024

Commits on Sep 30, 2024

Commits on Oct 1, 2024

Commits on Oct 2, 2024

Commits on Oct 3, 2024