File tree Expand file tree Collapse file tree 1 file changed +37
-0
lines changed Expand file tree Collapse file tree 1 file changed +37
-0
lines changed Original file line number Diff line number Diff line change @@ -6,6 +6,43 @@ MSMQ (Microsoft Message Queuing) helper library
6
6
Install-Package MsmqExts
7
7
```
8
8
9
+ ### Simple Publisher
10
+ ``` csharp
11
+ var _jobQueue = new MsmqJobQueue ();
12
+ var obj = new Product
13
+ {
14
+ Id = 1 ,
15
+ Name = @" Jin"
16
+ };
17
+
18
+ _jobQueue .Enqueue (" my-queue" , obj );
19
+ ```
20
+
21
+ ### Simple Consumer
22
+ ``` csharp
23
+ CancellationTokenSource tokenSource = new CancellationTokenSource ();
24
+ CancellationToken token = tokenSource .Token ;
25
+
26
+ var _jobQueue = new MsmqJobQueue ();
27
+ var deObj = _jobQueue .Dequeue (" my-queue" , token );
28
+
29
+ try
30
+ {
31
+ if (deObj .Result is Product prod )
32
+ {
33
+ Console .WriteLine ($" - processing product <{prod .Id }>" );
34
+ }
35
+ deObj .RemoveFromQueue ();
36
+ }
37
+ catch (Exception ex )
38
+ {
39
+ Console .WriteLine ($" Error: {ex .Message }" );
40
+
41
+ deObj .Requeue ();
42
+ deObj .Dispose ();
43
+ }
44
+ ```
45
+
9
46
### Feature:
10
47
- Transaction
11
48
- Fetch batch messages
You can’t perform that action at this time.
0 commit comments