Skip to content
Permalink

Comparing changes

Choose two branches to see what’s changed or to start a new pull request. If you need to, you can also or learn more about diff comparisons.

Open a pull request

Create a new pull request by comparing changes across two branches. If you need to, you can also . Learn more about diff comparisons here.
base repository: MassTransit/MassTransit
Failed to load repositories. Confirm that selected base ref is valid, then try again.
Loading
base: v8.2.2
Choose a base ref
...
head repository: MassTransit/MassTransit
Failed to load repositories. Confirm that selected head ref is valid, then try again.
Loading
compare: v8.2.3
Choose a head ref

Commits on Apr 26, 2024

  1. Updated version to 8.2.3

    phatboyg committed Apr 26, 2024
    Copy the full SHA
    71429ff View commit details

Commits on Apr 27, 2024

  1. Copy the full SHA
    25fd050 View commit details

Commits on May 1, 2024

  1. Added xmin to PostgresLockStatementFormatter.cs queries to allow for …

    …EF-style optimistic concurrency checking.
    phatboyg committed May 1, 2024
    Copy the full SHA
    12563fa View commit details

Commits on May 2, 2024

  1. Fixed #4510 - Properly handle cross-region or SNS deliveries that are…

    … wrapped in an SNS envelope when deserializing using System.Text.Json only.
    phatboyg committed May 2, 2024
    Copy the full SHA
    1d640dc View commit details
  2. Copy the full SHA
    5e70659 View commit details
  3. Copy the full SHA
    c9561ee View commit details
  4. Copy the full SHA
    25d6373 View commit details

Commits on May 3, 2024

  1. Fixed "Submitted policy is over max allowed size" exception, serializ…

    …ed access to the QueueInfo when adding subscriptions to reduce race condition.
    sergiuciudin authored and phatboyg committed May 3, 2024
    Copy the full SHA
    0381674 View commit details
  2. Added ConfigureConsumeTopology overload that accepts a messageType pa…

    …rameter, fixed some topology bugs in publish/consume
    phatboyg committed May 3, 2024
    Copy the full SHA
    3e8be46 View commit details

Commits on May 8, 2024

  1. Copy the full SHA
    6a81e2d View commit details
  2. Add SQL Quick Start

    drusellers authored and phatboyg committed May 8, 2024
    Copy the full SHA
    4fe74cd View commit details

Commits on May 15, 2024

  1. Copy the full SHA
    4c37cd8 View commit details
  2. Fixed #5185 - Missing parameter on PostgreSQL query, also using wrong…

    … parameter type (object vs Guid?) for schedulingTokenId.
    phatboyg committed May 15, 2024
    Copy the full SHA
    231fb93 View commit details
  3. Fixed #5191 - Redelivery using SQL Server with the SQL Transport was …

    …not properly specifying the delay parameter
    phatboyg committed May 15, 2024
    Copy the full SHA
    2a56e02 View commit details

Commits on May 17, 2024

  1. Copy the full SHA
    40775e9 View commit details
  2. Copy the full SHA
    b2ce0ef View commit details

Commits on May 18, 2024

  1. Separated MessageTopology so that each bus gets its own topology to a…

    …llow MultiBus with separate settings.
    phatboyg committed May 18, 2024
    Copy the full SHA
    be8e177 View commit details

Commits on May 24, 2024

  1. Migrate to EventHub emulator

    NooNameR authored and phatboyg committed May 24, 2024
    Copy the full SHA
    c815611 View commit details
  2. Add Azure Storage tests

    NooNameR authored and phatboyg committed May 24, 2024
    Copy the full SHA
    c76611b View commit details
  3. Enable transaction tests for mongodb

    NooNameR authored and phatboyg committed May 24, 2024
    Copy the full SHA
    9b0634d View commit details

Commits on May 25, 2024

  1. Add CosmosDB test

    NooNameR authored and phatboyg committed May 25, 2024
    Copy the full SHA
    fbf5956 View commit details

Commits on May 28, 2024

  1. When using MultiBus, endpoint name formatters are now properly config…

    …urable on each bus instance instead of overwriting the default bus instance.
    phatboyg committed May 28, 2024
    Copy the full SHA
    7342ec8 View commit details
  2. Set fail over parameters to query and server specific parameters to e…

    …ach server URI for ActiveMQ connection
    McMlok authored and phatboyg committed May 28, 2024
    Copy the full SHA
    033b102 View commit details
  3. Copy the full SHA
    333eea4 View commit details

Commits on May 30, 2024

  1. Copy the full SHA
    a31fe99 View commit details

Commits on Jun 6, 2024

  1. Fixed #4882 - if MessageType isn't found, don't set it and don't fail…

    … to process the scheduled message job.
    phatboyg committed Jun 6, 2024
    Copy the full SHA
    4a3ad9c View commit details

Commits on Jun 7, 2024

  1. Fix summaries of overloads referring to message type while no message…

    …Type parameter is available
    sandord authored and phatboyg committed Jun 7, 2024
    Copy the full SHA
    1353a8a View commit details
  2. Updated package versions

    phatboyg committed Jun 7, 2024
    Copy the full SHA
    5400fbc View commit details

Commits on Jun 10, 2024

  1. Check if endpoint is stopping before allowing messages to be dispatch…

    …ed to the ConsumerAgent for processing.
    phatboyg committed Jun 10, 2024
    Copy the full SHA
    a414629 View commit details

Commits on Jun 11, 2024

  1. Copy the full SHA
    8348aea View commit details

Commits on Jun 13, 2024

  1. Update docs regarding serializer/deserializer

    Let's be correct here.
    stjepan authored and phatboyg committed Jun 13, 2024
    Copy the full SHA
    813a446 View commit details
  2. Upgrade vulnerable packages (#5258)

    * Bump Azure.Identity
    
    GHSA-m5vv-6r4h-3vj9
    
    * Bump Npgsql
    
    GHSA-x9vc-6hfv-hg8c
    stjepan authored Jun 13, 2024
    Copy the full SHA
    806e196 View commit details

Commits on Jun 14, 2024

  1. Copy the full SHA
    f358ac7 View commit details
  2. Copy the full SHA
    5a0cac2 View commit details

Commits on Jun 15, 2024

  1. Copy the full SHA
    7099536 View commit details

Commits on Jun 16, 2024

  1. Fixed #5255 - Newtonsoft not setting raw message headers properly whe…

    …n copying raw message body
    phatboyg committed Jun 16, 2024
    Copy the full SHA
    ff9de5c View commit details
Showing with 2,145 additions and 637 deletions.
  1. +60 −54 .github/workflows/build.yml
  2. +15 −15 Directory.Packages.props
  3. +1 −0 MassTransit.sln.DotSettings
  4. +0 −1 README.md
  5. +7 −0 doc/content/2.quick-starts/0.index.md
  6. +4 −1 doc/content/2.quick-starts/2.rabbitmq.md
  7. +125 −0 doc/content/2.quick-starts/5.postgresql.md
  8. +41 −0 doc/content/3.documentation/2.configuration/0.index.md
  9. +0 −79 doc/content/3.documentation/6.transports/grpc.md
  10. +6 −0 src/MassTransit.Abstractions/Configuration/Middleware/IReceiveEndpointConfigurator.cs
  11. +7 −8 src/MassTransit.Abstractions/Configuration/Topology/IConsumeTopologyConfigurator.cs
  12. +6 −6 src/MassTransit.Abstractions/Configuration/Topology/IMessageConsumeTopologyConfigurator.cs
  13. +2 −0 src/MassTransit.Abstractions/Configuration/Topology/IMessagePublishTopologyConfigurator.cs
  14. +1 −0 src/MassTransit.Abstractions/Configuration/Topology/IMessageSendTopologyConfigurator.cs
  15. +3 −6 src/MassTransit.Abstractions/Contexts/TimeSpanContextScheduleExtensions.cs
  16. +3 −6 src/MassTransit.Abstractions/Contexts/TimeSpanScheduleExtensions.cs
  17. +3 −6 src/MassTransit.Abstractions/Contexts/TimeSpanSchedulePublishExtensions.cs
  18. +2 −4 src/MassTransit.Abstractions/IPublishEndpoint.cs
  19. +1 −2 src/MassTransit.Abstractions/ISendEndpoint.cs
  20. +4 −2 src/MassTransit.Abstractions/MediatorRequestExtensions.cs
  21. +2 −4 src/MassTransit.Abstractions/SchedulePublishExtensions.cs
  22. +2 −4 src/MassTransit.Abstractions/Scheduling/ConsumeContextSchedulerExtensions.cs
  23. +2 −4 src/MassTransit.Abstractions/Scheduling/ConsumeContextSelfSchedulerExtensions.cs
  24. +8 −7 src/MassTransit.Abstractions/Scheduling/IMessageScheduler.cs
  25. +2 −4 src/MassTransit.Abstractions/Scheduling/IRecurringMessageScheduler.cs
  26. +4 −2 src/MassTransit.Abstractions/Scheduling/IScheduleMessageProvider.cs
  27. +1 −2 src/MassTransit.Abstractions/Scheduling/MessageSchedulerContext.cs
  28. +6 −0 src/MassTransit.Abstractions/Topology/Topology/MessagePublishTopology.cs
  29. +6 −0 src/MassTransit.Abstractions/Topology/Topology/MessageSendTopology.cs
  30. +31 −38 src/MassTransit.Abstractions/Topology/Topology/PublishTopology.cs
  31. +7 −3 src/MassTransit.Abstractions/Topology/Topology/SendTopology.cs
  32. +4 −0 src/MassTransit.Newtonsoft/Serialization/NewtonsoftRawJsonBodyMessageSerializer.cs
  33. +1 −1 src/MassTransit.Newtonsoft/Serialization/NewtonsoftRawJsonMessageSerializer.cs
  34. +1 −1 src/MassTransit.Newtonsoft/Serialization/RawXmlMessageSerializer.cs
  35. +1 −1 src/MassTransit.TestFramework/TestConsumeContext.cs
  36. +5 −0 src/MassTransit/Configuration/Configuration/ReceiveEndpointConfiguration.cs
  37. +4 −0 src/MassTransit/Configuration/Configuration/ReceiverConfiguration.cs
  38. +1 −1 src/MassTransit/Configuration/DependencyInjection/TestHarnessOptions.cs
  39. +4 −4 src/MassTransit/Configuration/JsonSerializerConfigurationExtensions.cs
  40. +1 −1 src/MassTransit/Configuration/MediatorConfigurationExtensions.cs
  41. +4 −4 src/MassTransit/Configuration/RawJsonSerializerConfigurationExtensions.cs
  42. +6 −6 src/MassTransit/Contexts/Context/ConsumeMessageSchedulerContext.cs
  43. +1 −2 src/MassTransit/DependencyInjection/Configuration/BusRegistrationContext.cs
  44. +23 −0 src/MassTransit/DependencyInjection/Configuration/DependencyInjectionContainerRegistrar.cs
  45. +2 −0 src/MassTransit/DependencyInjection/Configuration/IContainerRegistrar.cs
  46. +7 −0 src/MassTransit/DependencyInjection/Configuration/IContainerSelector.cs
  47. +1 −2 src/MassTransit/DependencyInjection/Configuration/RegistrationConfigurator.cs
  48. +3 −1 src/MassTransit/DependencyInjection/Configuration/ScopedFilterSpecificationObserver.cs
  49. +8 −8 src/MassTransit/InMemoryTransport/InMemoryBus.cs
  50. +1 −1 src/MassTransit/InMemoryTransport/InMemoryTransport/Configuration/InMemoryRegistrationBusFactory.cs
  51. +1 −1 src/MassTransit/InMemoryTransport/InMemoryTransport/InMemoryConsumeTopology.cs
  52. +12 −0 src/MassTransit/JsonMessageBody.cs
  53. +6 −6 src/MassTransit/Middleware/InMemoryOutbox/InMemoryOutboxMessageSchedulerContext.cs
  54. +5 −5 src/MassTransit/Scheduling/BaseScheduleMessageProvider.cs
  55. +2 −2 src/MassTransit/Scheduling/DelayedScheduleMessageProvider.cs
  56. +2 −2 src/MassTransit/Scheduling/EndpointScheduleMessageProvider.cs
  57. +6 −6 src/MassTransit/Scheduling/MessageScheduler.cs
  58. +2 −2 src/MassTransit/Scheduling/PublishScheduleMessageProvider.cs
  59. +1 −2 src/MassTransit/Serialization/RawMessageSerializer.cs
  60. +1 −1 src/MassTransit/Serialization/SystemTextJsonBodyMessageSerializer.cs
  61. +6 −5 src/MassTransit/Serialization/SystemTextJsonMessageSerializer.cs
  62. +14 −7 src/MassTransit/Serialization/SystemTextJsonRawMessageSerializer.cs
  63. +0 −29 src/MassTransit/SqlTransport/Configuration/SqlBusFactoryConfiguratorExtensions.cs
  64. +54 −1 src/MassTransit/SqlTransport/Configuration/SqlScheduleMessageExtensions.cs
  65. +70 −13 src/MassTransit/SqlTransport/Scheduling/SqlScheduleMessageProvider.cs
  66. +8 −7 src/MassTransit/SqlTransport/SqlBusFactory.cs
  67. +1 −1 src/MassTransit/SqlTransport/SqlTransport/ClientContext.cs
  68. +1 −1 src/MassTransit/SqlTransport/SqlTransport/Configuration/SqlRegistrationBusFactory.cs
  69. +2 −2 src/MassTransit/SqlTransport/SqlTransport/ScopeClientContext.cs
  70. +2 −2 src/MassTransit/SqlTransport/SqlTransport/SharedClientContext.cs
  71. +1 −1 src/MassTransit/SqlTransport/SqlTransport/SqlClientContext.cs
  72. +1 −1 src/MassTransit/SqlTransport/SqlTransport/Topology/SqlConsumeTopology.cs
  73. +1 −1 src/MassTransit/Testing/AsyncTestHarness.cs
  74. +1 −1 src/MassTransit/Testing/InMemoryTestHarness.cs
  75. +60 −22 src/MassTransit/Topology/ConsumeTopology.cs
  76. +1 −1 src/MassTransit/Transports/Fabric/MessageFabric.cs
  77. +2 −2 ...t.EntityFrameworkCoreIntegration/EntityFrameworkCoreIntegration/PostgresLockStatementFormatter.cs
  78. +7 −2 src/Scheduling/MassTransit.QuartzIntegration/QuartzIntegration/ScheduledMessageJob.cs
  79. +8 −10 src/Transports/MassTransit.ActiveMqTransport/ActiveMqBusFactory.cs
  80. +1 −1 ...s/MassTransit.ActiveMqTransport/ActiveMqTransport/Configuration/ActiveMqRegistrationBusFactory.cs
  81. +33 −6 ...sports/MassTransit.ActiveMqTransport/ActiveMqTransport/Configuration/ConfigurationHostSettings.cs
  82. +3 −0 src/Transports/MassTransit.ActiveMqTransport/ActiveMqTransport/Middleware/ActiveMqConsumer.cs
  83. +1 −1 src/Transports/MassTransit.ActiveMqTransport/ActiveMqTransport/Topology/ActiveMqConsumeTopology.cs
  84. +8 −10 src/Transports/MassTransit.AmazonSqsTransport/AmazonSqsBusFactory.cs
  85. +5 −48 src/Transports/MassTransit.AmazonSqsTransport/AmazonSqsTransport/AmazonSqsClientContext.cs
  86. +9 −1 src/Transports/MassTransit.AmazonSqsTransport/AmazonSqsTransport/AmazonSqsHeaderProvider.cs
  87. +8 −2 src/Transports/MassTransit.AmazonSqsTransport/AmazonSqsTransport/AmazonSqsReceiveContext.cs
  88. +1 −1 src/Transports/MassTransit.AmazonSqsTransport/AmazonSqsTransport/ClientContext.cs
  89. +1 −1 ...assTransit.AmazonSqsTransport/AmazonSqsTransport/Configuration/AmazonSqsRegistrationBusFactory.cs
  90. +20 −7 .../MassTransit.AmazonSqsTransport/AmazonSqsTransport/Middleware/ConfigureAmazonSqsTopologyFilter.cs
  91. +2 −2 src/Transports/MassTransit.AmazonSqsTransport/AmazonSqsTransport/QueueCache.cs
  92. +78 −1 src/Transports/MassTransit.AmazonSqsTransport/AmazonSqsTransport/QueueInfo.cs
  93. +1 −1 src/Transports/MassTransit.AmazonSqsTransport/AmazonSqsTransport/ScopeClientContext.cs
  94. +1 −1 src/Transports/MassTransit.AmazonSqsTransport/AmazonSqsTransport/SharedClientContext.cs
  95. +40 −0 src/Transports/MassTransit.AmazonSqsTransport/AmazonSqsTransport/SqsMessageBody.cs
  96. +2 −2 src/Transports/MassTransit.AmazonSqsTransport/AmazonSqsTransport/TopicCache.cs
  97. +3 −1 src/Transports/MassTransit.AmazonSqsTransport/AmazonSqsTransport/TopicInfo.cs
  98. +1 −1 ...Transports/MassTransit.AmazonSqsTransport/AmazonSqsTransport/Topology/AmazonSqsConsumeTopology.cs
  99. +8 −9 src/Transports/MassTransit.Azure.ServiceBus.Core/AzureBusFactory.cs
  100. +7 −0 ...MassTransit.Azure.ServiceBus.Core/AzureServiceBusTransport/Contexts/AzureServiceBusSendContext.cs
  101. +1 −0 ....Azure.ServiceBus.Core/AzureServiceBusTransport/Contexts/AzureServiceBusTransportPropertyNames.cs
  102. +3 −0 src/Transports/MassTransit.Azure.ServiceBus.Core/AzureServiceBusTransport/Receiver.cs
  103. +1 −1 ...ts/MassTransit.Azure.ServiceBus.Core/AzureServiceBusTransport/ServiceBusRegistrationBusFactory.cs
  104. +3 −0 ...orts/MassTransit.Azure.ServiceBus.Core/AzureServiceBusTransport/ServiceBusSendTransportContext.cs
  105. +3 −0 src/Transports/MassTransit.Azure.ServiceBus.Core/AzureServiceBusTransport/SessionReceiver.cs
  106. +1 −1 .../MassTransit.Azure.ServiceBus.Core/AzureServiceBusTransport/Topology/ServiceBusConsumeTopology.cs
  107. +17 −1 ...sports/MassTransit.Azure.ServiceBus.Core/Configuration/ServiceBusMessageSchedulerBusExtensions.cs
  108. +3 −3 src/Transports/MassTransit.Azure.ServiceBus.Core/Scheduling/ServiceBusScheduleMessageProvider.cs
  109. +5 −0 src/Transports/MassTransit.Azure.ServiceBus.Core/ServiceBusSendContext.cs
  110. +6 −0 src/Transports/MassTransit.Azure.ServiceBus.Core/ServiceBusSendContextExtensions.cs
  111. +16 −15 src/Transports/MassTransit.RabbitMqTransport/RabbitMqBusFactory.cs
  112. +1 −1 ...s/MassTransit.RabbitMqTransport/RabbitMqTransport/Configuration/RabbitMqRegistrationBusFactory.cs
  113. +1 −1 src/Transports/MassTransit.RabbitMqTransport/RabbitMqTransport/RabbitMqAddressExtensions.cs
  114. +11 −1 src/Transports/MassTransit.RabbitMqTransport/RabbitMqTransport/RabbitMqBasicConsumer.cs
  115. +1 −1 src/Transports/MassTransit.RabbitMqTransport/RabbitMqTransport/Topology/RabbitMqConsumeTopology.cs
  116. +4 −4 src/Transports/MassTransit.SqlTransport.PostgreSql/SqlTransport/PostgreSql/PostgresClientContext.cs
  117. +1 −1 ...ransports/MassTransit.SqlTransport.PostgreSql/SqlTransport/PostgreSql/PostgresDatabaseMigrator.cs
  118. +30 −4 ...Transports/MassTransit.SqlTransport.PostgreSql/SqlTransport/PostgreSql/PostgresSqlHostSettings.cs
  119. +22 −4 ...rts/MassTransit.SqlTransport.PostgreSql/SqlTransport/PostgreSql/PostgresSqlTransportConnection.cs
  120. +2 −2 src/Transports/MassTransit.SqlTransport.PostgreSql/SqlTransport/PostgreSql/SqlStatements.cs
  121. +12 −5 src/Transports/MassTransit.SqlTransport.SqlServer/SqlTransport/SqlServer/SqlServerClientContext.cs
  122. +4 −4 ...Transports/MassTransit.SqlTransport.SqlServer/SqlTransport/SqlServer/SqlServerDatabaseMigrator.cs
  123. +4 −3 tests/MassTransit.ActiveMqTransport.Tests/Configure_Specs.cs
  124. +107 −0 tests/MassTransit.AmazonSqsTransport.Tests/MessageBody_Specs.cs
  125. +118 −0 tests/MassTransit.AmazonSqsTransport.Tests/MultiBus_Specs.cs
  126. +1 −1 tests/MassTransit.AmazonSqsTransport.Tests/RawJson_Specs.cs
  127. +21 −0 tests/MassTransit.Azure.Cosmos.Tests/docker-compose.yml
  128. +3 −3 tests/MassTransit.Azure.ServiceBus.Core.Tests/BuildTopology_Specs.cs
  129. +1 −9 tests/MassTransit.Azure.Table.Tests/Configuration.cs
  130. +8 −0 tests/MassTransit.Azure.Table.Tests/docker-compose.yml
  131. +84 −0 tests/MassTransit.Benchmark/Latency/SqlMessageLatencyTransport.cs
  132. +1 −0 tests/MassTransit.Benchmark/MassTransit.Benchmark.csproj
  133. +9 −0 tests/MassTransit.Benchmark/Program.cs
  134. +3 −1 tests/MassTransit.Benchmark/ProgramOptionSet.cs
  135. +43 −0 tests/MassTransit.Benchmark/SqlOptionSet.cs
  136. +1 −1 tests/MassTransit.EventHubIntegration.Tests/BatchProducer_Specs.cs
  137. +1 −1 tests/MassTransit.EventHubIntegration.Tests/BatchReceive_Specs.cs
  138. +5 −15 tests/MassTransit.EventHubIntegration.Tests/Configuration.cs
  139. +1 −1 tests/MassTransit.EventHubIntegration.Tests/EndpointConnector_Specs.cs
  140. +1 −1 tests/MassTransit.EventHubIntegration.Tests/Faults_Receive_Specs.cs
  141. +4 −3 tests/MassTransit.EventHubIntegration.Tests/Filter_Specs.cs
  142. +1 −1 tests/MassTransit.EventHubIntegration.Tests/HealthCheck_Specs.cs
  143. +1 −1 tests/MassTransit.EventHubIntegration.Tests/Long_Receive_Specs.cs
  144. +4 −3 tests/MassTransit.EventHubIntegration.Tests/MultiBus_Specs.cs
  145. +1 −1 tests/MassTransit.EventHubIntegration.Tests/Outbox_Specs.cs
  146. +1 −1 tests/MassTransit.EventHubIntegration.Tests/ProducerPipe_Specs.cs
  147. +1 −1 tests/MassTransit.EventHubIntegration.Tests/Producer_Saga_Specs.cs
  148. +2 −2 tests/MassTransit.EventHubIntegration.Tests/Producer_Specs.cs
  149. +3 −4 tests/MassTransit.EventHubIntegration.Tests/Publish_Specs.cs
  150. +2 −2 tests/MassTransit.EventHubIntegration.Tests/Receive_Specs.cs
  151. +4 −3 tests/MassTransit.EventHubIntegration.Tests/Recycle_Specs.cs
  152. +24 −0 tests/MassTransit.EventHubIntegration.Tests/config.json
  153. +22 −0 tests/MassTransit.EventHubIntegration.Tests/docker-compose.yml
  154. +0 −1 tests/MassTransit.MongoDbIntegration.Tests/BusOutbox_Specs.cs
  155. +3 −3 tests/MassTransit.RabbitMqTransport.Tests/BuildTopology_Specs.cs
  156. +3 −3 tests/MassTransit.RabbitMqTransport.Tests/ExcludeTopology_Specs.cs
  157. +32 −0 tests/MassTransit.RabbitMqTransport.Tests/MessageTopology_Specs.cs
  158. +140 −0 tests/MassTransit.SqlTransport.Tests/PgSql/MultiHost_Specs.cs
  159. +78 −0 tests/MassTransit.SqlTransport.Tests/Redelivery_Specs.cs
  160. +132 −0 tests/MassTransit.SqlTransport.Tests/Scheduler_Specs.cs
  161. +59 −0 tests/MassTransit.Tests/ContainerTests/TenantScope_Specs.cs
  162. +117 −0 tests/MassTransit.Tests/Serialization/Redelivery_Specs.cs
114 changes: 60 additions & 54 deletions .github/workflows/build.yml
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
name: MassTransit
env:
MASSTRANSIT_VERSION: 8.2.2
MASSTRANSIT_VERSION: 8.2.3
on:
push:
paths:
@@ -196,7 +196,6 @@ jobs:
working-directory: tests/MassTransit.AmazonSqsTransport.Tests
test-azure-table:
name: "Storage: Azure Table"
if: (github.ref == 'refs/heads/master' || github.ref == 'refs/heads/develop' || github.ref == 'refs/heads/v8') && github.repository == 'MassTransit/MassTransit'
timeout-minutes: 10
runs-on: ubuntu-latest
steps:
@@ -208,16 +207,25 @@ jobs:
with:
dotnet-version: '8.0.x'

- name: Spin up test environment
run: |
docker compose -f docker-compose.yml up -d
working-directory: tests/MassTransit.Azure.Table.Tests

- name: Test Azure Table
env:
MT_AZURE_STORAGE_ACCOUNT: ${{ secrets.AZURE_STORAGE }}
run: dotnet test -c Release --logger:"console;verbosity=normal" --filter "Category!=Flaky&Category!=Integration"
working-directory: tests/MassTransit.Azure.Table.Tests

- name: Stop test environment
run: |
docker compose -f docker-compose.yml down
working-directory: tests/MassTransit.Azure.Table.Tests
test-cosmosdb:
name: "Storage: CosmosDB"
timeout-minutes: 10
runs-on: ubuntu-latest
if: (github.ref == 'refs/heads/master' || github.ref == 'refs/heads/develop' || github.ref == 'refs/heads/v8') && github.repository == 'MassTransit/MassTransit'
steps:
- name: Check out code
uses: actions/checkout@v4
@@ -227,12 +235,28 @@ jobs:
with:
dotnet-version: '8.0.x'

- name: Spin up test environment
run: |
docker compose -f docker-compose.yml up -d
echo "Waiting for CosmosDB at localhost:8081..."
until [ "$(curl -k -s --connect-timeout 5 -o /dev/null -w "%{http_code}" https://localhost:8081/_explorer/emulator.pem)" == "200" ]; do
sleep 5;
echo "Waiting for CosmosDB at localhost:8081..."
done;
curl -k https://localhost:8081/_explorer/emulator.pem > ~/emulatorcert.crt
sudo cp ~/emulatorcert.crt /usr/local/share/ca-certificates/
sudo update-ca-certificates
working-directory: tests/MassTransit.Azure.Cosmos.Tests

- name: Test CosmosDB
env:
MT_COSMOS_ENDPOINT: ${{ secrets.AZURE_COSMOSENDPOINT }}
MT_COSMOS_KEY: ${{ secrets.AZURE_COSMOSKEY }}
run: dotnet test -c Release --logger:"console;verbosity=normal" --filter "Category!=Flaky&Category!=Integration"
working-directory: tests/MassTransit.Azure.Cosmos.Tests

- name: Stop test environment
run: docker compose -f docker-compose.yml down
working-directory: tests/MassTransit.Azure.Cosmos.Tests
test-dapper:
name: "Storage: Dapper"
timeout-minutes: 10
@@ -326,11 +350,6 @@ jobs:
name: "Storage: MongoDB"
timeout-minutes: 10
runs-on: ubuntu-latest
services:
mongo:
image: mongo
ports:
- '27017-27019:27017-27019'
steps:
- name: Check out code
uses: actions/checkout@v4
@@ -340,9 +359,19 @@ jobs:
with:
dotnet-version: '8.0.x'

- name: Spin up test environment
run: |
docker compose -f docker-compose.yml up -d
working-directory: tests/MassTransit.MongoDbIntegration.Tests

- name: Test MongoDB
run: dotnet test -c Release --logger:"console;verbosity=normal" --filter Category!=Flaky
working-directory: tests/MassTransit.MongoDbIntegration.Tests

- name: Stop test environment
run: |
docker compose -f docker-compose.yml down
working-directory: tests/MassTransit.MongoDbIntegration.Tests
test-nhibernate:
name: "Storage: NHibernate"
timeout-minutes: 10
@@ -416,7 +445,6 @@ jobs:
test-eventhub:
name: "Rider: EventHub"
runs-on: ubuntu-latest
if: false # turned off for flakey
steps:
- name: Check out code
uses: actions/checkout@v4
@@ -426,57 +454,25 @@ jobs:
with:
dotnet-version: '8.0.x'

- name: Spin up test environment
run: |
docker compose -f docker-compose.yml up -d
working-directory: tests/MassTransit.EventHubIntegration.Tests

- name: Test EventHub
run: dotnet test -c Release --logger:"console;verbosity=normal" --filter Category!=Flaky
env:
MT_EH_NAMESPACE: ${{ secrets.AZURE_EVENTHUB }}
MT_AZURE_STORAGE_ACCOUNT: ${{ secrets.AZURE_STORAGE }}
working-directory: tests/MassTransit.EventHubIntegration.Tests

- name: Stop test environment
run: |
docker compose -f docker-compose.yml down
working-directory: tests/MassTransit.EventHubIntegration.Tests
test-kafka:
name: "Rider: Kafka"
runs-on: ubuntu-latest
if: true # turned off for flakey
services:
zookeeper:
image: confluentinc/cp-zookeeper:latest
ports:
- "2181:2181"
env:
ZOOKEEPER_CLIENT_PORT: 2181
ZOOKEEPER_TICK_TIME: 2000
broker:
image: confluentinc/cp-kafka:latest
ports:
- "29092:29092"
- "9092:9092"
- "9101:9101"
env:
KAFKA_BROKER_ID: 1
KAFKA_ZOOKEEPER_CONNECT: 'zookeeper:2181'
KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT
KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://broker:29092,PLAINTEXT_HOST://localhost:9092
KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS: 0
KAFKA_CONFLUENT_LICENSE_TOPIC_REPLICATION_FACTOR: 1
KAFKA_CONFLUENT_BALANCER_TOPIC_REPLICATION_FACTOR: 1
KAFKA_TRANSACTION_STATE_LOG_MIN_ISR: 1
KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR: 1
KAFKA_JMX_PORT: 9101
KAFKA_JMX_HOSTNAME: localhost
KAFKA_CONFLUENT_SCHEMA_REGISTRY_URL: http://schema-registry:8081
CONFLUENT_METRICS_REPORTER_BOOTSTRAP_SERVERS: broker:29092
CONFLUENT_METRICS_REPORTER_TOPIC_REPLICAS: 1
CONFLUENT_METRICS_ENABLE: 'false'
options: --health-cmd "nc -vz localhost 9092 || exit 1" --health-interval 10s --health-timeout 5s --health-retries 5
schema-registry:
image: confluentinc/cp-schema-registry:latest
ports:
- "8081:8081"
env:
SCHEMA_REGISTRY_HOST_NAME: schema-registry
SCHEMA_REGISTRY_KAFKASTORE_BOOTSTRAP_SERVERS: 'broker:29092'
SCHEMA_REGISTRY_LISTENERS: http://0.0.0.0:8081
options: --health-cmd "curl --fail http://localhost:8081/subjects || exit 1" --health-interval 10s --health-timeout 5s --health-retries 5
steps:
- name: Check out code
uses: actions/checkout@v4
@@ -486,10 +482,20 @@ jobs:
with:
dotnet-version: '8.0.x'

- name: Spin up test environment
run: |
docker compose -f docker-compose.yml up -d
working-directory: tests/MassTransit.KafkaIntegration.Tests

- name: Test Kafka
run: dotnet test -c Release --logger:"console;verbosity=normal" --filter Category!=Flaky
working-directory: tests/MassTransit.KafkaIntegration.Tests

- name: Stop test environment
run: |
docker compose -f docker-compose.yml down
working-directory: tests/MassTransit.KafkaIntegration.Tests

test-signalr:
name: SignalR
timeout-minutes: 10
30 changes: 15 additions & 15 deletions Directory.Packages.props
Original file line number Diff line number Diff line change
@@ -8,13 +8,13 @@
<PackageVersion Include="AWSSDK.SimpleNotificationService" Version="3.7.301.8" />
<PackageVersion Include="AWSSDK.S3" Version="3.7.307.1" />
<PackageVersion Include="AWSSDK.SQS" Version="3.7.300.60" />
<PackageVersion Include="Azure.Identity" Version="1.11.2" />
<PackageVersion Include="Azure.Messaging.EventHubs.Processor" Version="5.11.2" />
<PackageVersion Include="Azure.Identity" Version="1.11.4" />
<PackageVersion Include="Azure.Messaging.EventHubs.Processor" Version="5.11.3" />
<PackageVersion Include="Azure.Messaging.ServiceBus" Version="7.17.5" />
<PackageVersion Include="Azure.Storage.Blobs" Version="12.19.1" />
<PackageVersion Include="Azure.Storage.Blobs" Version="12.20.0" />
<PackageVersion Include="BenchmarkDotNet" Version="0.13.11" />
<PackageVersion Include="Confluent.Kafka" Version="2.3.0" />
<PackageVersion Include="Confluent.SchemaRegistry.Serdes.Avro" Version="2.3.0" />
<PackageVersion Include="Confluent.Kafka" Version="2.4.0" />
<PackageVersion Include="Confluent.SchemaRegistry.Serdes.Avro" Version="2.4.0" />
<PackageVersion Include="coverlet.collector" Version="3.1.2" />
<PackageVersion Include="Dapper" Version="2.1.35" />
<PackageVersion Include="dapper.contrib" Version="2.0.78" />
@@ -26,16 +26,16 @@
<PackageVersion Include="Iesi.Collections" Version="4.1.1" />
<PackageVersion Include="Ionic.Zlib.Core" Version="1.0.0" />
<PackageVersion Include="Marten" Version="5.11.0" Condition="'$(TargetFramework)' != 'net6.0' AND '$(TargetFramework)' != 'net8.0'" />
<PackageVersion Include="Marten" Version="7.9.0" Condition="'$(TargetFramework)' == 'net6.0' OR '$(TargetFramework)' == 'net8.0'" />
<PackageVersion Include="Marten" Version="7.19.1" Condition="'$(TargetFramework)' == 'net6.0' OR '$(TargetFramework)' == 'net8.0'" />
<PackageVersion Include="MathNet.Numerics" Version="5.0.0" />
<PackageVersion Include="MediatR" Version="12.2.0" />
<PackageVersion Include="Microsoft.ApplicationInsights.AspNetCore" Version="2.22.0" />
<PackageVersion Include="Microsoft.AspNetCore.SignalR.Core" Version="1.1.0" />
<PackageVersion Include="Microsoft.AspNetCore.SignalR.Protocols.MessagePack" Version="7.0.13" />
<PackageVersion Include="Microsoft.Azure.Cosmos" Version="3.39.1" />
<PackageVersion Include="Microsoft.Azure.Cosmos" Version="3.40.0" />
<PackageVersion Include="Microsoft.Azure.Cosmos.Table" Version="1.0.8" />
<PackageVersion Include="Microsoft.Azure.WebJobs.Extensions.EventHubs" Version="6.3.1" />
<PackageVersion Include="Microsoft.Azure.WebJobs.Extensions.ServiceBus" Version="5.15.1" />
<PackageVersion Include="Microsoft.Azure.WebJobs.Extensions.EventHubs" Version="6.3.2" />
<PackageVersion Include="Microsoft.Azure.WebJobs.Extensions.ServiceBus" Version="5.16.0" />
<PackageVersion Include="Microsoft.Bcl.AsyncInterfaces" Version="6.0.0" />
<PackageVersion Include="Microsoft.CodeAnalysis.Analyzers" Version="3.3.4" />
<PackageVersion Include="Microsoft.CodeAnalysis.CSharp.Workspaces" Version="4.1.0" />
@@ -71,7 +71,7 @@
<PackageVersion Include="Newtonsoft.Json" Version="13.0.3" />
<PackageVersion Include="Newtonsoft.Json.Bson" Version="1.0.2" />
<PackageVersion Include="NHibernate" Version="5.5.1" />
<PackageVersion Include="Npgsql" Version="8.0.0" />
<PackageVersion Include="Npgsql" Version="8.0.3" />
<PackageVersion Include="Npgsql.EntityFrameworkCore.PostgreSQL" Version="8.0.0" />
<PackageVersion Include="NUnit" Version="4.1.0" />
<PackageVersion Include="NUnit.Analyzers" Version="4.2.0">
@@ -82,10 +82,10 @@
<PackageVersion Include="OpenTelemetry.Exporter.Jaeger" Version="1.5.1" />
<PackageVersion Include="OpenTelemetry.Exporter.OpenTelemetryProtocol" Version="1.8.1" />
<PackageVersion Include="prometheus-net" Version="6.0.0" />
<PackageVersion Include="Quartz" Version="3.8.1" />
<PackageVersion Include="Quartz.Extensions.Hosting" Version="3.8.1" />
<PackageVersion Include="Quartz.Plugins.TimeZoneConverter" Version="3.8.1" />
<PackageVersion Include="Quartz.Serialization.Json" Version="3.8.1" />
<PackageVersion Include="Quartz" Version="3.9.0" />
<PackageVersion Include="Quartz.Extensions.Hosting" Version="3.9.0" />
<PackageVersion Include="Quartz.Plugins.TimeZoneConverter" Version="3.9.0" />
<PackageVersion Include="Quartz.Serialization.Json" Version="3.9.0" />
<PackageVersion Include="QuikGraph" Version="2.5.0" />
<PackageVersion Include="QuikGraph.Graphviz" Version="2.5.0" />
<PackageVersion Include="RabbitMQ.Client" Version="6.8.1" />
@@ -105,4 +105,4 @@
<ItemGroup>
<GlobalPackageReference Include="Microsoft.SourceLink.GitHub" Version="8.0.0" />
</ItemGroup>
</Project>
</Project>
1 change: 1 addition & 0 deletions MassTransit.sln.DotSettings
Original file line number Diff line number Diff line change
@@ -38,6 +38,7 @@
<s:String x:Key="/Default/CodeStyle/CodeFormatting/CSharpFormat/INDENT_PREPROCESSOR_IF/@EntryValue">OUTDENT</s:String>
<s:String x:Key="/Default/CodeStyle/CodeFormatting/CSharpFormat/INDENT_PREPROCESSOR_OTHER/@EntryValue">USUAL_INDENT</s:String>
<s:String x:Key="/Default/CodeStyle/CodeFormatting/CSharpFormat/INDENT_PREPROCESSOR_REGION/@EntryValue">OUTDENT</s:String>
<s:String x:Key="/Default/CodeStyle/CodeFormatting/CSharpFormat/INDENT_RAW_LITERAL_STRING/@EntryValue">INDENT</s:String>
<s:Int64 x:Key="/Default/CodeStyle/CodeFormatting/CSharpFormat/KEEP_BLANK_LINES_IN_DECLARATIONS/@EntryValue">1</s:Int64>
<s:Boolean x:Key="/Default/CodeStyle/CodeFormatting/CSharpFormat/KEEP_EXISTING_DECLARATION_PARENS_ARRANGEMENT/@EntryValue">False</s:Boolean>
<s:Boolean x:Key="/Default/CodeStyle/CodeFormatting/CSharpFormat/KEEP_EXISTING_EMBEDDED_ARRANGEMENT/@EntryValue">False</s:Boolean>
1 change: 0 additions & 1 deletion README.md
Original file line number Diff line number Diff line change
@@ -136,7 +136,6 @@ Logo Design by _The Agile Badger_
[AmazonS3.nuget]: https://www.nuget.org/packages/MassTransit.AmazonS3
[AmazonSQS.nuget]: https://www.nuget.org/packages/MassTransit.AmazonSQS
[AzureSbCore.nuget]: https://www.nuget.org/packages/MassTransit.Azure.ServiceBus.Core
[Grpc.nuget]: https://www.nuget.org/packages/MassTransit.Grpc
[RabbitMQ.nuget]: https://www.nuget.org/packages/MassTransit.RabbitMQ
[PostgreSQL.nuget]: https://nuget.org/packages/MassTransit.SqlTransport.PostgreSQL/
[SqlServer.nuget]: https://nuget.org/packages/MassTransit.SqlTransport.SqlServer/
7 changes: 7 additions & 0 deletions doc/content/2.quick-starts/0.index.md
Original file line number Diff line number Diff line change
@@ -37,5 +37,12 @@ Transports
#description
Requires an AWS account
::

::card
#title
[PostgreSQL](/quick-starts/postgresql)
#description
For smaller setups
::
::

5 changes: 4 additions & 1 deletion doc/content/2.quick-starts/2.rabbitmq.md
Original file line number Diff line number Diff line change
@@ -16,7 +16,10 @@ This tutorial will get you from zero to up and running with [RabbitMQ](/document
The following instructions assume you are starting from a completed [In-Memory Quick Start](/quick-starts/in-memory)
::

This example requires a functioning installation of the .NET Runtime and SDK (at least 6.0) and a functioning installation of _Docker_ with _Docker Compose_ support enabled.
This example requires the following:

- a functioning installation of the .NET Runtime and SDK (at least 6.0)
- a functioning installation of _Docker_ with _Docker Compose_ support enabled.

## Run RabbitMQ

Loading