Skip to content

Commit 47fd732

Browse files
committed
Merge pull request #42 from Particular/seamless-scaleout
Seamless scaleout for both callbacks and pubsub
2 parents 54af010 + ed52df4 commit 47fd732

File tree

130 files changed

+1930
-443
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

130 files changed

+1930
-443
lines changed

src/NServiceBus.RabbitMQ.AcceptanceTests/App_Packages/NServiceBus.AcceptanceTests/Audit/When_a_message_is_audited.cs renamed to src/NServiceBus.RabbitMQ.AcceptanceTests/App_Packages/NSB.AcceptanceTests.5.0.0/Audit/When_a_message_is_audited.cs

File renamed without changes.

src/NServiceBus.RabbitMQ.AcceptanceTests/App_Packages/NServiceBus.AcceptanceTests/Audit/When_using_audit_message_is_received.cs renamed to src/NServiceBus.RabbitMQ.AcceptanceTests/App_Packages/NSB.AcceptanceTests.5.0.0/Audit/When_using_audit_message_is_received.cs

File renamed without changes.

src/NServiceBus.RabbitMQ.AcceptanceTests/App_Packages/NServiceBus.AcceptanceTests/Audit/When_using_auditing_as_a_feature.cs renamed to src/NServiceBus.RabbitMQ.AcceptanceTests/App_Packages/NSB.AcceptanceTests.5.0.0/Audit/When_using_auditing_as_a_feature.cs

File renamed without changes.

src/NServiceBus.RabbitMQ.AcceptanceTests/App_Packages/NServiceBus.AcceptanceTests/BasicMessaging/When_Deferring_a_message.cs renamed to src/NServiceBus.RabbitMQ.AcceptanceTests/App_Packages/NSB.AcceptanceTests.5.0.0/Basic/When_Deferring_a_message.cs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
1-
namespace NServiceBus.AcceptanceTests.BasicMessaging
1+
namespace NServiceBus.AcceptanceTests.Basic
22
{
33
using System;
4-
using EndpointTemplates;
5-
using AcceptanceTesting;
4+
using NServiceBus.AcceptanceTesting;
5+
using NServiceBus.AcceptanceTests.EndpointTemplates;
66
using NUnit.Framework;
77

88
public class When_Deferring_a_message : NServiceBusAcceptanceTest

src/NServiceBus.RabbitMQ.AcceptanceTests/App_Packages/NServiceBus.AcceptanceTests/BasicMessaging/When_using_a_message_with_TimeToBeReceived_has_expired.cs renamed to src/NServiceBus.RabbitMQ.AcceptanceTests/App_Packages/NSB.AcceptanceTests.5.0.0/Basic/When_TimeToBeReceived_has_expired.cs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,11 @@
1-
namespace NServiceBus.AcceptanceTests.BasicMessaging
1+
namespace NServiceBus.AcceptanceTests.Basic
22
{
33
using System;
4-
using EndpointTemplates;
5-
using AcceptanceTesting;
4+
using NServiceBus.AcceptanceTesting;
5+
using NServiceBus.AcceptanceTests.EndpointTemplates;
66
using NUnit.Framework;
77

8-
public class When_using_a_message_with_TimeToBeReceived_has_expired : NServiceBusAcceptanceTest
8+
public class When_TimeToBeReceived_has_expired : NServiceBusAcceptanceTest
99
{
1010
[Test, Ignore("The TTL will only be started at the moment the timeoutmanager sends the message back, still giving the test a second to receive it")]
1111
public void Message_should_not_be_received()

src/NServiceBus.RabbitMQ.AcceptanceTests/App_Packages/NServiceBus.AcceptanceTests/BasicMessaging/When_using_a_message_with_TimeToBeReceived_has_not_expired.cs renamed to src/NServiceBus.RabbitMQ.AcceptanceTests/App_Packages/NSB.AcceptanceTests.5.0.0/Basic/When_TimeToBeReceived_has_not_expired.cs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,11 @@
1-
namespace NServiceBus.AcceptanceTests.BasicMessaging
1+
namespace NServiceBus.AcceptanceTests.Basic
22
{
33
using System;
4-
using EndpointTemplates;
5-
using AcceptanceTesting;
4+
using NServiceBus.AcceptanceTesting;
5+
using NServiceBus.AcceptanceTests.EndpointTemplates;
66
using NUnit.Framework;
77

8-
public class When_using_a_message_with_TimeToBeReceived_has_not_expired : NServiceBusAcceptanceTest
8+
public class When_TimeToBeReceived_has_not_expired : NServiceBusAcceptanceTest
99
{
1010
[Test]
1111
public void Message_should_be_received()

src/NServiceBus.RabbitMQ.AcceptanceTests/App_Packages/NServiceBus.AcceptanceTests/BasicMessaging/When_registering_a_callback_for_a_local_message.cs renamed to src/NServiceBus.RabbitMQ.AcceptanceTests/App_Packages/NSB.AcceptanceTests.5.0.0/Basic/When_a_callback_for_local_message.cs

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,12 @@
1-
namespace NServiceBus.AcceptanceTests.BasicMessaging
1+
namespace NServiceBus.AcceptanceTests.Basic
22
{
33
using System;
4-
using EndpointTemplates;
5-
using AcceptanceTesting;
4+
using NServiceBus.AcceptanceTesting;
5+
using NServiceBus.AcceptanceTests.EndpointTemplates;
6+
using NServiceBus.AcceptanceTests.ScenarioDescriptors;
67
using NUnit.Framework;
7-
using ScenarioDescriptors;
88

9-
public class When_registering_a_callback_for_a_local_message : NServiceBusAcceptanceTest
9+
public class When_a_callback_for_local_message : NServiceBusAcceptanceTest
1010
{
1111
[Test]
1212
public void Should_trigger_the_callback_when_the_response_comes_back()

src/NServiceBus.RabbitMQ.AcceptanceTests/App_Packages/NServiceBus.AcceptanceTests/BasicMessaging/When_aborting_the_behavior_chain.cs renamed to src/NServiceBus.RabbitMQ.AcceptanceTests/App_Packages/NSB.AcceptanceTests.5.0.0/Basic/When_aborting_the_behavior_chain.cs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
1-
namespace NServiceBus.AcceptanceTests.BasicMessaging
1+
namespace NServiceBus.AcceptanceTests.Basic
22
{
33
using System;
4-
using AcceptanceTesting;
5-
using EndpointTemplates;
4+
using NServiceBus.AcceptanceTesting;
5+
using NServiceBus.AcceptanceTests.EndpointTemplates;
66
using NUnit.Framework;
77

88
public class When_aborting_the_behavior_chain : NServiceBusAcceptanceTest

src/NServiceBus.RabbitMQ.AcceptanceTests/App_Packages/NServiceBus.AcceptanceTests/BasicMessaging/When_handling_current_message_later.cs renamed to src/NServiceBus.RabbitMQ.AcceptanceTests/App_Packages/NSB.AcceptanceTests.5.0.0/Basic/When_handling_current_message_later.cs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,10 @@
1-
namespace NServiceBus.AcceptanceTests.BasicMessaging
1+
namespace NServiceBus.AcceptanceTests.Basic
22
{
33
using System;
4-
using AcceptanceTesting;
5-
using EndpointTemplates;
4+
using NServiceBus.AcceptanceTesting;
5+
using NServiceBus.AcceptanceTests.EndpointTemplates;
6+
using NServiceBus.UnitOfWork;
67
using NUnit.Framework;
7-
using UnitOfWork;
88

99
public class When_handling_current_message_later : NServiceBusAcceptanceTest
1010
{

src/NServiceBus.RabbitMQ.AcceptanceTests/App_Packages/NServiceBus.AcceptanceTests/BasicMessaging/When_handling_incoming_messages_headers_should_be_shared.cs renamed to src/NServiceBus.RabbitMQ.AcceptanceTests/App_Packages/NSB.AcceptanceTests.5.0.0/Basic/When_incoming_headers_should_be_shared.cs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,12 @@
1-
namespace NServiceBus.AcceptanceTests.Sagas
1+
namespace NServiceBus.AcceptanceTests.Basic
22
{
33
using System;
4-
using AcceptanceTesting;
5-
using EndpointTemplates;
4+
using NServiceBus.AcceptanceTesting;
5+
using NServiceBus.AcceptanceTests.EndpointTemplates;
66
using NUnit.Framework;
77

88
[Explicit]
9-
public class When_handling_incoming_messages_headers_should_be_shared : NServiceBusAcceptanceTest
9+
public class When_incoming_headers_should_be_shared : NServiceBusAcceptanceTest
1010
{
1111
[Test]
1212
public void Should_expose_header_in_downstream_handlers()

0 commit comments

Comments
 (0)