Skip to content

Commit 53b8b1d

Browse files
lukebakkenlukebakken
authored
Merge pull request #51 from rabbitmq/lukebakken/more-api-work
More API work prior to beta
2 parents 4a95106 + a99471e commit 53b8b1d

37 files changed

+181
-44
lines changed

‎RabbitMQ.AMQP.Client/ByteCapacity.cs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
// This source code is dual-licensed under the Apache License, version
2+
// 2.0, and the Mozilla Public License, version 2.0.
3+
// Copyright (c) 2017-2023 Broadcom. All Rights Reserved. The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
4+
15
using System.Text.RegularExpressions;
26

37
namespace RabbitMQ.AMQP.Client;

‎RabbitMQ.AMQP.Client/IAddressBuilder.cs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
// This source code is dual-licensed under the Apache License, version
2+
// 2.0, and the Mozilla Public License, version 2.0.
3+
// Copyright (c) 2017-2023 Broadcom. All Rights Reserved. The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
4+
15
namespace RabbitMQ.AMQP.Client;
26

37
public class InvalidAddressException(string message) : Exception(message);

‎RabbitMQ.AMQP.Client/IConnection.cs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
// This source code is dual-licensed under the Apache License, version
2+
// 2.0, and the Mozilla Public License, version 2.0.
3+
// Copyright (c) 2017-2023 Broadcom. All Rights Reserved. The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
4+
15
using System.Collections.ObjectModel;
26

37
namespace RabbitMQ.AMQP.Client;

‎RabbitMQ.AMQP.Client/IConnectionSettings.cs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
// This source code is dual-licensed under the Apache License, version
2+
// 2.0, and the Mozilla Public License, version 2.0.
3+
// Copyright (c) 2017-2023 Broadcom. All Rights Reserved. The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
4+
15
using System.Net.Security;
26
using System.Security.Authentication;
37
using System.Security.Cryptography.X509Certificates;

‎RabbitMQ.AMQP.Client/IConsumer.cs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
// This source code is dual-licensed under the Apache License, version
2+
// 2.0, and the Mozilla Public License, version 2.0.
3+
// Copyright (c) 2017-2023 Broadcom. All Rights Reserved. The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
4+
15
namespace RabbitMQ.AMQP.Client;
26

37
public class ConsumerException(string message) : Exception(message);

‎RabbitMQ.AMQP.Client/IConsumerBuilder.cs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
// This source code is dual-licensed under the Apache License, version
2+
// 2.0, and the Mozilla Public License, version 2.0.
3+
// Copyright (c) 2017-2023 Broadcom. All Rights Reserved. The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
4+
15
namespace RabbitMQ.AMQP.Client;
26

37
public enum StreamOffsetSpecification

‎RabbitMQ.AMQP.Client/IEntities.cs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
// This source code is dual-licensed under the Apache License, version
2+
// 2.0, and the Mozilla Public License, version 2.0.
3+
// Copyright (c) 2017-2023 Broadcom. All Rights Reserved. The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
4+
15
namespace RabbitMQ.AMQP.Client;
26

37
public interface IEntityInfo

‎RabbitMQ.AMQP.Client/IEntitiesInfo.cs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
// This source code is dual-licensed under the Apache License, version
2+
// 2.0, and the Mozilla Public License, version 2.0.
3+
// Copyright (c) 2017-2023 Broadcom. All Rights Reserved. The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
4+
15
namespace RabbitMQ.AMQP.Client;
26

37
public enum QueueType

‎RabbitMQ.AMQP.Client/IEnvironment.cs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
// This source code is dual-licensed under the Apache License, version
2+
// 2.0, and the Mozilla Public License, version 2.0.
3+
// Copyright (c) 2017-2023 Broadcom. All Rights Reserved. The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
4+
15
using System.Collections.ObjectModel;
26

37
namespace RabbitMQ.AMQP.Client;

‎RabbitMQ.AMQP.Client/ILifeCycle.cs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
// This source code is dual-licensed under the Apache License, version
2+
// 2.0, and the Mozilla Public License, version 2.0.
3+
// Copyright (c) 2017-2023 Broadcom. All Rights Reserved. The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
4+
15
namespace RabbitMQ.AMQP.Client;
26

37
public enum State

‎RabbitMQ.AMQP.Client/IManagement.cs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
// This source code is dual-licensed under the Apache License, version
2+
// 2.0, and the Mozilla Public License, version 2.0.
3+
// Copyright (c) 2017-2023 Broadcom. All Rights Reserved. The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
4+
15
namespace RabbitMQ.AMQP.Client;
26

37
public class ModelException(string message) : Exception(message);

‎RabbitMQ.AMQP.Client/IMessage.cs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
// This source code is dual-licensed under the Apache License, version
2+
// 2.0, and the Mozilla Public License, version 2.0.
3+
// Copyright (c) 2017-2023 Broadcom. All Rights Reserved. The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
4+
15
namespace RabbitMQ.AMQP.Client;
26

37
public interface IMessage

‎RabbitMQ.AMQP.Client/IPublisher.cs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
// This source code is dual-licensed under the Apache License, version
2+
// 2.0, and the Mozilla Public License, version 2.0.
3+
// Copyright (c) 2017-2023 Broadcom. All Rights Reserved. The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
4+
15
namespace RabbitMQ.AMQP.Client;
26

37
public class PublisherException(string message) : Exception(message);

‎RabbitMQ.AMQP.Client/IPublisherBuilder.cs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
// This source code is dual-licensed under the Apache License, version
2+
// 2.0, and the Mozilla Public License, version 2.0.
3+
// Copyright (c) 2017-2023 Broadcom. All Rights Reserved. The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
4+
15
namespace RabbitMQ.AMQP.Client;
26

37
public interface IPublisherBuilder : IAddressBuilder<IPublisherBuilder>

‎RabbitMQ.AMQP.Client/IRecoveryConfiguration.cs

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,8 @@
1-
namespace RabbitMQ.AMQP.Client;
1+
// This source code is dual-licensed under the Apache License, version
2+
// 2.0, and the Mozilla Public License, version 2.0.
3+
// Copyright (c) 2017-2023 Broadcom. All Rights Reserved. The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
24

5+
namespace RabbitMQ.AMQP.Client;
36

47
/// <summary>
58
/// Interface for the recovery configuration.
@@ -36,7 +39,6 @@ public interface IRecoveryConfiguration
3639
IRecoveryConfiguration Topology(bool activated);
3740

3841
bool IsTopologyActive();
39-
4042
}
4143

4244
/// <summary>

‎RabbitMQ.AMQP.Client/ITopologyListener.cs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
// This source code is dual-licensed under the Apache License, version
2+
// 2.0, and the Mozilla Public License, version 2.0.
3+
// Copyright (c) 2017-2023 Broadcom. All Rights Reserved. The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
4+
15
namespace RabbitMQ.AMQP.Client;
26

37
internal interface ITopologyListener

‎RabbitMQ.AMQP.Client/Impl/AbstractLifeCycle.cs

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
// This source code is dual-licensed under the Apache License, version
2+
// 2.0, and the Mozilla Public License, version 2.0.
3+
// Copyright (c) 2017-2023 Broadcom. All Rights Reserved. The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
4+
15
using Amqp;
26

37
namespace RabbitMQ.AMQP.Client.Impl;
@@ -8,11 +12,6 @@ public abstract class AbstractLifeCycle : ILifeCycle
812
{
913
protected bool _disposed;
1014

11-
// TODO this should not be part of AbstractLifeCycle
12-
// wait until the close operation is completed
13-
protected readonly TaskCompletionSource<bool> _connectionCloseTaskCompletionSource =
14-
new(TaskCreationOptions.RunContinuationsAsynchronously);
15-
1615
public virtual Task OpenAsync()
1716
{
1817
OnNewStatus(State.Open, null);

‎RabbitMQ.AMQP.Client/Impl/AmqpBindingSpecification.cs

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,12 @@
1+
// This source code is dual-licensed under the Apache License, version
2+
// 2.0, and the Mozilla Public License, version 2.0.
3+
// Copyright (c) 2017-2023 Broadcom. All Rights Reserved. The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
4+
15
using Amqp.Types;
26

37
namespace RabbitMQ.AMQP.Client.Impl;
48

5-
public abstract class BindingSpecificationBase
9+
public abstract class BindingSpecification
610
{
711
protected string _source = "";
812
protected string _destination = "";
@@ -23,7 +27,7 @@ protected Map ArgsToMap()
2327
}
2428
}
2529

26-
public class AmqpBindingSpecification : BindingSpecificationBase, IBindingSpecification
30+
public class AmqpBindingSpecification : BindingSpecification, IBindingSpecification
2731
{
2832
private readonly AmqpManagement _management;
2933
private readonly ITopologyListener _topologyListener;

‎RabbitMQ.AMQP.Client/Impl/AmqpConnection.cs

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -42,6 +42,9 @@ public class AmqpConnection : AbstractLifeCycle, IConnection
4242
internal ConcurrentDictionary<Guid, IPublisher> Publishers { get; } = new();
4343
internal ConcurrentDictionary<Guid, IConsumer> Consumers { get; } = new();
4444

45+
private readonly TaskCompletionSource _connectionClosedTcs =
46+
new(TaskCreationOptions.RunContinuationsAsynchronously);
47+
4548
public ReadOnlyCollection<IPublisher> GetPublishers()
4649
{
4750
return Publishers.Values.ToList().AsReadOnly();
@@ -131,7 +134,8 @@ await _nativeConnection.CloseAsync()
131134
_semaphoreClose.Release();
132135
}
133136

134-
await _connectionCloseTaskCompletionSource.Task.WaitAsync(TimeSpan.FromSeconds(10))
137+
// TODO configurable timeout?
138+
await _connectionClosedTcs.Task.WaitAsync(TimeSpan.FromSeconds(10))
135139
.ConfigureAwait(false);
136140

137141
OnNewStatus(State.Closed, null);
@@ -344,7 +348,7 @@ void DoClose(Error? argError = null)
344348
Trace.WriteLine(TraceLevel.Verbose, $"{ToString()} is closed");
345349
OnNewStatus(State.Closed, err);
346350
ChangeEntitiesStatus(State.Closed, err);
347-
_connectionCloseTaskCompletionSource.SetResult(true);
351+
_connectionClosedTcs.SetResult();
348352
}
349353

350354
if (error is null)
@@ -449,10 +453,10 @@ await ReconnectEntitiesAsync()
449453
}
450454
catch
451455
{
452-
// TODO set states to Closed? Error?
456+
// TODO set states to Closed? Error? Log exception? Set exception on TCS?
453457
// This will be skipped if reconnection succeeds, but if there
454458
// is an exception, it's important that this be called.
455-
_connectionCloseTaskCompletionSource.SetResult(true);
459+
_connectionClosedTcs.SetResult();
456460
throw;
457461
}
458462
finally

‎RabbitMQ.AMQP.Client/Impl/AmqpConsumerBuilder.cs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
// This source code is dual-licensed under the Apache License, version
2+
// 2.0, and the Mozilla Public License, version 2.0.
3+
// Copyright (c) 2017-2023 Broadcom. All Rights Reserved. The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
4+
15
using Amqp.Types;
26

37
namespace RabbitMQ.AMQP.Client.Impl;

‎RabbitMQ.AMQP.Client/Impl/AmqpEnvironment.cs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
// This source code is dual-licensed under the Apache License, version
2+
// 2.0, and the Mozilla Public License, version 2.0.
3+
// Copyright (c) 2017-2023 Broadcom. All Rights Reserved. The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
4+
15
using System.Collections.Concurrent;
26
using System.Collections.ObjectModel;
37

‎RabbitMQ.AMQP.Client/Impl/AmqpExchangeSpecification.cs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
// This source code is dual-licensed under the Apache License, version
2+
// 2.0, and the Mozilla Public License, version 2.0.
3+
// Copyright (c) 2017-2023 Broadcom. All Rights Reserved. The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
4+
15
using Amqp.Types;
26

37
namespace RabbitMQ.AMQP.Client.Impl;

‎RabbitMQ.AMQP.Client/Impl/AmqpManagement.cs

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
// This source code is dual-licensed under the Apache License, version
2+
// 2.0, and the Mozilla Public License, version 2.0.
3+
// Copyright (c) 2017-2023 Broadcom. All Rights Reserved. The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
4+
15
using System.Collections.Concurrent;
26
using System.Diagnostics;
37
using Amqp;
@@ -39,6 +43,9 @@ public class AmqpManagement : AbstractLifeCycle, IManagement, IManagementTopolog
3943
internal const string Delete = "DELETE";
4044
private const string ReplyTo = "$me";
4145

46+
protected readonly TaskCompletionSource _managementSessionClosedTcs =
47+
new(TaskCreationOptions.RunContinuationsAsynchronously);
48+
4249
internal AmqpManagement(AmqpManagementParameters amqpManagementParameters)
4350
{
4451
_amqpManagementParameters = amqpManagementParameters;
@@ -161,7 +168,7 @@ private void OnManagementSessionClosed(IAmqpObject sender, Amqp.Framing.Error er
161168
OnNewStatus(State.Closed, Utils.ConvertError(error));
162169

163170
// Note: TrySetResult *must* be used here
164-
_connectionCloseTaskCompletionSource.TrySetResult(true);
171+
_managementSessionClosedTcs.TrySetResult();
165172
}
166173

167174
private async Task ProcessResponses()
@@ -468,7 +475,7 @@ public override async Task CloseAsync()
468475
await _managementSession.CloseAsync(closeSpan)
469476
.ConfigureAwait(false);
470477

471-
await _connectionCloseTaskCompletionSource.Task.WaitAsync(closeSpan)
478+
await _managementSessionClosedTcs.Task.WaitAsync(closeSpan)
472479
.ConfigureAwait(false);
473480

474481
_managementSession = null;

‎RabbitMQ.AMQP.Client/Impl/AmqpMessage.cs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
// This source code is dual-licensed under the Apache License, version
2+
// 2.0, and the Mozilla Public License, version 2.0.
3+
// Copyright (c) 2017-2023 Broadcom. All Rights Reserved. The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
4+
15
using Amqp;
26
using Amqp.Framing;
37
using Amqp.Types;

‎RabbitMQ.AMQP.Client/Impl/AmqpPublisherBuilder.cs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
// This source code is dual-licensed under the Apache License, version
2+
// 2.0, and the Mozilla Public License, version 2.0.
3+
// Copyright (c) 2017-2023 Broadcom. All Rights Reserved. The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
4+
15
namespace RabbitMQ.AMQP.Client.Impl;
26

37
public class AddressBuilder : IAddressBuilder<AddressBuilder>

‎RabbitMQ.AMQP.Client/Impl/AmqpQueueSpecification.cs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
// This source code is dual-licensed under the Apache License, version
2+
// 2.0, and the Mozilla Public License, version 2.0.
3+
// Copyright (c) 2017-2023 Broadcom. All Rights Reserved. The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
4+
15
using Amqp;
26
using Amqp.Types;
37

‎RabbitMQ.AMQP.Client/Impl/ConnectionSettings.cs

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,8 @@
1-
using System.Net.Security;
1+
// This source code is dual-licensed under the Apache License, version
2+
// 2.0, and the Mozilla Public License, version 2.0.
3+
// Copyright (c) 2017-2023 Broadcom. All Rights Reserved. The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
4+
5+
using System.Net.Security;
26
using System.Security.Authentication;
37
using System.Security.Cryptography.X509Certificates;
48
using Amqp;

‎RabbitMQ.AMQP.Client/Impl/Consts.cs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
// This source code is dual-licensed under the Apache License, version
2+
// 2.0, and the Mozilla Public License, version 2.0.
3+
// Copyright (c) 2017-2023 Broadcom. All Rights Reserved. The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
4+
15
namespace RabbitMQ.AMQP.Client.Impl;
26

37
public class Consts

‎RabbitMQ.AMQP.Client/Impl/RecordingTopologyListener.cs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
// This source code is dual-licensed under the Apache License, version
2+
// 2.0, and the Mozilla Public License, version 2.0.
3+
// Copyright (c) 2017-2023 Broadcom. All Rights Reserved. The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
4+
15
using System.Collections.Concurrent;
26

37
namespace RabbitMQ.AMQP.Client.Impl;

‎RabbitMQ.AMQP.Client/PublicAPI.Unshipped.txt

Lines changed: 8 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -335,14 +335,14 @@ RabbitMQ.AMQP.Client.Impl.BackOffDelayPolicy.CurrentAttempt.get -> int
335335
RabbitMQ.AMQP.Client.Impl.BackOffDelayPolicy.Delay() -> int
336336
RabbitMQ.AMQP.Client.Impl.BackOffDelayPolicy.IsActive() -> bool
337337
RabbitMQ.AMQP.Client.Impl.BackOffDelayPolicy.Reset() -> void
338-
RabbitMQ.AMQP.Client.Impl.BindingSpecificationBase
339-
RabbitMQ.AMQP.Client.Impl.BindingSpecificationBase.ArgsToMap() -> Amqp.Types.Map!
340-
RabbitMQ.AMQP.Client.Impl.BindingSpecificationBase.BindingSpecificationBase() -> void
341-
RabbitMQ.AMQP.Client.Impl.BindingSpecificationBase._arguments -> System.Collections.Generic.Dictionary<string!, object!>!
342-
RabbitMQ.AMQP.Client.Impl.BindingSpecificationBase._destination -> string!
343-
RabbitMQ.AMQP.Client.Impl.BindingSpecificationBase._routingKey -> string!
344-
RabbitMQ.AMQP.Client.Impl.BindingSpecificationBase._source -> string!
345-
RabbitMQ.AMQP.Client.Impl.BindingSpecificationBase._toQueue -> bool
338+
RabbitMQ.AMQP.Client.Impl.BindingSpecification
339+
RabbitMQ.AMQP.Client.Impl.BindingSpecification.ArgsToMap() -> Amqp.Types.Map!
340+
RabbitMQ.AMQP.Client.Impl.BindingSpecification.BindingSpecification() -> void
341+
RabbitMQ.AMQP.Client.Impl.BindingSpecification._arguments -> System.Collections.Generic.Dictionary<string!, object!>!
342+
RabbitMQ.AMQP.Client.Impl.BindingSpecification._destination -> string!
343+
RabbitMQ.AMQP.Client.Impl.BindingSpecification._routingKey -> string!
344+
RabbitMQ.AMQP.Client.Impl.BindingSpecification._source -> string!
345+
RabbitMQ.AMQP.Client.Impl.BindingSpecification._toQueue -> bool
346346
RabbitMQ.AMQP.Client.Impl.ConnectionSettingBuilder
347347
RabbitMQ.AMQP.Client.Impl.ConnectionSettingBuilder.Build() -> RabbitMQ.AMQP.Client.Impl.ConnectionSettings!
348348
RabbitMQ.AMQP.Client.Impl.ConnectionSettingBuilder.ContainerId(string! containerId) -> RabbitMQ.AMQP.Client.Impl.ConnectionSettingBuilder!
@@ -555,7 +555,6 @@ RabbitMQ.AMQP.Client.StreamOffsetSpecification
555555
RabbitMQ.AMQP.Client.StreamOffsetSpecification.First = 0 -> RabbitMQ.AMQP.Client.StreamOffsetSpecification
556556
RabbitMQ.AMQP.Client.StreamOffsetSpecification.Last = 1 -> RabbitMQ.AMQP.Client.StreamOffsetSpecification
557557
RabbitMQ.AMQP.Client.StreamOffsetSpecification.Next = 2 -> RabbitMQ.AMQP.Client.StreamOffsetSpecification
558-
readonly RabbitMQ.AMQP.Client.Impl.AbstractLifeCycle._connectionCloseTaskCompletionSource -> System.Threading.Tasks.TaskCompletionSource<bool>!
559558
static RabbitMQ.AMQP.Client.ByteCapacity.B(long bytes) -> RabbitMQ.AMQP.Client.ByteCapacity!
560559
static RabbitMQ.AMQP.Client.ByteCapacity.From(string! value) -> RabbitMQ.AMQP.Client.ByteCapacity!
561560
static RabbitMQ.AMQP.Client.ByteCapacity.Gb(long gigabytes) -> RabbitMQ.AMQP.Client.ByteCapacity!

‎RabbitMQ.AMQP.Client/SaslMechanism.cs

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,8 @@
1-
namespace RabbitMQ.AMQP.Client
1+
// This source code is dual-licensed under the Apache License, version
2+
// 2.0, and the Mozilla Public License, version 2.0.
3+
// Copyright (c) 2017-2023 Broadcom. All Rights Reserved. The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
4+
5+
namespace RabbitMQ.AMQP.Client
26
{
37
public class SaslMechanism : IEquatable<SaslMechanism>
48
{

‎Tests/ByteCapacityTests.cs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,7 @@
1+
// This source code is dual-licensed under the Apache License, version
2+
// 2.0, and the Mozilla Public License, version 2.0.
3+
// Copyright (c) 2017-2023 Broadcom. All Rights Reserved. The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
4+
15
using System;
26
using RabbitMQ.AMQP.Client;
37
using Xunit;

0 commit comments

Comments
 (0)