Skip to content

Commit

Permalink
Update deps and fix some tests
Browse files Browse the repository at this point in the history
  • Loading branch information
ejsmith committed Jan 30, 2022
1 parent d58a4c7 commit efbccc4
Show file tree
Hide file tree
Showing 3 changed files with 22 additions and 1 deletion.
2 changes: 2 additions & 0 deletions Foundatio.sln
Original file line number Diff line number Diff line change
Expand Up @@ -13,6 +13,8 @@ Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Solution Items", "Solution
src\Directory.Build.props = src\Directory.Build.props
samples\Directory.Build.props = samples\Directory.Build.props
NuGet.config = NuGet.config
global.json = global.json
Dockerfile = Dockerfile
README.md = README.md
EndProjectSection
EndProject
Expand Down
18 changes: 18 additions & 0 deletions src/Foundatio/Messaging/scenarios.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,18 @@
- Multiple receivers (pub/sub)
- Fire and forget
- Message acknowledgement
- Worker queues
- Single Worker
- Round robin workers
- Delayed delivery
- Can schedule delivery, messages are persisted to a message store and a background task polls for messages that are due and then sends them out
- Message persistence
- Not all messages need to be persisted and guaranteed delivery
- Message subscriptions are push based with prefetch count setting which should greatly improve throughput
- Can either use generic method overloads or use options to change the message type or topic the message is being published to
- Can subscribe to multiple message types by controlling the message topic instead of using the default topic per .net type
- Request/response
- Publishes message and then does a single message receive on a topic that is for that exact request and waits the specified amount of time
- Receive message (pull model)
- Equivalent of current worker queues pulling a single message at a time
- Ability to receive a batch of messages
3 changes: 2 additions & 1 deletion tests/Foundatio.Tests/Utility/SystemClockTests.cs
Original file line number Diff line number Diff line change
Expand Up @@ -21,9 +21,10 @@ public void CanSetTime() {
Assert.Equal(now.ToLocalTime(), clock.Now);
Assert.Equal(now.ToUniversalTime(), clock.OffsetUtcNow);

// set using utc
now = DateTime.UtcNow;
clock.SetTime(now);
Assert.Equal(now, clock.Now);
Assert.Equal(now, clock.UtcNow);
Assert.Equal(DateTimeOffset.Now.Offset, clock.Offset);
Assert.Equal(now.ToUniversalTime(), clock.UtcNow);
Assert.Equal(now.ToLocalTime(), clock.Now);
Expand Down

0 comments on commit efbccc4

Please sign in to comment.