Skip to content

Commit a7888ca

Browse files
committed
Merge branch 'hotfix-2.1.3'
2 parents 8ac481d + 0550074 commit a7888ca

File tree

154 files changed

+1311
-317
lines changed

Some content is hidden

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

154 files changed

+1311
-317
lines changed

packaging/nuget/NServiceBus.RabbitMQ.nuspec

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -12,11 +12,11 @@
1212
<requireLicenseAcceptance>true</requireLicenseAcceptance>
1313
<description>RabbitMQ support for NServicebus</description>
1414
<releaseNotes></releaseNotes>
15-
<copyright>Copyright 2010-2014 NServiceBus. All rights reserved</copyright>
15+
<copyright>Copyright 2010-2015 NServiceBus. All rights reserved</copyright>
1616
<tags>nservicebus servicebus msmq cqrs publish subscribe</tags>
1717
<dependencies>
1818
<dependency id="NServiceBus" version="[5.0.0, 6.0.0)" />
19-
<dependency id="RabbitMQ.Client" version="[3.4.3]" />
19+
<dependency id="RabbitMQ.Client" version="[3.5.0, 3.6.0)" />
2020
</dependencies>
2121
</metadata>
2222
<files>
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,72 @@
1+
namespace NServiceBus.AcceptanceTests.Audit
2+
{
3+
using System;
4+
using EndpointTemplates;
5+
using AcceptanceTesting;
6+
using NServiceBus.Config;
7+
using NUnit.Framework;
8+
9+
public class When_ForwardReceivedMessagesTo_is_set : NServiceBusAcceptanceTest
10+
{
11+
[Test]
12+
public void Should_forward_message()
13+
{
14+
var context = new Context();
15+
16+
Scenario.Define(context)
17+
.WithEndpoint<EndpointThatForwards>(b => b.Given((bus, c) =>
18+
{
19+
bus.SendLocal(new MessageToForward());
20+
}))
21+
.WithEndpoint<ForwardReceiver>()
22+
.Done(c => c.GotForwardedMessage)
23+
.Run();
24+
25+
Assert.IsTrue(context.GotForwardedMessage);
26+
}
27+
28+
public class Context : ScenarioContext
29+
{
30+
public bool GotForwardedMessage { get; set; }
31+
}
32+
33+
public class ForwardReceiver : EndpointConfigurationBuilder
34+
{
35+
public ForwardReceiver()
36+
{
37+
EndpointSetup<DefaultServer>(c => c.EndpointName("forward_receiver"));
38+
}
39+
40+
public class MessageToForwardHandler : IHandleMessages<MessageToForward>
41+
{
42+
public Context Context { get; set; }
43+
44+
public void Handle(MessageToForward message)
45+
{
46+
Context.GotForwardedMessage = true;
47+
}
48+
}
49+
}
50+
51+
public class EndpointThatForwards : EndpointConfigurationBuilder
52+
{
53+
public EndpointThatForwards()
54+
{
55+
EndpointSetup<DefaultServer>()
56+
.WithConfig<UnicastBusConfig>(c => c.ForwardReceivedMessagesTo = "forward_receiver");
57+
}
58+
59+
public class MessageToForwardHandler : IHandleMessages<MessageToForward>
60+
{
61+
public void Handle(MessageToForward message)
62+
{
63+
}
64+
}
65+
}
66+
67+
[Serializable]
68+
public class MessageToForward : IMessage
69+
{
70+
}
71+
}
72+
}

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

File renamed without changes.

src/NServiceBus.RabbitMQ.AcceptanceTests/App_Packages/NSB.AcceptanceTests.5.1.3/Audit/When_a_replymessage_is_audited.cs renamed to src/NServiceBus.RabbitMQ.AcceptanceTests/App_Packages/NSB.AcceptanceTests.5.2.0/Audit/When_a_replymessage_is_audited.cs

File renamed without changes.

src/NServiceBus.RabbitMQ.AcceptanceTests/App_Packages/NSB.AcceptanceTests.5.1.3/Audit/When_auditing.cs renamed to src/NServiceBus.RabbitMQ.AcceptanceTests/App_Packages/NSB.AcceptanceTests.5.2.0/Audit/When_auditing.cs

File renamed without changes.

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

File renamed without changes.

src/NServiceBus.RabbitMQ.AcceptanceTests/App_Packages/NSB.AcceptanceTests.5.1.3/Basic/When_Deferring_a_message.cs renamed to src/NServiceBus.RabbitMQ.AcceptanceTests/App_Packages/NSB.AcceptanceTests.5.2.0/Basic/When_Deferring_a_message.cs

File renamed without changes.

src/NServiceBus.RabbitMQ.AcceptanceTests/App_Packages/NSB.AcceptanceTests.5.1.3/Basic/When_TimeToBeReceived_has_expired.cs renamed to src/NServiceBus.RabbitMQ.AcceptanceTests/App_Packages/NSB.AcceptanceTests.5.2.0/Basic/When_TimeToBeReceived_has_expired.cs

File renamed without changes.

src/NServiceBus.RabbitMQ.AcceptanceTests/App_Packages/NSB.AcceptanceTests.5.1.3/Basic/When_TimeToBeReceived_has_not_expired.cs renamed to src/NServiceBus.RabbitMQ.AcceptanceTests/App_Packages/NSB.AcceptanceTests.5.2.0/Basic/When_TimeToBeReceived_has_not_expired.cs

File renamed without changes.

src/NServiceBus.RabbitMQ.AcceptanceTests/App_Packages/NSB.AcceptanceTests.5.1.3/Basic/When_a_callback_for_local_message.cs renamed to src/NServiceBus.RabbitMQ.AcceptanceTests/App_Packages/NSB.AcceptanceTests.5.2.0/Basic/When_a_callback_for_local_message.cs

File renamed without changes.

0 commit comments

Comments
 (0)