Skip to content

Commit 650ce94

Browse files
authored
Update README.md
1 parent 0657fdf commit 650ce94

File tree

1 file changed

+13
-16
lines changed

1 file changed

+13
-16
lines changed

README.md

Lines changed: 13 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -43,39 +43,36 @@ Tried to fetch a batch 10000 messages, got 10000/10000, avg 0.04ms per message
4343
## Demo
4444
### Simple Publisher
4545
```csharp
46-
var _messageQueue = new MsmqMessageQueue();
46+
var messageQueue = new MsmqMessageQueue(".\\private$\\hungvo-hello");
4747
var obj = new Product
4848
{
4949
Id = 1,
5050
Name = @"Jin"
5151
};
5252

53-
_messageQueue.Enqueue("my-queue", obj);
53+
messageQueue.Enqueue(obj);
5454
```
5555

5656
### Simple Consumer
5757
```csharp
5858
CancellationTokenSource tokenSource = new CancellationTokenSource();
5959
CancellationToken token = tokenSource.Token;
6060

61-
var _messageQueue = new MsmqMessageQueue();
61+
var msmqMessageQueue = new MsmqMessageQueue(".\\private$\\hungvo-hello");
6262

63-
using(var deObj = _messageQueue.Dequeue("my-queue", token))
63+
try
6464
{
65-
try
65+
var message = _messageQueue.Dequeue(token);
66+
if (message.Result is Product prod)
6667
{
67-
if (deObj.Result is Product prod)
68-
{
69-
Console.WriteLine($"- processing product <{prod.Id}>");
70-
}
71-
deObj.Commit();
72-
}
73-
catch (Exception ex)
74-
{
75-
Console.WriteLine($"Error: {ex.Message}");
76-
77-
deObj.Abort();
68+
Console.WriteLine($"- processing product <{prod.Id}>");
7869
}
70+
message.Commit();
71+
}
72+
catch (Exception ex)
73+
{
74+
Console.WriteLine($"Error: {ex.Message}");
75+
message.Abort();
7976
}
8077
```
8178

0 commit comments

Comments
 (0)