bump: Akka 2.10.11, Akka HTTP 10.7.3, Akka gRPC 2.5.8, Alpakka Kafka 8.0.0

amqp/src/test/java/akka/stream/alpakka/amqp/javadsl/AmqpConnectionProvidersTest.java

@@ -6,20 +6,19 @@
 
 import static org.hamcrest.CoreMatchers.instanceOf;
 import static org.hamcrest.MatcherAssert.assertThat;
-import static org.junit.Assert.assertNotEquals;
 import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertNotEquals;
 import static org.junit.Assert.assertTrue;
 
 import akka.stream.alpakka.amqp.*;
 import akka.stream.alpakka.testkit.javadsl.LogCapturingJunit4;
 import com.rabbitmq.client.Connection;
 import com.rabbitmq.client.ConnectionFactory;
+import java.net.ConnectException;
 import org.junit.Rule;
 import org.junit.Test;
 
-import java.net.ConnectException;
-
 public class AmqpConnectionProvidersTest {
 
   @Rule public final LogCapturingJunit4 logCapturing = new LogCapturingJunit4();

amqp/src/test/java/akka/stream/alpakka/amqp/javadsl/AmqpConnectorsTest.java

@@ -4,6 +4,9 @@
 
 package akka.stream.alpakka.amqp.javadsl;
 
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.fail;
+
 import akka.Done;
 import akka.NotUsed;
 import akka.actor.ActorSystem;
@@ -23,10 +26,6 @@
 import akka.testkit.javadsl.TestKit;
 import akka.util.ByteString;
 import com.rabbitmq.client.AuthenticationFailureException;
-import org.junit.*;
-import scala.concurrent.duration.Duration;
-import scala.jdk.javaapi.CollectionConverters;
-
 import java.net.ConnectException;
 import java.util.Arrays;
 import java.util.Collections;
@@ -35,9 +34,9 @@
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
-
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.fail;
+import org.junit.*;
+import scala.concurrent.duration.Duration;
+import scala.jdk.javaapi.CollectionConverters;
 
 /** Needs a local running AMQP server on the default port with no password. */
 public class AmqpConnectorsTest {
@@ -161,7 +160,9 @@ public void publishAndConsumeRpcWithoutAutoAck() throws Exception {
             .to(amqpSink)
             .run(system);
 
-    java.util.Collection<ReadResult> probeResult = CollectionConverters.asJavaCollection(result.second().toStrict(Duration.create(3, TimeUnit.SECONDS)));
+    java.util.Collection<ReadResult> probeResult =
+        CollectionConverters.asJavaCollection(
+            result.second().toStrict(Duration.create(3, TimeUnit.SECONDS)));
     assertEquals(
         probeResult.stream().map(s -> s.bytes().utf8String()).collect(Collectors.toList()), input);
     sourceToSink.shutdown();

amqp/src/test/java/akka/stream/alpakka/amqp/javadsl/AmqpFlowTest.java

@@ -4,17 +4,6 @@
 
 package akka.stream.alpakka.amqp.javadsl;
 
-import java.time.Duration;
-import java.util.Arrays;
-import java.util.List;
-import java.util.concurrent.CompletionStage;
-import java.util.stream.Collectors;
-
-import akka.stream.alpakka.testkit.javadsl.LogCapturingJunit4;
-import org.junit.BeforeClass;
-import org.junit.Rule;
-import org.junit.Test;
-
 import akka.Done;
 import akka.actor.ActorSystem;
 import akka.japi.Pair;
@@ -23,14 +12,22 @@
 import akka.stream.alpakka.amqp.QueueDeclaration;
 import akka.stream.alpakka.amqp.WriteMessage;
 import akka.stream.alpakka.amqp.WriteResult;
+import akka.stream.alpakka.testkit.javadsl.LogCapturingJunit4;
 import akka.stream.javadsl.Flow;
 import akka.stream.javadsl.FlowWithContext;
 import akka.stream.javadsl.Keep;
 import akka.stream.javadsl.Source;
 import akka.stream.testkit.TestSubscriber;
 import akka.stream.testkit.javadsl.TestSink;
 import akka.util.ByteString;
-
+import java.time.Duration;
+import java.util.Arrays;
+import java.util.List;
+import java.util.concurrent.CompletionStage;
+import java.util.stream.Collectors;
+import org.junit.BeforeClass;
+import org.junit.Rule;
+import org.junit.Test;
 import scala.jdk.javaapi.CollectionConverters;
 
 /** Needs a local running AMQP server on the default port with no password. */
@@ -85,9 +82,7 @@ private void shouldEmitConfirmationForPublishedMessages(
             .toMat(TestSink.create(system), Keep.right())
             .run(system);
 
-    result
-        .request(input.size())
-        .expectNextN(CollectionConverters.asScala(expectedOutput).toList());
+    result.request(input.size()).expectNextN(CollectionConverters.asScala(expectedOutput).toList());
   }
 
   @Test
@@ -119,9 +114,7 @@ private void shouldPropagateContext(
             .toMat(TestSink.create(system), Keep.right())
             .run(system);
 
-    result
-        .request(input.size())
-        .expectNextN(CollectionConverters.asScala(expectedOutput).toList());
+    result.request(input.size()).expectNextN(CollectionConverters.asScala(expectedOutput).toList());
   }
 
   @Test
@@ -142,8 +135,6 @@ public void shouldPropagatePassThrough() {
             .toMat(TestSink.create(system), Keep.right())
             .run(system);
 
-    result
-        .request(input.size())
-        .expectNextN(CollectionConverters.asScala(expectedOutput).toList());
+    result.request(input.size()).expectNextN(CollectionConverters.asScala(expectedOutput).toList());
   }
 }

amqp/src/test/java/docs/javadsl/AmqpDocsTest.java

@@ -4,6 +4,8 @@
 
 package docs.javadsl;
 
+import static org.junit.Assert.assertEquals;
+
 import akka.Done;
 import akka.NotUsed;
 import akka.actor.ActorSystem;
@@ -27,17 +29,13 @@
 import akka.stream.testkit.javadsl.TestSink;
 import akka.testkit.javadsl.TestKit;
 import akka.util.ByteString;
-
-import org.junit.*;
-
 import java.time.Duration;
 import java.util.*;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.CompletionStage;
 import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
-
-import static org.junit.Assert.assertEquals;
+import org.junit.*;
 
 /** Needs a local running AMQP server on the default port with no password. */
 public class AmqpDocsTest {

awslambda/src/test/java/docs/javadsl/AwsLambdaFlowTest.java

@@ -4,6 +4,11 @@
 
 package docs.javadsl;
 
+import static org.junit.Assert.assertEquals;
+import static org.mockito.ArgumentMatchers.eq;
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.when;
+
 import akka.NotUsed;
 import akka.actor.ActorSystem;
 import akka.stream.alpakka.awslambda.javadsl.AwsLambdaFlow;
@@ -13,20 +18,14 @@
 import akka.stream.javadsl.Source;
 import akka.stream.testkit.javadsl.StreamTestKit;
 import akka.testkit.javadsl.TestKit;
-import org.junit.*;
-import software.amazon.awssdk.services.lambda.LambdaAsyncClient;
-import software.amazon.awssdk.services.lambda.model.InvokeRequest;
-import software.amazon.awssdk.services.lambda.model.InvokeResponse;
-
 import java.util.List;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.CompletionStage;
 import java.util.concurrent.TimeUnit;
-
-import static org.junit.Assert.assertEquals;
-import static org.mockito.ArgumentMatchers.eq;
-import static org.mockito.Mockito.mock;
-import static org.mockito.Mockito.when;
+import org.junit.*;
+import software.amazon.awssdk.services.lambda.LambdaAsyncClient;
+import software.amazon.awssdk.services.lambda.model.InvokeRequest;
+import software.amazon.awssdk.services.lambda.model.InvokeResponse;
 
 public class AwsLambdaFlowTest {
 

azure-storage-queue/src/test/java/docs/javadsl/JavaDslTest.java

@@ -16,15 +16,13 @@
 import akka.testkit.javadsl.TestKit;
 import com.microsoft.azure.storage.*;
 import com.microsoft.azure.storage.queue.*;
-
 import java.time.Duration;
 import java.util.List;
 import java.util.concurrent.CompletionStage;
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.TimeoutException;
 import java.util.function.Supplier;
-
 import org.junit.*;
 
 public class JavaDslTest {

azure-storage/src/test/java/docs/javadsl/RequestBuilderTest.java

@@ -19,65 +19,68 @@
 
 public class RequestBuilderTest {
 
-    @Rule
-    public final LogCapturingJunit4 logCapturing = new LogCapturingJunit4();
-
-    @Test
-    public void createSimpleRequest() {
-
-        //#simple-request-builder
-        final GetBlob requestBuilder = GetBlob.create();
-        //#simple-request-builder
-
-        Assert.assertEquals(Option.empty(), requestBuilder.versionId());
-        Assert.assertEquals(Option.empty(), requestBuilder.range());
-        Assert.assertEquals(Option.empty(), requestBuilder.leaseId());
-        Assert.assertEquals(Option.empty(), requestBuilder.sse());
-    }
-
-    @Test
-    public void populateRequestBuilder() {
-
-        //#populate-request-builder
-        final var requestBuilder = GetBlob.create().withLeaseId("my-lease-id").withRange(ByteRange.createSlice(0, 25));
-        //#populate-request-builder
-
-        Assert.assertEquals(Option.apply("my-lease-id"), requestBuilder.leaseId());
-        Assert.assertEquals(Option.apply(ByteRange.createSlice(0, 25)), requestBuilder.range());
-        Assert.assertEquals(Option.empty(), requestBuilder.sse());
-    }
-
-    @Test
-    public void createRequestBuilderWithMandatoryParams() {
-
-        //#request-builder-with-initial-values
-        final var requestBuilder = CreateFile.create(256L, ContentTypes.TEXT_PLAIN_UTF8);
-        //#request-builder-with-initial-values
-
-        Assert.assertEquals(Option.empty(), requestBuilder.leaseId());
-        Assert.assertEquals(256L, requestBuilder.maxFileSize());
-        Assert.assertEquals(ContentTypes.TEXT_PLAIN_UTF8, requestBuilder.contentType());
-    }
-
-    @Test
-    public void populateServerSideEncryption() {
-
-        //#request-builder-with-sse
-        final var requestBuilder = PutBlockBlob.create(256L, ContentTypes.TEXT_PLAIN_UTF8)
-                .withServerSideEncryption(ServerSideEncryption.customerKey("SGVsbG9Xb3JsZA=="));
-        //#request-builder-with-sse
-
-        Assert.assertEquals(ServerSideEncryption.customerKey("SGVsbG9Xb3JsZA=="), requestBuilder.sse().get());
-    }
-
-    @Test
-    public void populateAdditionalHeaders() {
-
-        //#request-builder-with-additional-headers
-        final var requestBuilder = GetBlob.create().addHeader("If-Match", "foobar");
-        //#request-builder-with-additional-headers
-
-        Assert.assertEquals(1, requestBuilder.additionalHeaders().size());
-        Assert.assertEquals(new RawHeader("If-Match", "foobar"), requestBuilder.additionalHeaders().head());
-    }
+  @Rule public final LogCapturingJunit4 logCapturing = new LogCapturingJunit4();
+
+  @Test
+  public void createSimpleRequest() {
+
+    // #simple-request-builder
+    final GetBlob requestBuilder = GetBlob.create();
+    // #simple-request-builder
+
+    Assert.assertEquals(Option.empty(), requestBuilder.versionId());
+    Assert.assertEquals(Option.empty(), requestBuilder.range());
+    Assert.assertEquals(Option.empty(), requestBuilder.leaseId());
+    Assert.assertEquals(Option.empty(), requestBuilder.sse());
+  }
+
+  @Test
+  public void populateRequestBuilder() {
+
+    // #populate-request-builder
+    final var requestBuilder =
+        GetBlob.create().withLeaseId("my-lease-id").withRange(ByteRange.createSlice(0, 25));
+    // #populate-request-builder
+
+    Assert.assertEquals(Option.apply("my-lease-id"), requestBuilder.leaseId());
+    Assert.assertEquals(Option.apply(ByteRange.createSlice(0, 25)), requestBuilder.range());
+    Assert.assertEquals(Option.empty(), requestBuilder.sse());
+  }
+
+  @Test
+  public void createRequestBuilderWithMandatoryParams() {
+
+    // #request-builder-with-initial-values
+    final var requestBuilder = CreateFile.create(256L, ContentTypes.TEXT_PLAIN_UTF8);
+    // #request-builder-with-initial-values
+
+    Assert.assertEquals(Option.empty(), requestBuilder.leaseId());
+    Assert.assertEquals(256L, requestBuilder.maxFileSize());
+    Assert.assertEquals(ContentTypes.TEXT_PLAIN_UTF8, requestBuilder.contentType());
+  }
+
+  @Test
+  public void populateServerSideEncryption() {
+
+    // #request-builder-with-sse
+    final var requestBuilder =
+        PutBlockBlob.create(256L, ContentTypes.TEXT_PLAIN_UTF8)
+            .withServerSideEncryption(ServerSideEncryption.customerKey("SGVsbG9Xb3JsZA=="));
+    // #request-builder-with-sse
+
+    Assert.assertEquals(
+        ServerSideEncryption.customerKey("SGVsbG9Xb3JsZA=="), requestBuilder.sse().get());
+  }
+
+  @Test
+  public void populateAdditionalHeaders() {
+
+    // #request-builder-with-additional-headers
+    final var requestBuilder = GetBlob.create().addHeader("If-Match", "foobar");
+    // #request-builder-with-additional-headers
+
+    Assert.assertEquals(1, requestBuilder.additionalHeaders().size());
+    Assert.assertEquals(
+        new RawHeader("If-Match", "foobar"), requestBuilder.additionalHeaders().head());
+  }
 }