Repository navigation
Expand file tree
/
Copy pathTestMessageSubscriber.cs
More file actions
99 lines (89 loc) · 2.51 KB
/
Copy pathTestMessageSubscriber.cs
File metadata and controls
99 lines (89 loc) · 2.51 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
/* Unmerged change from project 'PubSubUsingCastleWindsor'
Before:
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using ProjectExtensions.Azure.ServiceBus;
using NLog;
After:
using NLog;
using ProjectExtensions.Azure.ServiceBus;
using System;
using System.Collections.Generic;
using System.Azure.ServiceBus;
using System.Text;
*/
/* Unmerged change from project 'PubSubUsingStructureMap'
Before:
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using ProjectExtensions.Azure.ServiceBus;
using NLog;
After:
using NLog;
using ProjectExtensions.Azure.ServiceBus;
using System;
using System.Collections.Generic;
using System.Azure.ServiceBus;
using System.Text;
*/
/* Unmerged change from project 'PubSubUsingUnity'
Before:
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using ProjectExtensions.Azure.ServiceBus;
using NLog;
After:
using NLog;
using ProjectExtensions.Azure.ServiceBus;
using System;
using System.Collections.Generic;
using System.Azure.ServiceBus;
using System.Text;
*/
/* Unmerged change from project 'PubSubUsingNinject'
Before:
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using ProjectExtensions.Azure.ServiceBus;
using NLog;
After:
using NLog;
using ProjectExtensions.Azure.ServiceBus;
using System;
using System.Collections.Generic;
using System.Azure.ServiceBus;
using System.Text;
*/
using NLog;
using ProjectExtensions.Azure.ServiceBus;
namespace PubSubUsingConfiguration {
[MessageHandlerConfiguration(
DeadLetterAfterMaxRetries = true,
MaxRetries = 2,
PauseTimeIfErrorWasThrown = 15000,
Singleton = true)]
public class TestMessageSubscriber : IHandleMessages<TestMessage> {
static Logger logger = LogManager.GetCurrentClassLogger();
public void Handle(IReceivedMessage<TestMessage> message) {
logger.Info("TestMessageSubscriber Message received: {0} {1}", message.Message.Value, message.Message.MessageId);
//throw new Exception("I hate this message");
}
}
[MessageHandlerConfiguration(
Singleton = true)]
public class TestMessageSubscriberNumber2 : IHandleMessages<TestMessage> {
static Logger logger = LogManager.GetCurrentClassLogger();
public void Handle(IReceivedMessage<TestMessage> message) {
logger.Info("TestMessageSubscriberNumber2 Message received: {0} {1}", message.Message.Value, message.Message.MessageId);
}
}
}