Merge branch 'eugenp:master' into master

annotations/annotation-processing/pom.xml

@@ -10,7 +10,6 @@
         <groupId>com.baeldung</groupId>
         <version>1.0.0-SNAPSHOT</version>
         <artifactId>annotations</artifactId>
-        <relativePath>../</relativePath>
     </parent>
 
     <dependencies>

annotations/annotation-user/pom.xml

@@ -10,7 +10,6 @@
         <groupId>com.baeldung</groupId>
         <artifactId>annotations</artifactId>
         <version>1.0.0-SNAPSHOT</version>
-        <relativePath>../</relativePath>
     </parent>
 
     <dependencies>

apache-kafka/src/test/java/com/baeldung/kafka/admin/KafkaTopicApplicationLiveTest.java

@@ -12,8 +12,10 @@ import java.util.Properties;
 
 import static org.assertj.core.api.Assertions.assertThat;
 
+// This live test needs a running Docker instance so that a kafka container can be created 
+
 @Testcontainers
-class KafkaTopicApplicationIntegrationTest {
+class KafkaTopicApplicationLiveTest {
 
     @Container
     private static final KafkaContainer KAFKA_CONTAINER = new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:5.4.3"));

apache-kafka/src/test/java/com/baeldung/kafka/serdes/KafkaSerDesLiveTest.java

@@ -20,6 +20,8 @@ import java.util.concurrent.atomic.AtomicReference;
 
 import static org.junit.Assert.assertEquals;
 
+// This live test needs a Docker instance running so that kafka container can be created
+
 public class KafkaSerDesLiveTest {
     private static final String CONSUMER_APP_ID = "consumer_id";
     private static final String CONSUMER_GROUP_ID = "group_id";

apache-kafka/src/test/java/com/baeldung/kafka/streamsvsconsumer/KafkaStreamsLiveTest.java

@@ -44,6 +44,8 @@ import static org.apache.kafka.clients.consumer.ConsumerConfig.BOOTSTRAP_SERVERS
 import static org.apache.kafka.clients.producer.ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG;
 import static org.apache.kafka.clients.producer.ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG;
 
+// This live test needs a Docker instance running so that kafka container can be created
+
 public class KafkaStreamsLiveTest {
     private final String LEFT_TOPIC = "left-stream-topic";
     private final String RIGHT_TOPIC = "right-stream-topic";

core-java-modules/core-java-8-2/pom.xml

@@ -12,7 +12,6 @@
         <groupId>com.baeldung.core-java-modules</groupId>
         <artifactId>core-java-modules</artifactId>
         <version>0.0.1-SNAPSHOT</version>
-        <relativePath>../</relativePath>
     </parent>
 
     <dependencies>

core-java-modules/core-java-8-datetime-2/pom.xml

@@ -12,7 +12,6 @@
         <groupId>com.baeldung.core-java-modules</groupId>
         <artifactId>core-java-modules</artifactId>
         <version>0.0.1-SNAPSHOT</version>
-        <relativePath>../</relativePath>
     </parent>
 
     <dependencies>

core-java-modules/core-java-8-datetime/pom.xml

@@ -12,7 +12,6 @@
         <groupId>com.baeldung.core-java-modules</groupId>
         <artifactId>core-java-modules</artifactId>
         <version>0.0.1-SNAPSHOT</version>
-        <relativePath>../</relativePath>
     </parent>
 
     <dependencies>

core-java-modules/core-java-8/pom.xml

@@ -12,7 +12,6 @@
         <groupId>com.baeldung.core-java-modules</groupId>
         <artifactId>core-java-modules</artifactId>
         <version>0.0.1-SNAPSHOT</version>
-        <relativePath>../</relativePath>
     </parent>
 
     <dependencies>

core-java-modules/core-java-9-new-features/README.md

@@ -6,7 +6,6 @@ This module contains articles about core Java features that have been introduced
 
 - [New Features in Java 9](https://www.baeldung.com/new-java-9)
 - [Java 9 Variable Handles Demystified](http://www.baeldung.com/java-variable-handles)
-- [Exploring the New HTTP Client in Java 9 and 11](http://www.baeldung.com/java-9-http-client)
 - [Multi-Release Jar Files](https://www.baeldung.com/java-multi-release-jar)
 - [Ahead of Time Compilation (AoT)](https://www.baeldung.com/ahead-of-time-compilation)
 - [Introduction to Java 9 StackWalking API](https://www.baeldung.com/java-9-stackwalking-api)

core-java-modules/core-java-9-new-features/src/modules/com.baeldung.httpclient/com/baeldung/httpclient/HttpClientExample.java

@@ -1,84 +0,0 @@
-/*
- * To change this license header, choose License Headers in Project Properties.
- * To change this template file, choose Tools | Templates
- * and open the template in the editor.
- */
-package com.baeldung.httpclient;
-
-import java.io.File;
-import java.io.IOException;
-import java.net.URI;
-import java.net.URISyntaxException;
-import java.nio.file.Paths;
-import java.util.Arrays;
-import java.util.List;
-import java.util.concurrent.CompletableFuture;
-import java.util.stream.Collectors;
-import jdk.incubator.http.HttpClient;
-import jdk.incubator.http.HttpRequest;
-import jdk.incubator.http.HttpRequest.BodyProcessor;
-import jdk.incubator.http.HttpResponse;
-import jdk.incubator.http.HttpResponse.BodyHandler;
-
-/**
- *
- * @author pkaria
- */
-public class HttpClientExample {
-    
-    public static void main(String[] args) throws Exception {
-        httpGetRequest();
-        httpPostRequest();
-        asynchronousRequest();
-        asynchronousMultipleRequests();
-    }
-
-    public static void httpGetRequest() throws URISyntaxException, IOException, InterruptedException {
-        HttpClient client = HttpClient.newHttpClient();
-        URI httpURI = new URI("http://jsonplaceholder.typicode.com/posts/1");
-        HttpRequest request = HttpRequest.newBuilder(httpURI).GET()
-          .headers("Accept-Enconding", "gzip, deflate").build();
-        HttpResponse<String> response = client.send(request, HttpResponse.BodyHandler.asString());
-        String responseBody = response.body();
-        int responseStatusCode = response.statusCode();
-        System.out.println(responseBody);
-    }
-
-    public static void httpPostRequest() throws URISyntaxException, IOException, InterruptedException {
-        HttpClient client = HttpClient
-                .newBuilder()
-                .build();
-        HttpRequest request = HttpRequest
-                .newBuilder(new URI("http://jsonplaceholder.typicode.com/posts"))
-                .POST(BodyProcessor.fromString("Sample Post Request"))
-                .build();
-        HttpResponse<String> response
-                = client.send(request, HttpResponse.BodyHandler.asString());
-        String responseBody = response.body();
-        System.out.println(responseBody);
-    }
-
-    public static void asynchronousRequest() throws URISyntaxException {
-        HttpClient client = HttpClient.newHttpClient();
-        URI httpURI = new URI("http://jsonplaceholder.typicode.com/posts/1");
-        HttpRequest request = HttpRequest.newBuilder(httpURI).GET().build();
-        CompletableFuture<HttpResponse<String>> futureResponse = client.sendAsync(request,
-                HttpResponse.BodyHandler.asString());
-    }
-
-    public static void asynchronousMultipleRequests() throws URISyntaxException {
-        List<URI> targets = Arrays.asList(new URI("http://jsonplaceholder.typicode.com/posts/1"), new URI("http://jsonplaceholder.typicode.com/posts/2"));
-        HttpClient client = HttpClient.newHttpClient();
-        List<CompletableFuture<File>> futures = targets
-                .stream()
-                .map(target -> client
-                .sendAsync(
-                        HttpRequest.newBuilder(target)
-                                .GET()
-                                .build(),
-                        BodyHandler.asFile(Paths.get("base", target.getPath())))
-                .thenApply(response -> response.body())
-                .thenApply(path -> path.toFile()))
-                .collect(Collectors.toList());
-    }
-}

core-java-modules/core-java-9-new-features/src/modules/com.baeldung.httpclient/module-info.java

@@ -1,3 +0,0 @@
-module com.baeldung.httpclient {   
-	requires jdk.incubator.httpclient;
-}

core-java-modules/core-java-9-new-features/src/test/java/com/baeldung/java9/httpclient/HttpClientIntegrationTest.java

@@ -1,218 +0,0 @@
-package com.baeldung.java9.httpclient;
-
-import jdk.incubator.http.HttpClient;
-import jdk.incubator.http.HttpRequest;
-import jdk.incubator.http.HttpResponse;
-import org.junit.Test;
-
-import java.io.IOException;
-import java.net.*;
-import java.util.Arrays;
-import java.util.List;
-import java.util.concurrent.CompletableFuture;
-import java.util.concurrent.ExecutionException;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
-import java.util.stream.Collectors;
-
-import static org.hamcrest.CoreMatchers.containsString;
-import static org.hamcrest.CoreMatchers.equalTo;
-import static org.hamcrest.collection.IsEmptyCollection.empty;
-import static org.hamcrest.core.IsNot.not;
-import static org.junit.Assert.assertThat;
-
-/**
- * Created by adam.
- */
-public class HttpClientIntegrationTest {
-
-    @Test
-    public void shouldReturnSampleDataContentWhenConnectViaSystemProxy() throws IOException, InterruptedException, URISyntaxException {
-        HttpRequest request = HttpRequest.newBuilder()
-            .uri(new URI("https://postman-echo.com/post"))
-            .headers("Content-Type", "text/plain;charset=UTF-8")
-            .POST(HttpRequest.BodyProcessor.fromString("Sample body"))
-            .build();
-
-        HttpResponse<String> response = HttpClient.newBuilder()
-            .proxy(ProxySelector.getDefault())
-            .build()
-            .send(request, HttpResponse.BodyHandler.asString());
-
-        assertThat(response.statusCode(), equalTo(HttpURLConnection.HTTP_OK));
-        assertThat(response.body(), containsString("Sample body"));
-    }
-
-    @Test
-    public void shouldNotFollowRedirectWhenSetToDefaultNever() throws IOException, InterruptedException, URISyntaxException {
-        HttpRequest request = HttpRequest.newBuilder()
-            .uri(new URI("http://stackoverflow.com"))
-            .version(HttpClient.Version.HTTP_1_1)
-            .GET()
-            .build();
-        HttpResponse<String> response = HttpClient.newBuilder()
-            .build()
-            .send(request, HttpResponse.BodyHandler.asString());
-
-        assertThat(response.statusCode(), equalTo(HttpURLConnection.HTTP_MOVED_PERM));
-        assertThat(response.body(), containsString(""));
-    }
-
-    @Test
-    public void shouldFollowRedirectWhenSetToAlways() throws IOException, InterruptedException, URISyntaxException {
-        HttpRequest request = HttpRequest.newBuilder()
-            .uri(new URI("http://stackoverflow.com"))
-            .version(HttpClient.Version.HTTP_1_1)
-            .GET()
-            .build();
-        HttpResponse<String> response = HttpClient.newBuilder()
-            .followRedirects(HttpClient.Redirect.ALWAYS)
-            .build()
-            .send(request, HttpResponse.BodyHandler.asString());
-
-        assertThat(response.statusCode(), equalTo(HttpURLConnection.HTTP_OK));
-        assertThat(response.finalRequest()
-            .uri()
-            .toString(), equalTo("https://stackoverflow.com/"));
-    }
-
-    @Test
-    public void shouldReturnOKStatusForAuthenticatedAccess() throws URISyntaxException, IOException, InterruptedException {
-        HttpRequest request = HttpRequest.newBuilder()
-            .uri(new URI("https://postman-echo.com/basic-auth"))
-            .GET()
-            .build();
-        HttpResponse<String> response = HttpClient.newBuilder()
-            .authenticator(new Authenticator() {
-                @Override
-                protected PasswordAuthentication getPasswordAuthentication() {
-                    return new PasswordAuthentication("postman", "password".toCharArray());
-                }
-            })
-            .build()
-            .send(request, HttpResponse.BodyHandler.asString());
-
-        assertThat(response.statusCode(), equalTo(HttpURLConnection.HTTP_OK));
-    }
-
-    @Test
-    public void shouldSendRequestAsync() throws URISyntaxException, InterruptedException, ExecutionException {
-        HttpRequest request = HttpRequest.newBuilder()
-            .uri(new URI("https://postman-echo.com/post"))
-            .headers("Content-Type", "text/plain;charset=UTF-8")
-            .POST(HttpRequest.BodyProcessor.fromString("Sample body"))
-            .build();
-        CompletableFuture<HttpResponse<String>> response = HttpClient.newBuilder()
-            .build()
-            .sendAsync(request, HttpResponse.BodyHandler.asString());
-
-        assertThat(response.get()
-            .statusCode(), equalTo(HttpURLConnection.HTTP_OK));
-    }
-
-    @Test
-    public void shouldUseJustTwoThreadWhenProcessingSendAsyncRequest() throws URISyntaxException, InterruptedException, ExecutionException {
-        HttpRequest request = HttpRequest.newBuilder()
-            .uri(new URI("https://postman-echo.com/get"))
-            .GET()
-            .build();
-
-        ExecutorService executorService = Executors.newFixedThreadPool(2);
-
-        CompletableFuture<HttpResponse<String>> response1 = HttpClient.newBuilder()
-            .executor(executorService)
-            .build()
-            .sendAsync(request, HttpResponse.BodyHandler.asString());
-
-        CompletableFuture<HttpResponse<String>> response2 = HttpClient.newBuilder()
-            .executor(executorService)
-            .build()
-            .sendAsync(request, HttpResponse.BodyHandler.asString());
-
-        CompletableFuture<HttpResponse<String>> response3 = HttpClient.newBuilder()
-            .executor(executorService)
-            .build()
-            .sendAsync(request, HttpResponse.BodyHandler.asString());
-
-        CompletableFuture.allOf(response1, response2, response3)
-            .join();
-
-        assertThat(response1.get()
-            .statusCode(), equalTo(HttpURLConnection.HTTP_OK));
-        assertThat(response2.get()
-            .statusCode(), equalTo(HttpURLConnection.HTTP_OK));
-        assertThat(response3.get()
-            .statusCode(), equalTo(HttpURLConnection.HTTP_OK));
-    }
-
-    @Test
-    public void shouldNotStoreCookieWhenPolicyAcceptNone() throws URISyntaxException, IOException, InterruptedException {
-        HttpRequest request = HttpRequest.newBuilder()
-            .uri(new URI("https://postman-echo.com/get"))
-            .GET()
-            .build();
-
-        HttpClient httpClient = HttpClient.newBuilder()
-            .cookieManager(new CookieManager(null, CookiePolicy.ACCEPT_NONE))
-            .build();
-
-        httpClient.send(request, HttpResponse.BodyHandler.asString());
-
-        assertThat(httpClient.cookieManager()
-            .get()
-            .getCookieStore()
-            .getCookies(), empty());
-    }
-
-    @Test
-    public void shouldStoreCookieWhenPolicyAcceptAll() throws URISyntaxException, IOException, InterruptedException {
-        HttpRequest request = HttpRequest.newBuilder()
-            .uri(new URI("https://postman-echo.com/get"))
-            .GET()
-            .build();
-
-        HttpClient httpClient = HttpClient.newBuilder()
-            .cookieManager(new CookieManager(null, CookiePolicy.ACCEPT_ALL))
-            .build();
-
-        httpClient.send(request, HttpResponse.BodyHandler.asString());
-
-        assertThat(httpClient.cookieManager()
-            .get()
-            .getCookieStore()
-            .getCookies(), not(empty()));
-    }
-
-    @Test
-    public void shouldProcessMultipleRequestViaStream() throws URISyntaxException, ExecutionException, InterruptedException {
-        List<URI> targets = Arrays.asList(new URI("https://postman-echo.com/get?foo1=bar1"), new URI("https://postman-echo.com/get?foo2=bar2"));
-
-        HttpClient client = HttpClient.newHttpClient();
-
-        List<CompletableFuture<String>> futures = targets.stream()
-            .map(target -> client.sendAsync(HttpRequest.newBuilder(target)
-                .GET()
-                .build(), HttpResponse.BodyHandler.asString())
-                .thenApply(response -> response.body()))
-            .collect(Collectors.toList());
-
-        CompletableFuture.allOf(futures.toArray(new CompletableFuture[0]))
-            .join();
-
-        if (futures.get(0)
-            .get()
-            .contains("foo1")) {
-            assertThat(futures.get(0)
-                .get(), containsString("bar1"));
-            assertThat(futures.get(1)
-                .get(), containsString("bar2"));
-        } else {
-            assertThat(futures.get(1)
-                .get(), containsString("bar2"));
-            assertThat(futures.get(1)
-                .get(), containsString("bar1"));
-        }
-
-    }
-
-}

core-java-modules/core-java-9-new-features/src/test/java/com/baeldung/java9/httpclient/HttpRequestIntegrationTest.java

@@ -1,171 +0,0 @@
-package com.baeldung.java9.httpclient;
-
-import jdk.incubator.http.HttpClient;
-import jdk.incubator.http.HttpRequest;
-import jdk.incubator.http.HttpResponse;
-import org.junit.Test;
-
-import java.io.ByteArrayInputStream;
-import java.io.IOException;
-import java.net.HttpURLConnection;
-import java.net.URI;
-import java.net.URISyntaxException;
-import java.nio.file.Paths;
-import java.security.NoSuchAlgorithmException;
-import java.time.Duration;
-
-import static java.time.temporal.ChronoUnit.SECONDS;
-import static org.hamcrest.CoreMatchers.containsString;
-import static org.hamcrest.CoreMatchers.equalTo;
-import static org.junit.Assert.assertThat;
-
-/**
- * Created by adam.
- */
-public class HttpRequestIntegrationTest {
-
-    @Test
-    public void shouldReturnStatusOKWhenSendGetRequest() throws IOException, InterruptedException, URISyntaxException {
-        HttpRequest request = HttpRequest.newBuilder()
-            .uri(new URI("https://postman-echo.com/get"))
-            .GET()
-            .build();
-
-        HttpResponse<String> response = HttpClient.newHttpClient()
-            .send(request, HttpResponse.BodyHandler.asString());
-
-        assertThat(response.statusCode(), equalTo(HttpURLConnection.HTTP_OK));
-    }
-
-    @Test
-    public void shouldUseHttp2WhenWebsiteUsesHttp2() throws IOException, InterruptedException, URISyntaxException {
-        HttpRequest request = HttpRequest.newBuilder()
-            .uri(new URI("https://stackoverflow.com"))
-            .version(HttpClient.Version.HTTP_2)
-            .GET()
-            .build();
-        HttpResponse<String> response = HttpClient.newHttpClient()
-            .send(request, HttpResponse.BodyHandler.asString());
-
-        assertThat(response.statusCode(), equalTo(HttpURLConnection.HTTP_OK));
-        assertThat(response.version(), equalTo(HttpClient.Version.HTTP_2));
-    }
-
-    @Test
-    public void shouldFallbackToHttp1_1WhenWebsiteDoesNotUseHttp2() throws IOException, InterruptedException, URISyntaxException, NoSuchAlgorithmException {
-        HttpRequest request = HttpRequest.newBuilder()
-            .uri(new URI("https://postman-echo.com/get"))
-            .version(HttpClient.Version.HTTP_2)
-            .GET()
-            .build();
-
-        HttpResponse<String> response = HttpClient.newHttpClient()
-            .send(request, HttpResponse.BodyHandler.asString());
-
-        assertThat(response.version(), equalTo(HttpClient.Version.HTTP_1_1));
-    }
-
-    @Test
-    public void shouldReturnStatusOKWhenSendGetRequestWithDummyHeaders() throws IOException, InterruptedException, URISyntaxException {
-        HttpRequest request = HttpRequest.newBuilder()
-            .uri(new URI("https://postman-echo.com/get"))
-            .headers("key1", "value1", "key2", "value2")
-            .GET()
-            .build();
-
-        HttpResponse<String> response = HttpClient.newHttpClient()
-            .send(request, HttpResponse.BodyHandler.asString());
-
-        assertThat(response.statusCode(), equalTo(HttpURLConnection.HTTP_OK));
-    }
-
-    @Test
-    public void shouldReturnStatusOKWhenSendGetRequestTimeoutSet() throws IOException, InterruptedException, URISyntaxException {
-        HttpRequest request = HttpRequest.newBuilder()
-            .uri(new URI("https://postman-echo.com/get"))
-            .timeout(Duration.of(10, SECONDS))
-            .GET()
-            .build();
-
-        HttpResponse<String> response = HttpClient.newHttpClient()
-            .send(request, HttpResponse.BodyHandler.asString());
-
-        assertThat(response.statusCode(), equalTo(HttpURLConnection.HTTP_OK));
-    }
-
-    @Test
-    public void shouldReturnNoContentWhenPostWithNoBody() throws IOException, InterruptedException, URISyntaxException {
-        HttpRequest request = HttpRequest.newBuilder()
-            .uri(new URI("https://postman-echo.com/post"))
-            .POST(HttpRequest.noBody())
-            .build();
-
-        HttpResponse<String> response = HttpClient.newHttpClient()
-            .send(request, HttpResponse.BodyHandler.asString());
-
-        assertThat(response.statusCode(), equalTo(HttpURLConnection.HTTP_OK));
-    }
-
-    @Test
-    public void shouldReturnSampleDataContentWhenPostWithBodyText() throws IOException, InterruptedException, URISyntaxException {
-        HttpRequest request = HttpRequest.newBuilder()
-            .uri(new URI("https://postman-echo.com/post"))
-            .headers("Content-Type", "text/plain;charset=UTF-8")
-            .POST(HttpRequest.BodyProcessor.fromString("Sample request body"))
-            .build();
-
-        HttpResponse<String> response = HttpClient.newHttpClient()
-            .send(request, HttpResponse.BodyHandler.asString());
-
-        assertThat(response.statusCode(), equalTo(HttpURLConnection.HTTP_OK));
-        assertThat(response.body(), containsString("Sample request body"));
-    }
-
-    @Test
-    public void shouldReturnSampleDataContentWhenPostWithInputStream() throws IOException, InterruptedException, URISyntaxException {
-        byte[] sampleData = "Sample request body".getBytes();
-        HttpRequest request = HttpRequest.newBuilder()
-            .uri(new URI("https://postman-echo.com/post"))
-            .headers("Content-Type", "text/plain;charset=UTF-8")
-            .POST(HttpRequest.BodyProcessor.fromInputStream(() -> new ByteArrayInputStream(sampleData)))
-            .build();
-
-        HttpResponse<String> response = HttpClient.newHttpClient()
-            .send(request, HttpResponse.BodyHandler.asString());
-
-        assertThat(response.statusCode(), equalTo(HttpURLConnection.HTTP_OK));
-        assertThat(response.body(), containsString("Sample request body"));
-    }
-
-    @Test
-    public void shouldReturnSampleDataContentWhenPostWithByteArrayProcessorStream() throws IOException, InterruptedException, URISyntaxException {
-        byte[] sampleData = "Sample request body".getBytes();
-        HttpRequest request = HttpRequest.newBuilder()
-            .uri(new URI("https://postman-echo.com/post"))
-            .headers("Content-Type", "text/plain;charset=UTF-8")
-            .POST(HttpRequest.BodyProcessor.fromByteArray(sampleData))
-            .build();
-
-        HttpResponse<String> response = HttpClient.newHttpClient()
-            .send(request, HttpResponse.BodyHandler.asString());
-
-        assertThat(response.statusCode(), equalTo(HttpURLConnection.HTTP_OK));
-        assertThat(response.body(), containsString("Sample request body"));
-    }
-
-    @Test
-    public void shouldReturnSampleDataContentWhenPostWithFileProcessorStream() throws IOException, InterruptedException, URISyntaxException {
-        HttpRequest request = HttpRequest.newBuilder()
-            .uri(new URI("https://postman-echo.com/post"))
-            .headers("Content-Type", "text/plain;charset=UTF-8")
-            .POST(HttpRequest.BodyProcessor.fromFile(Paths.get("src/test/resources/sample.txt")))
-            .build();
-
-        HttpResponse<String> response = HttpClient.newHttpClient()
-            .send(request, HttpResponse.BodyHandler.asString());
-
-        assertThat(response.statusCode(), equalTo(HttpURLConnection.HTTP_OK));
-        assertThat(response.body(), containsString("Sample file content"));
-    }
-
-}

core-java-modules/core-java-9-new-features/src/test/java/com/baeldung/java9/httpclient/HttpResponseIntegrationTest.java

@@ -1,55 +0,0 @@
-package com.baeldung.java9.httpclient;
-
-import jdk.incubator.http.HttpClient;
-import jdk.incubator.http.HttpRequest;
-import jdk.incubator.http.HttpResponse;
-import org.junit.Test;
-
-import java.io.IOException;
-import java.net.HttpURLConnection;
-import java.net.URI;
-import java.net.URISyntaxException;
-
-import static org.hamcrest.CoreMatchers.equalTo;
-import static org.hamcrest.Matchers.isEmptyString;
-import static org.hamcrest.core.IsNot.not;
-import static org.junit.Assert.assertThat;
-
-/**
- * Created by adam.
- */
-public class HttpResponseIntegrationTest {
-
-    @Test
-    public void shouldReturnStatusOKWhenSendGetRequest() throws IOException, InterruptedException, URISyntaxException {
-        HttpRequest request = HttpRequest.newBuilder()
-            .uri(new URI("https://postman-echo.com/get"))
-            .GET()
-            .build();
-
-        HttpResponse<String> response = HttpClient.newHttpClient()
-            .send(request, HttpResponse.BodyHandler.asString());
-
-        assertThat(response.statusCode(), equalTo(HttpURLConnection.HTTP_OK));
-        assertThat(response.body(), not(isEmptyString()));
-    }
-
-    @Test
-    public void shouldResponseURIDifferentThanRequestUIRWhenRedirect() throws IOException, InterruptedException, URISyntaxException {
-        HttpRequest request = HttpRequest.newBuilder()
-            .uri(new URI("http://stackoverflow.com"))
-            .version(HttpClient.Version.HTTP_1_1)
-            .GET()
-            .build();
-        HttpResponse<String> response = HttpClient.newBuilder()
-            .followRedirects(HttpClient.Redirect.ALWAYS)
-            .build()
-            .send(request, HttpResponse.BodyHandler.asString());
-
-        assertThat(request.uri()
-            .toString(), equalTo("http://stackoverflow.com"));
-        assertThat(response.uri()
-            .toString(), equalTo("https://stackoverflow.com/"));
-    }
-
-}

core-java-modules/core-java-annotations/README.md

@@ -12,3 +12,4 @@
 - [Efficient Word Frequency Calculator in Java](https://www.baeldung.com/java-word-frequency)
 - [Why Missing Annotations Don’t Cause ClassNotFoundException](https://www.baeldung.com/classnotfoundexception-missing-annotation)
 - [Valid @SuppressWarnings Warning Names](https://www.baeldung.com/java-suppresswarnings-valid-names)
+- [Get a Field’s Annotations Using Reflection](https://www.baeldung.com/java-get-field-annotations)

core-java-modules/core-java-annotations/pom.xml

@@ -1,7 +1,7 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <project xmlns="http://maven.apache.org/POM/4.0.0"
-    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <modelVersion>4.0.0</modelVersion>
     <artifactId>core-java-annotations</artifactId>
     <version>0.1.0-SNAPSHOT</version>
@@ -12,9 +12,21 @@
         <groupId>com.baeldung.core-java-modules</groupId>
         <artifactId>core-java-modules</artifactId>
         <version>0.0.1-SNAPSHOT</version>
-        <relativePath>../</relativePath>
     </parent>
 
+    <dependencies>
+        <dependency>
+            <groupId>org.assertj</groupId>
+            <artifactId>assertj-core</artifactId>
+            <version>${assertj-core.version}</version>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+
+    <properties>
+        <assertj-core.version>3.10.0</assertj-core.version>
+    </properties>
+
     <build>
         <finalName>core-java-annotations</finalName>
         <resources>

core-java-modules/core-java-annotations/src/main/java/com/baeldung/readannotations/ClassWithAnnotations.java

@@ -0,0 +1,9 @@
+package com.baeldung.readannotations;
+
+public class ClassWithAnnotations {
+
+    @FirstAnnotation
+    @SecondAnnotation
+    @ThirdAnnotation
+    private String classMember;
+}

core-java-modules/core-java-annotations/src/main/java/com/baeldung/readannotations/FirstAnnotation.java

@@ -0,0 +1,8 @@
+package com.baeldung.readannotations;
+
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+
+@Retention(RetentionPolicy.RUNTIME)
+public @interface FirstAnnotation {
+}

core-java-modules/core-java-annotations/src/main/java/com/baeldung/readannotations/SecondAnnotation.java

@@ -0,0 +1,8 @@
+package com.baeldung.readannotations;
+
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+
+@Retention(RetentionPolicy.RUNTIME)
+public @interface SecondAnnotation {
+}

core-java-modules/core-java-annotations/src/main/java/com/baeldung/readannotations/ThirdAnnotation.java

@@ -0,0 +1,8 @@
+package com.baeldung.readannotations;
+
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+
+@Retention(RetentionPolicy.SOURCE)
+public @interface ThirdAnnotation {
+}

core-java-modules/core-java-annotations/src/test/java/com/baeldung/readannotations/ClassWithAnnotationsUnitTest.java

@@ -0,0 +1,34 @@
+package com.baeldung.readannotations;
+
+import org.junit.Test;
+
+import java.lang.annotation.Annotation;
+import java.lang.reflect.Field;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+public class ClassWithAnnotationsUnitTest {
+
+    @Test
+    public void whenCallingGetDeclaredAnnotations_thenOnlyRuntimeAnnotationsAreAvailable() throws NoSuchFieldException {
+        Field classMemberField = ClassWithAnnotations.class.getDeclaredField("classMember");
+        Annotation[] annotations = classMemberField.getDeclaredAnnotations();
+        assertThat(annotations).hasSize(2);
+    }
+
+    @Test
+    public void whenCallingIsAnnotationPresent_thenOnlyRuntimeAnnotationsAreAvailable() throws NoSuchFieldException {
+        Field classMemberField = ClassWithAnnotations.class.getDeclaredField("classMember");
+        assertThat(classMemberField.isAnnotationPresent(FirstAnnotation.class)).isTrue();
+        assertThat(classMemberField.isAnnotationPresent(SecondAnnotation.class)).isTrue();
+        assertThat(classMemberField.isAnnotationPresent(ThirdAnnotation.class)).isFalse();
+    }
+
+    @Test
+    public void whenCallingGetDeclaredAnnotationsOrGetAnnotations_thenSameAnnotationsAreReturned() throws NoSuchFieldException {
+        Field classMemberField = ClassWithAnnotations.class.getDeclaredField("classMember");
+        Annotation[] declaredAnnotations = classMemberField.getDeclaredAnnotations();
+        Annotation[] annotations = classMemberField.getAnnotations();
+        assertThat(declaredAnnotations).containsExactly(annotations);
+    }
+}

core-java-modules/core-java-arrays-convert/pom.xml

@@ -19,6 +19,11 @@
             <artifactId>guava</artifactId>
             <version>${guava.version}</version>
         </dependency>
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-lang3</artifactId>
+            <version>${commons-lang3.version}</version>
+        </dependency>
     </dependencies>
 
     <properties>

core-java-modules/core-java-arrays-convert/src/main/java/com/baeldung/array/conversions/ByteArrayToNumericRepresentation.java

@@ -0,0 +1,281 @@
+package com.baeldung.array.conversions;
+
+import com.google.common.primitives.Ints;
+import com.google.common.primitives.Longs;
+import org.apache.commons.lang3.ArrayUtils;
+import org.apache.commons.lang3.Conversion;
+
+import java.math.BigInteger;
+import java.nio.ByteBuffer;
+import java.util.Arrays;
+
+class ByteArrayToNumericRepresentation {
+
+    static int convertByteArrayToIntUsingShiftOperator(byte[] bytes) {
+        int value = 0;
+        for (byte b : bytes) {
+            value = (value << 8) + (b & 0xFF);
+        }
+        return value;
+    }
+
+    static byte[] convertIntToByteArrayUsingShiftOperator(int value) {
+        byte[] bytes = new byte[Integer.BYTES];
+        int length = bytes.length;
+        for (int i = 0; i < length; i++) {
+            bytes[length - i - 1] = (byte) (value & 0xFF);
+            value >>= 8;
+        }
+        return bytes;
+    }
+
+    static long convertByteArrayToLongUsingShiftOperator(byte[] bytes) {
+        long value = 0;
+        for (byte b : bytes) {
+            value <<= 8;
+            value |= (b & 0xFF);
+        }
+        return value;
+    }
+
+    static byte[] convertLongToByteArrayUsingShiftOperator(long value) {
+        byte[] bytes = new byte[Long.BYTES];
+        int length = bytes.length;
+        for (int i = 0; i < length; i++) {
+            bytes[length - i - 1] = (byte) (value & 0xFF);
+            value >>= 8;
+        }
+        return bytes;
+    }
+
+    static float convertByteArrayToFloatUsingShiftOperator(byte[] bytes) {
+        // convert bytes to int
+        int intValue = 0;
+        for (byte b : bytes) {
+            intValue = (intValue << 8) + (b & 0xFF);
+        }
+
+        // convert int to float
+        return Float.intBitsToFloat(intValue);
+    }
+
+    static byte[] convertFloatToByteArrayUsingShiftOperator(float value) {
+        // convert float to int
+        int intValue = Float.floatToIntBits(value);
+
+        // convert int to bytes
+        byte[] bytes = new byte[Float.BYTES];
+        int length = bytes.length;
+        for (int i = 0; i < length; i++) {
+            bytes[length - i - 1] = (byte) (intValue & 0xFF);
+            intValue >>= 8;
+        }
+        return bytes;
+    }
+
+    static double convertingByteArrayToDoubleUsingShiftOperator(byte[] bytes) {
+        long longValue = 0;
+        for (byte b : bytes) {
+            longValue = (longValue << 8) + (b & 0xFF);
+        }
+
+        return Double.longBitsToDouble(longValue);
+    }
+
+    static byte[] convertDoubleToByteArrayUsingShiftOperator(double value) {
+        long longValue = Double.doubleToLongBits(value);
+
+        byte[] bytes = new byte[Double.BYTES];
+        int length = bytes.length;
+        for (int i = 0; i < length; i++) {
+            bytes[length - i - 1] = (byte) (longValue & 0xFF);
+            longValue >>= 8;
+        }
+        return bytes;
+    }
+
+    static int convertByteArrayToIntUsingByteBuffer(byte[] bytes) {
+        ByteBuffer buffer = ByteBuffer.allocate(Integer.BYTES);
+        buffer.put(bytes);
+        buffer.rewind();
+        return buffer.getInt();
+    }
+
+    static byte[] convertIntToByteArrayUsingByteBuffer(int value) {
+        ByteBuffer buffer = ByteBuffer.allocate(Integer.BYTES);
+        buffer.putInt(value);
+        buffer.rewind();
+        return buffer.array();
+    }
+
+    static long convertByteArrayToLongUsingByteBuffer(byte[] bytes) {
+        ByteBuffer buffer = ByteBuffer.allocate(Long.BYTES);
+        buffer.put(bytes);
+        buffer.rewind();
+        return buffer.getLong();
+    }
+
+    static byte[] convertLongToByteArrayUsingByteBuffer(long value) {
+        ByteBuffer buffer = ByteBuffer.allocate(Long.BYTES);
+        buffer.putLong(value);
+        buffer.rewind();
+        return buffer.array();
+    }
+
+    static float convertByteArrayToFloatUsingByteBuffer(byte[] bytes) {
+        ByteBuffer buffer = ByteBuffer.allocate(Float.BYTES);
+        buffer.put(bytes);
+        buffer.rewind();
+        return buffer.getFloat();
+    }
+
+    static byte[] convertFloatToByteArrayUsingByteBuffer(float value) {
+        ByteBuffer buffer = ByteBuffer.allocate(Float.BYTES);
+        buffer.putFloat(value);
+        buffer.rewind();
+        return buffer.array();
+    }
+
+    static double convertByteArrayToDoubleUsingByteBuffer(byte[] bytes) {
+        ByteBuffer buffer = ByteBuffer.allocate(Double.BYTES);
+        buffer.put(bytes);
+        buffer.rewind();
+        return buffer.getDouble();
+    }
+
+    static byte[] convertDoubleToByteArrayUsingByteBuffer(double value) {
+        ByteBuffer buffer = ByteBuffer.allocate(Double.BYTES);
+        buffer.putDouble(value);
+        buffer.rewind();
+        return buffer.array();
+    }
+
+    static int convertByteArrayToIntUsingBigInteger(byte[] bytes) {
+        return new BigInteger(bytes).intValue();
+    }
+
+    static byte[] convertIntToByteArrayUsingBigInteger(int value) {
+        return BigInteger.valueOf(value).toByteArray();
+    }
+
+    static long convertByteArrayToLongUsingBigInteger(byte[] bytes) {
+        return new BigInteger(bytes).longValue();
+    }
+
+    static byte[] convertLongToByteArrayUsingBigInteger(long value) {
+        return BigInteger.valueOf(value).toByteArray();
+    }
+
+    static float convertByteArrayToFloatUsingBigInteger(byte[] bytes) {
+        int intValue = new BigInteger(bytes).intValue();
+        return Float.intBitsToFloat(intValue);
+    }
+
+    static byte[] convertFloatToByteArrayUsingBigInteger(float value) {
+        int intValue = Float.floatToIntBits(value);
+        return BigInteger.valueOf(intValue).toByteArray();
+    }
+
+    static double convertByteArrayToDoubleUsingBigInteger(byte[] bytes) {
+        long longValue = new BigInteger(bytes).longValue();
+        return Double.longBitsToDouble(longValue);
+    }
+
+    static byte[] convertDoubleToByteArrayUsingBigInteger(double value) {
+        long longValue = Double.doubleToLongBits(value);
+        return BigInteger.valueOf(longValue).toByteArray();
+    }
+
+    static int convertingByteArrayToIntUsingGuava(byte[] bytes) {
+        return Ints.fromByteArray(bytes);
+    }
+
+    static byte[] convertIntToByteArrayUsingGuava(int value) {
+        return Ints.toByteArray(value);
+    }
+
+    static long convertByteArrayToLongUsingGuava(byte[] bytes) {
+        return Longs.fromByteArray(bytes);
+    }
+
+    static byte[] convertLongToByteArrayUsingGuava(long value) {
+        return Longs.toByteArray(value);
+    }
+
+    static float convertByteArrayToFloatUsingGuava(byte[] bytes) {
+        int intValue = Ints.fromByteArray(bytes);
+        return Float.intBitsToFloat(intValue);
+    }
+
+    static byte[] convertFloatToByteArrayUsingGuava(float value) {
+        int intValue = Float.floatToIntBits(value);
+        return Ints.toByteArray(intValue);
+    }
+
+    static double convertByteArrayToDoubleUsingGuava(byte[] bytes) {
+        long longValue = Longs.fromByteArray(bytes);
+        return Double.longBitsToDouble(longValue);
+    }
+
+    static byte[] convertDoubleToByteArrayUsingGuava(double value) {
+        long longValue = Double.doubleToLongBits(value);
+        return Longs.toByteArray(longValue);
+    }
+
+    static int convertByteArrayToIntUsingCommonsLang(byte[] bytes) {
+        byte[] copyBytes = Arrays.copyOf(bytes, bytes.length);
+        ArrayUtils.reverse(copyBytes);
+        return Conversion.byteArrayToInt(copyBytes, 0, 0, 0, copyBytes.length);
+    }
+
+    static byte[] convertIntToByteArrayUsingCommonsLang(int value) {
+        byte[] bytes = new byte[Integer.BYTES];
+        Conversion.intToByteArray(value, 0, bytes, 0, bytes.length);
+        ArrayUtils.reverse(bytes);
+        return bytes;
+    }
+
+    static long convertByteArrayToLongUsingCommonsLang(byte[] bytes) {
+        byte[] copyBytes = Arrays.copyOf(bytes, bytes.length);
+        ArrayUtils.reverse(copyBytes);
+        return Conversion.byteArrayToLong(copyBytes, 0, 0, 0, copyBytes.length);
+    }
+
+    static byte[] convertLongToByteArrayUsingCommonsLang(long value) {
+        byte[] bytes = new byte[Long.BYTES];
+        Conversion.longToByteArray(value, 0, bytes, 0, bytes.length);
+        ArrayUtils.reverse(bytes);
+        return bytes;
+    }
+
+    static float convertByteArrayToFloatUsingCommonsLang(byte[] bytes) {
+        byte[] copyBytes = Arrays.copyOf(bytes, bytes.length);
+        ArrayUtils.reverse(copyBytes);
+        int intValue = Conversion.byteArrayToInt(copyBytes, 0, 0, 0, copyBytes.length);
+        return Float.intBitsToFloat(intValue);
+    }
+
+    static byte[] convertFloatToByteArrayUsingCommonsLang(float value) {
+        int intValue = Float.floatToIntBits(value);
+        byte[] bytes = new byte[Float.BYTES];
+        Conversion.intToByteArray(intValue, 0, bytes, 0, bytes.length);
+        ArrayUtils.reverse(bytes);
+        return bytes;
+    }
+
+    static double convertByteArrayToDoubleUsingCommonsLang(byte[] bytes) {
+        byte[] copyBytes = Arrays.copyOf(bytes, bytes.length);
+        ArrayUtils.reverse(copyBytes);
+        long longValue = Conversion.byteArrayToLong(copyBytes, 0, 0, 0, copyBytes.length);
+        return Double.longBitsToDouble(longValue);
+    }
+
+    static byte[] convertDoubleToByteArrayUsingCommonsLang(double value) {
+        long longValue = Double.doubleToLongBits(value);
+        byte[] bytes = new byte[Long.BYTES];
+        Conversion.longToByteArray(longValue, 0, bytes, 0, bytes.length);
+        ArrayUtils.reverse(bytes);
+        return bytes;
+    }
+
+}

core-java-modules/core-java-arrays-sorting/pom.xml

@@ -11,7 +11,6 @@
         <artifactId>core-java-modules</artifactId>
         <groupId>com.baeldung.core-java-modules</groupId>
         <version>0.0.1-SNAPSHOT</version>
-        <relativePath>../</relativePath>
     </parent>
 
     <dependencies>

core-java-modules/core-java-char/pom.xml

@@ -12,7 +12,6 @@
         <groupId>com.baeldung.core-java-modules</groupId>
         <artifactId>core-java-modules</artifactId>
         <version>0.0.1-SNAPSHOT</version>
-        <relativePath>../</relativePath>
     </parent>
 
     <dependencies>

core-java-modules/core-java-collections-2/pom.xml

@@ -11,7 +11,6 @@
         <groupId>com.baeldung.core-java-modules</groupId>
         <artifactId>core-java-modules</artifactId>
         <version>0.0.1-SNAPSHOT</version>
-        <relativePath>../</relativePath>
     </parent>
 
     <dependencies>

core-java-modules/core-java-collections-3/pom.xml

@@ -12,7 +12,6 @@
         <groupId>com.baeldung.core-java-modules</groupId>
         <artifactId>core-java-modules</artifactId>
         <version>0.0.1-SNAPSHOT</version>
-        <relativePath>../</relativePath>
     </parent>
 
     <dependencies>

core-java-modules/core-java-collections-4/pom.xml

@@ -12,7 +12,6 @@
         <groupId>com.baeldung.core-java-modules</groupId>
         <artifactId>core-java-modules</artifactId>
         <version>0.0.1-SNAPSHOT</version>
-        <relativePath>../pom.xml</relativePath>
     </parent>
 
     <dependencies>