achilleasa · achilleasa · May 19, 2024 · May 17, 2024 · May 17, 2024 · May 17, 2024
diff --git a/.github/workflows/ci.yaml b/.github/workflows/ci.yaml
@@ -12,6 +12,8 @@ jobs:
 
       - name: Setup Dart SDK
         uses: dart-lang/setup-dart@v1
+        with:
+          sdk: stable
 
       - name: Prepare RabbitMQ configuration
         run: |

diff --git a/lib/src/authentication/amq_plain_authenticator.dart b/lib/src/authentication/amq_plain_authenticator.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.authentication;
+part of "../authentication.dart";
 
 class AmqPlainAuthenticator implements Authenticator {
   final String userName;

diff --git a/lib/src/authentication/authenticator.dart b/lib/src/authentication/authenticator.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.authentication;
+part of "../authentication.dart";
 
 abstract class Authenticator {
   /// Get the SASL type of this authenticator

diff --git a/lib/src/authentication/plain_authenticator.dart b/lib/src/authentication/plain_authenticator.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.authentication;
+part of "../authentication.dart";
 
 class PlainAuthenticator implements Authenticator {
   final String userName;

diff --git a/lib/src/client/amqp_message.dart b/lib/src/client/amqp_message.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.client;
+part of "../client.dart";
 
 abstract class AmqpMessage {
   /// Get the payload as a [Uint8List]

diff --git a/lib/src/client/basicreturn_message.dart b/lib/src/client/basicreturn_message.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.client;
+part of "../client.dart";
 
 abstract class BasicReturnMessage {
   /// Get the payload as a [Uint8List]

diff --git a/lib/src/client/channel.dart b/lib/src/client/channel.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.client;
+part of "../client.dart";
 
 abstract class Channel {
   /// Close the channel, abort any pending operations and return a [Future<Channel>] to be completed

diff --git a/lib/src/client/client.dart b/lib/src/client/client.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.client;
+part of "../client.dart";
 
 abstract class Client {
   factory Client({ConnectionSettings? settings}) =>

diff --git a/lib/src/client/connection_settings.dart b/lib/src/client/connection_settings.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.client;
+part of "../client.dart";
 
 class ConnectionSettings {
   // The host to connect to

diff --git a/lib/src/client/consumer.dart b/lib/src/client/consumer.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.client;
+part of "../client.dart";
 
 abstract class Consumer {
   /// Get the consumer tag.

diff --git a/lib/src/client/exchange.dart b/lib/src/client/exchange.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.client;
+part of "../client.dart";
 
 abstract class Exchange {
   /// Get the name of the exchange

diff --git a/lib/src/client/impl/amqp_message_impl.dart b/lib/src/client/impl/amqp_message_impl.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.client;
+part of "../../client.dart";
 
 class _AmqpMessageImpl implements AmqpMessage {
   final _ConsumerImpl consumer;

diff --git a/lib/src/client/impl/basic_return_message_impl.dart b/lib/src/client/impl/basic_return_message_impl.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.client;
+part of "../../client.dart";
 
 class _BasicReturnMessageImpl implements BasicReturnMessage {
   final DecodedMessage message;

diff --git a/lib/src/client/impl/channel_impl.dart b/lib/src/client/impl/channel_impl.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.client;
+part of "../../client.dart";
 
 class _ChannelImpl implements Channel {
   // The allocated channel id

diff --git a/lib/src/client/impl/client_impl.dart b/lib/src/client/impl/client_impl.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.client;
+part of "../../client.dart";
 
 class _ClientImpl implements Client {
   // Configuration options

diff --git a/lib/src/client/impl/consumer_impl.dart b/lib/src/client/impl/consumer_impl.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.client;
+part of "../../client.dart";
 
 class _ConsumerImpl implements Consumer {
   // https://github.com/dart-lang/linter/issues/2697

diff --git a/lib/src/client/impl/exchange_impl.dart b/lib/src/client/impl/exchange_impl.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.client;
+part of "../../client.dart";
 
 class _ExchangeImpl implements Exchange {
   final String _name;

diff --git a/lib/src/client/impl/publish_notification_impl.dart b/lib/src/client/impl/publish_notification_impl.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.client;
+part of "../../client.dart";
 
 class _PublishNotificationImpl implements PublishNotification {
   @override

diff --git a/lib/src/client/impl/queue_impl.dart b/lib/src/client/impl/queue_impl.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.client;
+part of "../../client.dart";
 
 class _QueueImpl implements Queue {
   // https://github.com/dart-lang/linter/issues/2697

diff --git a/lib/src/client/publish_notification.dart b/lib/src/client/publish_notification.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.client;
+part of "../client.dart";
 
 abstract class PublishNotification {
   Object? get message;

diff --git a/lib/src/client/queue.dart b/lib/src/client/queue.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.client;
+part of "../client.dart";
 
 abstract class Queue {
   /// Get the queue name

diff --git a/lib/src/enums/delivery_mode.dart b/lib/src/enums/delivery_mode.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.enums;
+part of "../enums.dart";
 
 class DeliveryMode extends Enum<int> {
   static const DeliveryMode TRANSIENT = DeliveryMode._(1);

diff --git a/lib/src/enums/enum.dart b/lib/src/enums/enum.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.enums;
+part of "../enums.dart";
 
 /// An abstract class for modeling enums
 abstract class Enum<T> {

diff --git a/lib/src/enums/error_type.dart b/lib/src/enums/error_type.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.enums;
+part of "../enums.dart";
 
 class ErrorType extends Enum<int> {
   static const ErrorType SUCCESS = ErrorType._(200, false);

diff --git a/lib/src/enums/exchange_type.dart b/lib/src/enums/exchange_type.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.enums;
+part of "../enums.dart";
 
 class ExchangeType extends BaseExchange<String> {
   static const ExchangeType FANOUT = ExchangeType._("fanout");

diff --git a/lib/src/enums/field_type.dart b/lib/src/enums/field_type.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.enums;
+part of "../enums.dart";
 
 class FieldType extends Enum<int> {
   static const FieldType BOOLEAN = FieldType._(116);

diff --git a/lib/src/enums/frame_type.dart b/lib/src/enums/frame_type.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.enums;
+part of "../enums.dart";
 
 class FrameType extends Enum<int> {
   static const FrameType METHOD = FrameType._(1);

diff --git a/lib/src/exceptions/channel_exception.dart b/lib/src/exceptions/channel_exception.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.exceptions;
+part of "../exceptions.dart";
 
 class ChannelException implements Exception {
   final String message;

diff --git a/lib/src/exceptions/connection_exception.dart b/lib/src/exceptions/connection_exception.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.exceptions;
+part of "../exceptions.dart";
 
 class ConnectionException implements Exception {
   final String message;

diff --git a/lib/src/exceptions/connection_failed_exception.dart b/lib/src/exceptions/connection_failed_exception.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.exceptions;
+part of "../exceptions.dart";
 
 class ConnectionFailedException implements Exception {
   final String message;

diff --git a/lib/src/exceptions/exchange_not_found_exception.dart b/lib/src/exceptions/exchange_not_found_exception.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.exceptions;
+part of "../exceptions.dart";
 
 class ExchangeNotFoundException extends ChannelException {
   ExchangeNotFoundException(String message, int channel, ErrorType errorType)

diff --git a/lib/src/exceptions/fatal_exception.dart b/lib/src/exceptions/fatal_exception.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.exceptions;
+part of "../exceptions.dart";
 
 class FatalException implements Exception {
   final String message;

diff --git a/lib/src/exceptions/heartbeat_failed_exception.dart b/lib/src/exceptions/heartbeat_failed_exception.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.exceptions;
+part of "../exceptions.dart";
 
 class HeartbeatFailedException implements Exception {
   final String message;

diff --git a/lib/src/exceptions/queue_not_found_exception.dart b/lib/src/exceptions/queue_not_found_exception.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.exceptions;
+part of "../exceptions.dart";
 
 class QueueNotFoundException extends ChannelException {
   QueueNotFoundException(String message, int channel, ErrorType errorType)

diff --git a/lib/src/logging/logger.dart b/lib/src/logging/logger.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.logger;
+part of "../logging.dart";
 
 // Define hierarchical loggers
 final Logger connectionLogger = Logger("dart_amqp.Connection");
diff --git a/lib/src/protocol/frame/decoded_message.dart b/lib/src/protocol/frame/decoded_message.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.protocol;
+part of "../../protocol.dart";
 
 abstract class DecodedMessage {
   int get channel;

diff --git a/lib/src/protocol/frame/impl/decoded_message_impl.dart b/lib/src/protocol/frame/impl/decoded_message_impl.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.protocol;
+part of "../../../protocol.dart";
 
 class DecodedMessageImpl implements DecodedMessage {
   @override

diff --git a/lib/src/protocol/frame/impl/heartbeat_frame_impl.dart b/lib/src/protocol/frame/impl/heartbeat_frame_impl.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.protocol;
+part of "../../../protocol.dart";
 
 class HeartbeatFrameImpl implements DecodedMessage {
   @override

diff --git a/lib/src/protocol/frame/raw_frame.dart b/lib/src/protocol/frame/raw_frame.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.protocol;
+part of "../../protocol.dart";
 
 class RawFrame {
   final FrameHeader header;

diff --git a/lib/src/protocol/headers/content_header.dart b/lib/src/protocol/headers/content_header.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.protocol;
+part of "../../protocol.dart";
 
 class ContentHeader implements Header {
   int classId = 0;

diff --git a/lib/src/protocol/headers/frame_header.dart b/lib/src/protocol/headers/frame_header.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.protocol;
+part of "../../protocol.dart";
 
 class FrameHeader implements Header {
   static const int LENGTH_IN_BYTES = 7;

diff --git a/lib/src/protocol/headers/header.dart b/lib/src/protocol/headers/header.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.protocol;
+part of "../../protocol.dart";
 
 abstract class Header {
   void serialize(TypeEncoder encoder);

diff --git a/lib/src/protocol/headers/protocol_header.dart b/lib/src/protocol/headers/protocol_header.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.protocol;
+part of "../../protocol.dart";
 
 class ProtocolHeader implements Header {
   static const int LENGTH_IN_BYTES = 8;

diff --git a/lib/src/protocol/io/amqp_message_decoder.dart b/lib/src/protocol/io/amqp_message_decoder.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.protocol;
+part of "../../protocol.dart";
 
 class AmqpMessageDecoder {
   Map<int, DecodedMessageImpl> incompleteMessages = <int, DecodedMessageImpl>{};

diff --git a/lib/src/protocol/io/frame_writer.dart b/lib/src/protocol/io/frame_writer.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.protocol;
+part of "../../protocol.dart";
 
 final Uint8List frameTerminatorSequence =
     Uint8List.fromList([RawFrameParser.FRAME_TERMINATOR]);

diff --git a/lib/src/protocol/io/raw_frame_parser.dart b/lib/src/protocol/io/raw_frame_parser.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.protocol;
+part of "../../protocol.dart";
 
 class RawFrameParser {
   static const int FRAME_TERMINATOR = 0xCE;

diff --git a/lib/src/protocol/io/tuning_settings.dart b/lib/src/protocol/io/tuning_settings.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.protocol;
+part of "../../protocol.dart";
 
 class TuningSettings {
   // The maximum number of channels to allow. A value of 0 indicates that there

diff --git a/lib/src/protocol/messages/bindings/basic.dart b/lib/src/protocol/messages/bindings/basic.dart
@@ -6,7 +6,7 @@
 
 // ignore_for_file: empty_constructor_bodies
 
-part of dart_amqp.protocol;
+part of "../../../protocol.dart";
 
 class BasicQos implements Message {
   @override

diff --git a/lib/src/protocol/messages/bindings/channel.dart b/lib/src/protocol/messages/bindings/channel.dart
@@ -6,7 +6,7 @@
 
 // ignore_for_file: empty_constructor_bodies
 
-part of dart_amqp.protocol;
+part of "../../../protocol.dart";
 
 class ChannelOpen implements Message {
   @override

diff --git a/lib/src/protocol/messages/bindings/confirm.dart b/lib/src/protocol/messages/bindings/confirm.dart
@@ -5,7 +5,7 @@
 
 // ignore_for_file: empty_constructor_bodies
 
-part of dart_amqp.protocol;
+part of "../../../protocol.dart";
 
 class ConfirmSelect implements Message {
   @override

diff --git a/lib/src/protocol/messages/bindings/connection.dart b/lib/src/protocol/messages/bindings/connection.dart
@@ -6,7 +6,7 @@
 
 // ignore_for_file: empty_constructor_bodies
 
-part of dart_amqp.protocol;
+part of "../../../protocol.dart";
 
 class ConnectionStart implements Message {
   @override

diff --git a/lib/src/protocol/messages/bindings/exchange.dart b/lib/src/protocol/messages/bindings/exchange.dart
@@ -6,7 +6,7 @@
 
 // ignore_for_file: empty_constructor_bodies
 
-part of dart_amqp.protocol;
+part of "../../../protocol.dart";
 
 class ExchangeDeclare implements Message {
   @override

diff --git a/lib/src/protocol/messages/bindings/queue.dart b/lib/src/protocol/messages/bindings/queue.dart
@@ -6,7 +6,7 @@
 
 // ignore_for_file: empty_constructor_bodies
 
-part of dart_amqp.protocol;
+part of "../../../protocol.dart";
 
 class QueueDeclare implements Message {
   @override

diff --git a/lib/src/protocol/messages/bindings/tx.dart b/lib/src/protocol/messages/bindings/tx.dart
@@ -6,7 +6,7 @@
 
 // ignore_for_file: empty_constructor_bodies
 
-part of dart_amqp.protocol;
+part of "../../../protocol.dart";
 
 class TxSelect implements Message {
   @override

diff --git a/lib/src/protocol/messages/message.dart b/lib/src/protocol/messages/message.dart
@@ -6,7 +6,7 @@
 //
 // Do not modify
 
-part of dart_amqp.protocol;
+part of "../../protocol.dart";
 
 abstract class Message {
   int get msgClassId;

diff --git a/lib/src/protocol/messages/message_properties.dart b/lib/src/protocol/messages/message_properties.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.protocol;
+part of "../../protocol.dart";
 
 class MessageProperties {
   String? contentType;

diff --git a/lib/src/protocol/stream/chunked_input_reader.dart b/lib/src/protocol/stream/chunked_input_reader.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.protocol;
+part of "../../protocol.dart";
 
 class ChunkedInputReader {
   final _bufferedChunks = ListQueue<List<int>>();

diff --git a/lib/src/protocol/stream/chunked_output_writer.dart b/lib/src/protocol/stream/chunked_output_writer.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.protocol;
+part of "../../protocol.dart";
 
 class ChunkedOutputWriter {
   final ListQueue<Uint8List> _bufferedChunks = ListQueue<Uint8List>();

diff --git a/lib/src/protocol/stream/type_decoder.dart b/lib/src/protocol/stream/type_decoder.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.protocol;
+part of "../../protocol.dart";
 
 class TypeDecoder {
   int _offset = 0;

diff --git a/lib/src/protocol/stream/type_encoder.dart b/lib/src/protocol/stream/type_encoder.dart
@@ -1,4 +1,4 @@
-part of dart_amqp.protocol;
+part of "../../protocol.dart";
 
 class TypeEncoder {
   late ChunkedOutputWriter _writer;