From e7d7e5b6435e0bc12f8cb73caee1b63bf6397cb5 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mat=C4=9Bj=20=C4=8Cern=C3=BD?= Date: Mon, 8 Jan 2024 14:36:15 +0100 Subject: [PATCH 1/2] Update copyright year --- .../scala-2.13/dev/profunktor/fs2rabbit/javaConversion.scala | 2 +- .../scala/dev/profunktor/fs2rabbit/algebra/AMQPInternals.scala | 2 +- .../scala/dev/profunktor/fs2rabbit/algebra/AckConsuming.scala | 2 +- .../main/scala/dev/profunktor/fs2rabbit/algebra/Acking.scala | 2 +- .../main/scala/dev/profunktor/fs2rabbit/algebra/Binding.scala | 2 +- .../scala/dev/profunktor/fs2rabbit/algebra/BindingOps.scala | 2 +- .../main/scala/dev/profunktor/fs2rabbit/algebra/Cancel.scala | 2 +- .../scala/dev/profunktor/fs2rabbit/algebra/Connection.scala | 2 +- .../main/scala/dev/profunktor/fs2rabbit/algebra/Consume.scala | 2 +- .../main/scala/dev/profunktor/fs2rabbit/algebra/Consuming.scala | 2 +- .../scala/dev/profunktor/fs2rabbit/algebra/Declaration.scala | 2 +- .../scala/dev/profunktor/fs2rabbit/algebra/DeclarationOps.scala | 2 +- .../main/scala/dev/profunktor/fs2rabbit/algebra/Deletion.scala | 2 +- .../scala/dev/profunktor/fs2rabbit/algebra/DeletionOps.scala | 2 +- .../scala/dev/profunktor/fs2rabbit/algebra/InternalQueue.scala | 2 +- .../main/scala/dev/profunktor/fs2rabbit/algebra/Publish.scala | 2 +- .../scala/dev/profunktor/fs2rabbit/algebra/Publishing.scala | 2 +- core/src/main/scala/dev/profunktor/fs2rabbit/arguments.scala | 2 +- .../scala/dev/profunktor/fs2rabbit/config/Fs2RabbitConfig.scala | 2 +- .../scala/dev/profunktor/fs2rabbit/config/declaration.scala | 2 +- .../main/scala/dev/profunktor/fs2rabbit/config/deletion.scala | 2 +- .../main/scala/dev/profunktor/fs2rabbit/effects/BoolValue.scala | 2 +- .../dev/profunktor/fs2rabbit/effects/EnvelopeDecoder.scala | 2 +- core/src/main/scala/dev/profunktor/fs2rabbit/effects/Log.scala | 2 +- .../scala/dev/profunktor/fs2rabbit/effects/StreamEval.scala | 2 +- .../main/scala/dev/profunktor/fs2rabbit/effects/package.scala | 2 +- .../profunktor/fs2rabbit/interpreter/LiveInternalQueue.scala | 2 +- .../dev/profunktor/fs2rabbit/interpreter/RabbitClient.scala | 2 +- .../dev/profunktor/fs2rabbit/interpreter/RabbitClientOps.scala | 2 +- core/src/main/scala/dev/profunktor/fs2rabbit/model.scala | 2 +- .../dev/profunktor/fs2rabbit/program/AckConsumingProgram.scala | 2 +- .../profunktor/fs2rabbit/program/AckConsumingProgramOps.scala | 2 +- .../scala/dev/profunktor/fs2rabbit/program/AckingProgram.scala | 2 +- .../dev/profunktor/fs2rabbit/program/ConsumingProgram.scala | 2 +- .../dev/profunktor/fs2rabbit/program/PublishingProgram.scala | 2 +- .../dev/profunktor/fs2rabbit/program/PublishingProgramOps.scala | 2 +- .../dev/profunktor/fs2rabbit/resiliency/ResilientStream.scala | 2 +- .../scala/dev/profunktor/fs2rabbit/AmqpFieldValueSpec.scala | 2 +- .../scala/dev/profunktor/fs2rabbit/AmqpPropertiesSpec.scala | 2 +- core/src/test/scala/dev/profunktor/fs2rabbit/SafeArgSpec.scala | 2 +- .../dev/profunktor/fs2rabbit/effects/EnvelopeDecoderSpec.scala | 2 +- .../dev/profunktor/fs2rabbit/examples/AckerConsumerDemo.scala | 2 +- .../dev/profunktor/fs2rabbit/examples/AutoAckConsumerDemo.scala | 2 +- .../profunktor/fs2rabbit/examples/DropwizardMetricsDemo.scala | 2 +- .../dev/profunktor/fs2rabbit/examples/IOAckerConsumer.scala | 2 +- .../profunktor/fs2rabbit/examples/MonixAutoAckConsumer.scala | 2 +- .../main/scala/dev/profunktor/fs2rabbit/examples/RPCDemo.scala | 2 +- .../dev/profunktor/fs2rabbit/examples/ZIOAutoAckConsumer.scala | 2 +- .../main/scala/dev/profunktor/fs2rabbit/examples/package.scala | 2 +- .../scala/dev/profunktor/fs2rabbit/json/Fs2JsonDecoder.scala | 2 +- .../scala/dev/profunktor/fs2rabbit/json/Fs2JsonEncoder.scala | 2 +- .../dev/profunktor/fs2rabbit/json/Fs2JsonDecoderSpec.scala | 2 +- .../dev/profunktor/fs2rabbit/json/Fs2JsonEncoderSpec.scala | 2 +- .../main/scala/dev/profunktor/fs2rabbit/testkit/package.scala | 2 +- tests/src/test/scala/dev/profunktor/fs2rabbit/BaseSpec.scala | 2 +- .../dev/profunktor/fs2rabbit/interpreter/Fs2RabbitSpec.scala | 2 +- .../dev/profunktor/fs2rabbit/interpreter/RabbitSuite.scala | 2 +- .../fs2rabbit/laws/CommutativeSemigroupInstancesSpec.scala | 2 +- .../scala/dev/profunktor/fs2rabbit/laws/EqInstancesSpec.scala | 2 +- .../dev/profunktor/fs2rabbit/laws/OrderInstancesSpec.scala | 2 +- .../dev/profunktor/fs2rabbit/laws/TraverseInstancesSpec.scala | 2 +- .../profunktor/fs2rabbit/resiliency/ResilientStreamSpec.scala | 2 +- 62 files changed, 62 insertions(+), 62 deletions(-) diff --git a/core/src/main/scala-2.13/dev/profunktor/fs2rabbit/javaConversion.scala b/core/src/main/scala-2.13/dev/profunktor/fs2rabbit/javaConversion.scala index f872b5aa..f7ba8685 100644 --- a/core/src/main/scala-2.13/dev/profunktor/fs2rabbit/javaConversion.scala +++ b/core/src/main/scala-2.13/dev/profunktor/fs2rabbit/javaConversion.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/AMQPInternals.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/AMQPInternals.scala index 6de94a6a..747ec470 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/AMQPInternals.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/AMQPInternals.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/AckConsuming.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/AckConsuming.scala index 8119cc47..3bcc1c30 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/AckConsuming.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/AckConsuming.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Acking.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Acking.scala index 58529b2c..64438d29 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Acking.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Acking.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Binding.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Binding.scala index 27821c9d..6d90828b 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Binding.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Binding.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/BindingOps.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/BindingOps.scala index 9d9cefb6..76f257ba 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/BindingOps.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/BindingOps.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Cancel.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Cancel.scala index ec52d2d4..39c6fba1 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Cancel.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Cancel.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Connection.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Connection.scala index 8a91b922..fe976574 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Connection.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Connection.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Consume.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Consume.scala index 07f77d27..8267e5b5 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Consume.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Consume.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Consuming.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Consuming.scala index 5af644d0..28d7c8b8 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Consuming.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Consuming.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Declaration.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Declaration.scala index c7575f31..a7a7820d 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Declaration.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Declaration.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/DeclarationOps.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/DeclarationOps.scala index b86dfc13..6682b8e3 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/DeclarationOps.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/DeclarationOps.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Deletion.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Deletion.scala index fdd8801a..f730d6ab 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Deletion.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Deletion.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/DeletionOps.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/DeletionOps.scala index 6f9b2bb0..1aab0708 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/DeletionOps.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/DeletionOps.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/InternalQueue.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/InternalQueue.scala index 070b847a..bbc847eb 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/InternalQueue.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/InternalQueue.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Publish.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Publish.scala index de9304cd..a1c009d8 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Publish.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Publish.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Publishing.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Publishing.scala index 04fc54d4..dd2860c5 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Publishing.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Publishing.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/arguments.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/arguments.scala index 1bf17d9c..a2d0b051 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/arguments.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/arguments.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/config/Fs2RabbitConfig.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/config/Fs2RabbitConfig.scala index f085143e..5436f755 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/config/Fs2RabbitConfig.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/config/Fs2RabbitConfig.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/config/declaration.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/config/declaration.scala index d2119d3f..925d6a5e 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/config/declaration.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/config/declaration.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/config/deletion.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/config/deletion.scala index 7cd37969..7841ab97 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/config/deletion.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/config/deletion.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/effects/BoolValue.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/effects/BoolValue.scala index 75374037..4ffa5e4c 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/effects/BoolValue.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/effects/BoolValue.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/effects/EnvelopeDecoder.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/effects/EnvelopeDecoder.scala index 969daf66..97b13197 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/effects/EnvelopeDecoder.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/effects/EnvelopeDecoder.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/effects/Log.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/effects/Log.scala index 0b5e824c..d6d175c8 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/effects/Log.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/effects/Log.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/effects/StreamEval.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/effects/StreamEval.scala index 69cc1ff7..7def2ab8 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/effects/StreamEval.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/effects/StreamEval.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/effects/package.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/effects/package.scala index 57a821c8..b9b1217c 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/effects/package.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/effects/package.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/interpreter/LiveInternalQueue.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/interpreter/LiveInternalQueue.scala index 410e3d36..1e585d46 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/interpreter/LiveInternalQueue.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/interpreter/LiveInternalQueue.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/interpreter/RabbitClient.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/interpreter/RabbitClient.scala index e528a1af..db8dd989 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/interpreter/RabbitClient.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/interpreter/RabbitClient.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/interpreter/RabbitClientOps.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/interpreter/RabbitClientOps.scala index 48daf9cf..b47aa403 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/interpreter/RabbitClientOps.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/interpreter/RabbitClientOps.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/model.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/model.scala index 70dd3cbb..cc4950b0 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/model.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/model.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/program/AckConsumingProgram.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/program/AckConsumingProgram.scala index d7b62e27..a30fe725 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/program/AckConsumingProgram.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/program/AckConsumingProgram.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/program/AckConsumingProgramOps.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/program/AckConsumingProgramOps.scala index 43d2ef9b..6314e07b 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/program/AckConsumingProgramOps.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/program/AckConsumingProgramOps.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/program/AckingProgram.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/program/AckingProgram.scala index 04af0c5a..13f566a6 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/program/AckingProgram.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/program/AckingProgram.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/program/ConsumingProgram.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/program/ConsumingProgram.scala index e0ddb81c..0d639f18 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/program/ConsumingProgram.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/program/ConsumingProgram.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/program/PublishingProgram.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/program/PublishingProgram.scala index 7ab72c65..318cc623 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/program/PublishingProgram.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/program/PublishingProgram.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/program/PublishingProgramOps.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/program/PublishingProgramOps.scala index 4a6ee9df..3bce5f6d 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/program/PublishingProgramOps.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/program/PublishingProgramOps.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/resiliency/ResilientStream.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/resiliency/ResilientStream.scala index f906b5e9..6825ef7b 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/resiliency/ResilientStream.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/resiliency/ResilientStream.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/test/scala/dev/profunktor/fs2rabbit/AmqpFieldValueSpec.scala b/core/src/test/scala/dev/profunktor/fs2rabbit/AmqpFieldValueSpec.scala index 4f97dbe8..270352b8 100644 --- a/core/src/test/scala/dev/profunktor/fs2rabbit/AmqpFieldValueSpec.scala +++ b/core/src/test/scala/dev/profunktor/fs2rabbit/AmqpFieldValueSpec.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/test/scala/dev/profunktor/fs2rabbit/AmqpPropertiesSpec.scala b/core/src/test/scala/dev/profunktor/fs2rabbit/AmqpPropertiesSpec.scala index fb4b70fc..befc31ba 100644 --- a/core/src/test/scala/dev/profunktor/fs2rabbit/AmqpPropertiesSpec.scala +++ b/core/src/test/scala/dev/profunktor/fs2rabbit/AmqpPropertiesSpec.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/test/scala/dev/profunktor/fs2rabbit/SafeArgSpec.scala b/core/src/test/scala/dev/profunktor/fs2rabbit/SafeArgSpec.scala index 25780a0e..f747d238 100644 --- a/core/src/test/scala/dev/profunktor/fs2rabbit/SafeArgSpec.scala +++ b/core/src/test/scala/dev/profunktor/fs2rabbit/SafeArgSpec.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/core/src/test/scala/dev/profunktor/fs2rabbit/effects/EnvelopeDecoderSpec.scala b/core/src/test/scala/dev/profunktor/fs2rabbit/effects/EnvelopeDecoderSpec.scala index 8352c19a..8d5e8ee5 100644 --- a/core/src/test/scala/dev/profunktor/fs2rabbit/effects/EnvelopeDecoderSpec.scala +++ b/core/src/test/scala/dev/profunktor/fs2rabbit/effects/EnvelopeDecoderSpec.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/examples/src/main/scala/dev/profunktor/fs2rabbit/examples/AckerConsumerDemo.scala b/examples/src/main/scala/dev/profunktor/fs2rabbit/examples/AckerConsumerDemo.scala index 11d3a789..6693be1f 100644 --- a/examples/src/main/scala/dev/profunktor/fs2rabbit/examples/AckerConsumerDemo.scala +++ b/examples/src/main/scala/dev/profunktor/fs2rabbit/examples/AckerConsumerDemo.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/examples/src/main/scala/dev/profunktor/fs2rabbit/examples/AutoAckConsumerDemo.scala b/examples/src/main/scala/dev/profunktor/fs2rabbit/examples/AutoAckConsumerDemo.scala index a3cd017a..fdac817f 100644 --- a/examples/src/main/scala/dev/profunktor/fs2rabbit/examples/AutoAckConsumerDemo.scala +++ b/examples/src/main/scala/dev/profunktor/fs2rabbit/examples/AutoAckConsumerDemo.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/examples/src/main/scala/dev/profunktor/fs2rabbit/examples/DropwizardMetricsDemo.scala b/examples/src/main/scala/dev/profunktor/fs2rabbit/examples/DropwizardMetricsDemo.scala index e40b2ee2..28427d2f 100644 --- a/examples/src/main/scala/dev/profunktor/fs2rabbit/examples/DropwizardMetricsDemo.scala +++ b/examples/src/main/scala/dev/profunktor/fs2rabbit/examples/DropwizardMetricsDemo.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/examples/src/main/scala/dev/profunktor/fs2rabbit/examples/IOAckerConsumer.scala b/examples/src/main/scala/dev/profunktor/fs2rabbit/examples/IOAckerConsumer.scala index 11a2bb6c..b48c3a1b 100644 --- a/examples/src/main/scala/dev/profunktor/fs2rabbit/examples/IOAckerConsumer.scala +++ b/examples/src/main/scala/dev/profunktor/fs2rabbit/examples/IOAckerConsumer.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/examples/src/main/scala/dev/profunktor/fs2rabbit/examples/MonixAutoAckConsumer.scala b/examples/src/main/scala/dev/profunktor/fs2rabbit/examples/MonixAutoAckConsumer.scala index 09540e7a..1a213c22 100644 --- a/examples/src/main/scala/dev/profunktor/fs2rabbit/examples/MonixAutoAckConsumer.scala +++ b/examples/src/main/scala/dev/profunktor/fs2rabbit/examples/MonixAutoAckConsumer.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/examples/src/main/scala/dev/profunktor/fs2rabbit/examples/RPCDemo.scala b/examples/src/main/scala/dev/profunktor/fs2rabbit/examples/RPCDemo.scala index e534ef84..f46877f7 100644 --- a/examples/src/main/scala/dev/profunktor/fs2rabbit/examples/RPCDemo.scala +++ b/examples/src/main/scala/dev/profunktor/fs2rabbit/examples/RPCDemo.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/examples/src/main/scala/dev/profunktor/fs2rabbit/examples/ZIOAutoAckConsumer.scala b/examples/src/main/scala/dev/profunktor/fs2rabbit/examples/ZIOAutoAckConsumer.scala index ff818279..e02efc7a 100644 --- a/examples/src/main/scala/dev/profunktor/fs2rabbit/examples/ZIOAutoAckConsumer.scala +++ b/examples/src/main/scala/dev/profunktor/fs2rabbit/examples/ZIOAutoAckConsumer.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/examples/src/main/scala/dev/profunktor/fs2rabbit/examples/package.scala b/examples/src/main/scala/dev/profunktor/fs2rabbit/examples/package.scala index c5805a77..3ad011bc 100644 --- a/examples/src/main/scala/dev/profunktor/fs2rabbit/examples/package.scala +++ b/examples/src/main/scala/dev/profunktor/fs2rabbit/examples/package.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/json-circe/src/main/scala/dev/profunktor/fs2rabbit/json/Fs2JsonDecoder.scala b/json-circe/src/main/scala/dev/profunktor/fs2rabbit/json/Fs2JsonDecoder.scala index 9f50c9bc..942bcea9 100644 --- a/json-circe/src/main/scala/dev/profunktor/fs2rabbit/json/Fs2JsonDecoder.scala +++ b/json-circe/src/main/scala/dev/profunktor/fs2rabbit/json/Fs2JsonDecoder.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/json-circe/src/main/scala/dev/profunktor/fs2rabbit/json/Fs2JsonEncoder.scala b/json-circe/src/main/scala/dev/profunktor/fs2rabbit/json/Fs2JsonEncoder.scala index d023bc89..ff947c28 100644 --- a/json-circe/src/main/scala/dev/profunktor/fs2rabbit/json/Fs2JsonEncoder.scala +++ b/json-circe/src/main/scala/dev/profunktor/fs2rabbit/json/Fs2JsonEncoder.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/json-circe/src/test/scala/dev/profunktor/fs2rabbit/json/Fs2JsonDecoderSpec.scala b/json-circe/src/test/scala/dev/profunktor/fs2rabbit/json/Fs2JsonDecoderSpec.scala index e2e284bf..892621a5 100644 --- a/json-circe/src/test/scala/dev/profunktor/fs2rabbit/json/Fs2JsonDecoderSpec.scala +++ b/json-circe/src/test/scala/dev/profunktor/fs2rabbit/json/Fs2JsonDecoderSpec.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/json-circe/src/test/scala/dev/profunktor/fs2rabbit/json/Fs2JsonEncoderSpec.scala b/json-circe/src/test/scala/dev/profunktor/fs2rabbit/json/Fs2JsonEncoderSpec.scala index 4e41c255..872ef00f 100644 --- a/json-circe/src/test/scala/dev/profunktor/fs2rabbit/json/Fs2JsonEncoderSpec.scala +++ b/json-circe/src/test/scala/dev/profunktor/fs2rabbit/json/Fs2JsonEncoderSpec.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/testkit/src/main/scala/dev/profunktor/fs2rabbit/testkit/package.scala b/testkit/src/main/scala/dev/profunktor/fs2rabbit/testkit/package.scala index d314b19a..55bbe7fa 100644 --- a/testkit/src/main/scala/dev/profunktor/fs2rabbit/testkit/package.scala +++ b/testkit/src/main/scala/dev/profunktor/fs2rabbit/testkit/package.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/tests/src/test/scala/dev/profunktor/fs2rabbit/BaseSpec.scala b/tests/src/test/scala/dev/profunktor/fs2rabbit/BaseSpec.scala index ce128815..41eca81f 100644 --- a/tests/src/test/scala/dev/profunktor/fs2rabbit/BaseSpec.scala +++ b/tests/src/test/scala/dev/profunktor/fs2rabbit/BaseSpec.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/tests/src/test/scala/dev/profunktor/fs2rabbit/interpreter/Fs2RabbitSpec.scala b/tests/src/test/scala/dev/profunktor/fs2rabbit/interpreter/Fs2RabbitSpec.scala index 941dd185..b1e01d93 100644 --- a/tests/src/test/scala/dev/profunktor/fs2rabbit/interpreter/Fs2RabbitSpec.scala +++ b/tests/src/test/scala/dev/profunktor/fs2rabbit/interpreter/Fs2RabbitSpec.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/tests/src/test/scala/dev/profunktor/fs2rabbit/interpreter/RabbitSuite.scala b/tests/src/test/scala/dev/profunktor/fs2rabbit/interpreter/RabbitSuite.scala index 9c229ecc..e87bbbce 100644 --- a/tests/src/test/scala/dev/profunktor/fs2rabbit/interpreter/RabbitSuite.scala +++ b/tests/src/test/scala/dev/profunktor/fs2rabbit/interpreter/RabbitSuite.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/tests/src/test/scala/dev/profunktor/fs2rabbit/laws/CommutativeSemigroupInstancesSpec.scala b/tests/src/test/scala/dev/profunktor/fs2rabbit/laws/CommutativeSemigroupInstancesSpec.scala index 040ac578..dc851d19 100644 --- a/tests/src/test/scala/dev/profunktor/fs2rabbit/laws/CommutativeSemigroupInstancesSpec.scala +++ b/tests/src/test/scala/dev/profunktor/fs2rabbit/laws/CommutativeSemigroupInstancesSpec.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/tests/src/test/scala/dev/profunktor/fs2rabbit/laws/EqInstancesSpec.scala b/tests/src/test/scala/dev/profunktor/fs2rabbit/laws/EqInstancesSpec.scala index ce9ccc0f..2df0c287 100644 --- a/tests/src/test/scala/dev/profunktor/fs2rabbit/laws/EqInstancesSpec.scala +++ b/tests/src/test/scala/dev/profunktor/fs2rabbit/laws/EqInstancesSpec.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/tests/src/test/scala/dev/profunktor/fs2rabbit/laws/OrderInstancesSpec.scala b/tests/src/test/scala/dev/profunktor/fs2rabbit/laws/OrderInstancesSpec.scala index 587d7108..eb2da152 100644 --- a/tests/src/test/scala/dev/profunktor/fs2rabbit/laws/OrderInstancesSpec.scala +++ b/tests/src/test/scala/dev/profunktor/fs2rabbit/laws/OrderInstancesSpec.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/tests/src/test/scala/dev/profunktor/fs2rabbit/laws/TraverseInstancesSpec.scala b/tests/src/test/scala/dev/profunktor/fs2rabbit/laws/TraverseInstancesSpec.scala index 03941e31..5e7518e5 100644 --- a/tests/src/test/scala/dev/profunktor/fs2rabbit/laws/TraverseInstancesSpec.scala +++ b/tests/src/test/scala/dev/profunktor/fs2rabbit/laws/TraverseInstancesSpec.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/tests/src/test/scala/dev/profunktor/fs2rabbit/resiliency/ResilientStreamSpec.scala b/tests/src/test/scala/dev/profunktor/fs2rabbit/resiliency/ResilientStreamSpec.scala index a2718ee3..dc1b682f 100644 --- a/tests/src/test/scala/dev/profunktor/fs2rabbit/resiliency/ResilientStreamSpec.scala +++ b/tests/src/test/scala/dev/profunktor/fs2rabbit/resiliency/ResilientStreamSpec.scala @@ -1,5 +1,5 @@ /* - * Copyright 2017-2023 ProfunKtor + * Copyright 2017-2024 ProfunKtor * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. From 0a06fb1fac9d00d851990a2230f4a8b0ebdf4bd0 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mat=C4=9Bj=20=C4=8Cern=C3=BD?= Date: Mon, 8 Jan 2024 14:39:17 +0100 Subject: [PATCH 2/2] Blocking state fix --- .../profunktor/fs2rabbit/algebra/Connection.scala | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Connection.scala b/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Connection.scala index fe976574..a8676178 100644 --- a/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Connection.scala +++ b/core/src/main/scala/dev/profunktor/fs2rabbit/algebra/Connection.scala @@ -69,7 +69,7 @@ object ConnectionResource { _.map(Executors.newFixedThreadPool(numOfThreads, _)) } .map { es => - sys.addShutdownHook(es.shutdown()) + val _ = sys.addShutdownHook(es.shutdown()) es } @@ -150,27 +150,29 @@ object ConnectionResource { private[fs2rabbit] val acquireConnection: F[AMQPConnection] = Sync[F] - .delay(connectionFactory.newConnection(addresses.toList.asJava, conf.clientProvidedConnectionName.orNull)) + .blocking( + connectionFactory.newConnection(addresses.toList.asJava, conf.clientProvidedConnectionName.orNull) + ) .flatTap(c => Log[F].info(s"Acquired connection: $c")) .map(RabbitConnection.apply) private[fs2rabbit] def acquireChannel(connection: AMQPConnection): F[AMQPChannel] = Sync[F] - .delay(connection.value.createChannel) + .blocking(connection.value.createChannel) .flatTap(c => Log[F].info(s"Acquired channel: $c")) .map(RabbitChannel.apply) override def createConnection: Resource[F, AMQPConnection] = Resource.make(acquireConnection) { amqpConn => Log[F].info(s"Releasing connection: ${amqpConn.value} previously acquired.") *> - Sync[F].delay { + Sync[F].blocking { if (amqpConn.value.isOpen) amqpConn.value.close() } } override def createChannel(connection: AMQPConnection): Resource[F, AMQPChannel] = Resource.make(acquireChannel(connection)) { amqpChannel => - Sync[F].delay { + Sync[F].blocking { if (amqpChannel.value.isOpen) amqpChannel.value.close() } }