1313
1414namespace RabbitMQ . AMQP . Client . Impl
1515{
16+ /// <summary>
17+ /// Implementation of <see cref="IPublisher"/>.
18+ /// </summary>
1619 public class AmqpPublisher : AbstractReconnectLifeCycle , IPublisher
1720 {
1821 private readonly AmqpConnection _connection ;
@@ -30,6 +33,10 @@ public AmqpPublisher(AmqpConnection connection, string? address, IMetricsReporte
3033 _connection . AddPublisher ( _id , this ) ;
3134 }
3235
36+ /// <summary>
37+ /// Open this publisher
38+ /// </summary>
39+ /// <returns>A <see cref="Task"/> representing the async operation.</returns>
3340 public override async Task OpenAsync ( )
3441 {
3542 try
@@ -91,13 +98,11 @@ await base.OpenAsync()
9198 }
9299
93100 /// <summary>
94- /// Publishes a message to the broker in an asynchronous manner.
95- /// The PublishResult is synchronous. In order to increase the performance
96- /// you can use more tasks to publish messages in parallel
101+ /// Publishes a message to the broker asynchronously.
97102 /// </summary>
98103 /// <param name="message"></param>
99104 /// <param name="cancellationToken"></param>
100- /// <returns></returns>
105+ /// <returns>A <see cref="Task"/> representating the await-able result of the publish operation. </returns>
101106 /// <exception cref="InvalidOperationException"></exception>
102107 /// <exception cref="NotSupportedException"></exception>
103108 /// <exception cref="PublisherException"></exception>
@@ -201,6 +206,10 @@ void OutcomeCallback(ILink sender, Message inMessage, Outcome outcome, object st
201206 return publishResultTcs . Task ;
202207 }
203208
209+ /// <summary>
210+ /// Close this publisher
211+ /// </summary>
212+ /// <returns>A <see cref="Task"/> representing the async operation.</returns>
204213 public override async Task CloseAsync ( )
205214 {
206215 if ( _senderLink is null )
0 commit comments