Skip to content

Commit

Permalink
AmazonSQS transport
Browse files Browse the repository at this point in the history
Signed-off-by: Tomasz Maruszak <[email protected]>
  • Loading branch information
zarusz committed Nov 17, 2024
1 parent b7edbb9 commit 618f65d
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 2 deletions.
2 changes: 1 addition & 1 deletion src/SlimMessageBus.Host/Collections/AsyncTaskList.cs
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ static async Task AddNext(Task prevTask, Func<Task> taskFactory)


/// <summary>
/// Awaits (if any) bus intialization (e.g. topology provisining) before we can produce message into the bus.
/// Awaits (if any) bus intialization tasks (e.g. topology provisining) before we can produce message into the bus (or consume messages).
/// </summary>
/// <returns></returns>
public async Task EnsureAllFinished()
Expand Down
8 changes: 7 additions & 1 deletion src/SlimMessageBus.Host/MessageBusBase.cs
Original file line number Diff line number Diff line change
Expand Up @@ -64,7 +64,13 @@ public abstract class MessageBusBase : IDisposable, IAsyncDisposable,
protected bool IsDisposed { get; private set; }

#endregion


/// <summary>
/// Maintains a list of tasks that should be completed before the bus can produce the first message or start consumers.
/// Add async things like
/// - connection creations here to the underlying transport client
/// - provision topology
/// </summary>
protected readonly AsyncTaskList InitTaskList = new();

#region Start & Stop
Expand Down

0 comments on commit 618f65d

Please sign in to comment.