Merge upstream changes

akka-modules/pom.xml

@@ -4,8 +4,8 @@
     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>akka-modules</artifactId>
-    <name>akka-modules</name>
     <packaging>pom</packaging>
+    <name>akka-modules</name>
 
     <parent>
         <artifactId>parent-modules</artifactId>

algorithms-modules/algorithms-miscellaneous-1/pom.xml

@@ -19,11 +19,6 @@
             <artifactId>commons-math3</artifactId>
             <version>${commons-math3.version}</version>
         </dependency>
-        <dependency>
-            <groupId>com.google.guava</groupId>
-            <artifactId>guava</artifactId>
-            <version>${guava.version}</version>
-        </dependency>
         <dependency>
             <groupId>commons-codec</groupId>
             <artifactId>commons-codec</artifactId>

algorithms-modules/algorithms-miscellaneous-5/pom.xml

@@ -5,6 +5,18 @@
     <modelVersion>4.0.0</modelVersion>
     <artifactId>algorithms-miscellaneous-5</artifactId>
     <version>0.0.1-SNAPSHOT</version>
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <configuration>
+                    <source>17</source>
+                    <target>17</target>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
     <name>algorithms-miscellaneous-5</name>
 
     <parent>
@@ -29,11 +41,7 @@
             <artifactId>tradukisto</artifactId>
             <version>${tradukisto.version}</version>
         </dependency>
-        <dependency>
-            <groupId>com.google.guava</groupId>
-            <artifactId>guava</artifactId>
-            <version>${guava.version}</version>
-        </dependency>
+
         <!-- API, java.xml.bind module -->
         <dependency>
             <groupId>jakarta.xml.bind</groupId>

algorithms-modules/algorithms-miscellaneous-5/src/main/java/com/baeldung/algorithms/conversion/HexStringConverter.java

@@ -1,15 +1,12 @@
 package com.baeldung.algorithms.conversion;
 
-import java.math.BigInteger;
-
-
-
+import com.google.common.io.BaseEncoding;
+import jakarta.xml.bind.DatatypeConverter;
 import org.apache.commons.codec.DecoderException;
 import org.apache.commons.codec.binary.Hex;
 
-import com.google.common.io.BaseEncoding;
-
-import jakarta.xml.bind.DatatypeConverter;
+import java.math.BigInteger;
+import java.util.HexFormat;
 
 public class HexStringConverter {
 
@@ -109,4 +106,14 @@ public class HexStringConverter {
         return BaseEncoding.base16()
             .decode(hexString.toUpperCase());
     }
+
+    public String encodeUsingHexFormat(byte[] bytes) {
+        HexFormat hexFormat = HexFormat.of();
+        return hexFormat.formatHex(bytes);
+    }
+
+    public byte[] decodeUsingHexFormat(String hexString) {
+        HexFormat hexFormat = HexFormat.of();
+        return hexFormat.parseHex(hexString);
+    }
 }

algorithms-modules/algorithms-miscellaneous-5/src/test/java/com/baeldung/algorithms/conversion/ByteArrayConverterUnitTest.java

@@ -1,15 +1,13 @@
 package com.baeldung.algorithms.conversion;
 
-import static org.hamcrest.MatcherAssert.assertThat;
-import static org.junit.jupiter.api.Assertions.assertArrayEquals;
-import static org.junit.jupiter.api.Assertions.assertThrows;
-
 import org.apache.commons.codec.DecoderException;
 import org.hamcrest.text.IsEqualIgnoringCase;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
 
-import com.baeldung.algorithms.conversion.HexStringConverter;
+import static org.hamcrest.MatcherAssert.assertThat;
+import static org.junit.jupiter.api.Assertions.assertArrayEquals;
+import static org.junit.jupiter.api.Assertions.assertThrows;
 
 class ByteArrayConverterUnitTest {
 
@@ -24,7 +22,7 @@ class ByteArrayConverterUnitTest {
     void shouldEncodeByteArrayToHexStringUsingBigIntegerToString() {
         byte[] bytes = getSampleBytes();
         String hexString = getSampleHexString();
-        if(hexString.charAt(0) == '0') {
+        if (hexString.charAt(0) == '0') {
             hexString = hexString.substring(1);
         }
         String output = hexStringConverter.encodeUsingBigIntegerToString(bytes);
@@ -46,7 +44,7 @@ class ByteArrayConverterUnitTest {
         byte[] output = hexStringConverter.decodeUsingBigInteger(hexString);
         assertArrayEquals(bytes, output);
     }
-    
+
     @Test
     void shouldEncodeByteArrayToHexStringUsingCharacterConversion() {
         byte[] bytes = getSampleBytes();
@@ -62,7 +60,7 @@ class ByteArrayConverterUnitTest {
         byte[] output = hexStringConverter.decodeHexString(hexString);
         assertArrayEquals(bytes, output);
     }
-    
+
     @Test
     void shouldDecodeHexToByteWithInvalidHexCharacter() {
         assertThrows(IllegalArgumentException.class, () -> {
@@ -118,12 +116,28 @@ class ByteArrayConverterUnitTest {
         assertArrayEquals(bytes, output);
     }
 
+    @Test
+    void shouldEncodeByteArrayToHexStringUsingHexFormat() throws DecoderException {
+        byte[] bytes = getSampleBytes();
+        String hexString = getSampleHexString();
+        String output = hexStringConverter.encodeUsingHexFormat(bytes);
+        assertThat(output, IsEqualIgnoringCase.equalToIgnoringCase(hexString));
+    }
+
+    @Test
+    void shouldDecodeHexStringToByteArrayUsingHexFormat() throws DecoderException {
+        byte[] bytes = getSampleBytes();
+        String hexString = getSampleHexString();
+        byte[] output = hexStringConverter.decodeUsingHexFormat(hexString);
+        assertArrayEquals(bytes, output);
+    }
+
     private String getSampleHexString() {
         return "0af50c0e2d10";
     }
 
     private byte[] getSampleBytes() {
-        return new byte[] { 10, -11, 12, 14, 45, 16 };
+        return new byte[]{10, -11, 12, 14, 45, 16};
     }
 
 }

algorithms-modules/algorithms-miscellaneous-7/README.md

@@ -8,4 +8,10 @@
 - [Find Missing Number From a Given Array in Java](https://www.baeldung.com/java-array-find-missing-number)
 - [Calculate Weighted Mean in Java](https://www.baeldung.com/java-compute-weighted-average)
 - [Check if Two Strings Are Rotations of Each Other](https://www.baeldung.com/java-string-check-strings-rotations)
+- [Find the Largest Prime Under the Given Number in Java](https://www.baeldung.com/java-largest-prime-lower-threshold)
+- [Count the Number of Unique Digits in an Integer using Java](https://www.baeldung.com/java-int-count-unique-digits)
+- [Generate Juggler Sequence in Java](https://www.baeldung.com/java-generate-juggler-sequence)
+- [Finding the Parent of a Node in a Binary Search Tree with Java](https://www.baeldung.com/java-find-parent-node-binary-search-tree)
+- [Check if a Number Is a Happy Number in Java](https://www.baeldung.com/java-happy-sad-number-test)
+- [Find the Largest Number Possible After Removing k Digits of a Number](https://www.baeldung.com/java-find-largest-number-remove-k-digits)
 - More articles: [[<-- prev]](/algorithms-miscellaneous-6)

algorithms-modules/algorithms-miscellaneous-7/pom.xml

@@ -13,4 +13,22 @@
         <version>1.0.0-SNAPSHOT</version>
     </parent>
 
+    <properties>
+        <jmh.version>1.35</jmh.version>
+    </properties>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.openjdk.jmh</groupId>
+            <artifactId>jmh-core</artifactId>
+            <version>${jmh.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.openjdk.jmh</groupId>
+            <artifactId>jmh-generator-annprocess</artifactId>
+            <version>${jmh.version}</version>
+        </dependency>
+    </dependencies>
+
 </project>

algorithms-modules/algorithms-miscellaneous-7/src/main/java/com/baeldung/algorithms/largestNumberRemovingK/LargestNumberRemoveKDigits.java

@@ -0,0 +1,57 @@
+package com.baeldung.algorithms.largestNumberRemovingK;
+
+import java.util.*;
+
+public class LargestNumberRemoveKDigits {
+    public static int findLargestNumberUsingArithmetic(int num, int k) {
+        for (int j = 0; j < k; j++) {
+
+            int result = 0;
+            int i = 1;
+
+            while (num / i > 0) {
+                int temp = (num / (i * 10))
+                        * i
+                        + (num % i);
+                i *= 10;
+
+                result = Math.max(result, temp);
+            }
+            num = result;
+        }
+
+        return num;
+    }
+
+    public static int findLargestNumberUsingStack(int num, int k) {
+        String numStr = Integer.toString(num);
+        int length = numStr.length();
+
+        if (k == length) return 0;
+
+        Stack<Character> stack = new Stack<>();
+
+        for (int i = 0; i < length; i++) {
+            char digit = numStr.charAt(i);
+
+            while (k > 0 && !stack.isEmpty() && stack.peek() < digit) {
+                stack.pop();
+                k--;
+            }
+
+            stack.push(digit);
+        }
+
+        while (k > 0) {
+            stack.pop();
+            k--;
+        }
+
+        StringBuilder result = new StringBuilder();
+        while (!stack.isEmpty()) {
+            result.insert(0, stack.pop());
+        }
+
+        return Integer.parseInt(result.toString());
+    }
+}

algorithms-modules/algorithms-miscellaneous-7/src/main/java/com/baeldung/algorithms/perfectnumber/PerfectNumber.java

@@ -0,0 +1,50 @@
+package com.baeldung.algorithms.perfectnumber;
+
+import java.util.stream.IntStream;
+
+class PerfectNumber {
+
+    public static boolean isPerfectBruteForce(int number) {
+        int sum = 0;
+        for (int i = 1; i <= number / 2; i++) {
+            if (number % i == 0) {
+                sum += i;
+            }
+        }
+        return sum == number;
+    }
+
+    public static boolean isPerfectStream(int number) {
+        int sum = IntStream.rangeClosed(2, (int) Math.sqrt(number))
+                .filter(test -> number % test == 0)
+                .reduce(1, (s, test) -> s + test + (number / test));
+        return sum == number;
+    }
+
+    public static boolean isPerfectEuclidEuler(int number) {
+        int p = 2;
+        int perfectNumber = (int) (Math.pow(2, p - 1) * (Math.pow(2, p) - 1));
+        while (perfectNumber <= number) {
+            if (perfectNumber == number) {
+                return true;
+            }
+            p++;
+            perfectNumber = (int) (Math.pow(2, p - 1) * (Math.pow(2, p) - 1));
+        }
+        return false;
+    }
+
+    public static boolean isPerfectEuclidEulerUsingShift(int number) {
+        int p = 2;
+        int perfectNumber = (2 << (p - 1)) * ((2 << p) - 1);
+        while (perfectNumber <= number) {
+            if (perfectNumber == number) {
+                return true;
+            }
+            p++;
+            perfectNumber = (2 << (p - 1)) * ((2 << p) - 1);
+        }
+        return false;
+    }
+
+}

algorithms-modules/algorithms-miscellaneous-7/src/main/java/com/baeldung/algorithms/perfectnumber/PerfectNumberBenchmark.java

@@ -0,0 +1,41 @@
+package com.baeldung.algorithms.perfectnumber;
+
+import org.openjdk.jmh.annotations.Benchmark;
+import org.openjdk.jmh.annotations.Scope;
+import org.openjdk.jmh.annotations.State;
+import org.openjdk.jmh.runner.Runner;
+import org.openjdk.jmh.runner.options.Options;
+import org.openjdk.jmh.runner.options.OptionsBuilder;
+
+@State(Scope.Benchmark)
+public class PerfectNumberBenchmark {
+
+    @Benchmark
+    public boolean bruteForceBenchmark() {
+        return PerfectNumber.isPerfectBruteForce(33550336);
+    }
+
+    @Benchmark
+    public boolean streamBenchmark() {
+        return PerfectNumber.isPerfectStream(33550336);
+    }
+
+    @Benchmark
+    public boolean euclidEulerBenchmark() {
+        return PerfectNumber.isPerfectEuclidEuler(33550336);
+    }
+
+    @Benchmark
+    public boolean euclidEulerUsingShiftBenchmark() {
+        return PerfectNumber.isPerfectEuclidEulerUsingShift(33550336);
+    }
+
+    public static void main(String[] args) throws Exception {
+        Options options = new OptionsBuilder()
+                .include(PerfectNumberBenchmark.class.getSimpleName())
+                .forks(1)
+                .build();
+
+        new Runner(options).run();
+    }
+}

algorithms-modules/algorithms-miscellaneous-7/src/test/java/com/baeldung/algorithms/happynumber/HappyNumberUnitTest.java

@@ -0,0 +1,82 @@
+package com.baeldung.algorithms.happynumber;
+
+import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+
+import java.util.HashSet;
+import java.util.Set;
+
+import org.junit.jupiter.api.Test;
+
+class HappyNumberDecider {
+
+    public static boolean isHappyNumber(int n) {
+        Set<Integer> checkedNumbers = new HashSet<>();
+        while (true) {
+            n = sumDigitsSquare(n);
+            if (n == 1) {
+                return true;
+            }
+            if (checkedNumbers.contains(n)) {
+                return false;
+            }
+            checkedNumbers.add(n);
+        }
+    }
+
+    public static boolean isHappyNumberFloyd(int n) {
+        int slow = n;
+        int fast = n;
+        do {
+            slow = sumDigitsSquare(slow);
+            fast = sumDigitsSquare(sumDigitsSquare(fast));
+        } while (slow != fast);
+
+        return slow == 1;
+    }
+
+    private static int sumDigitsSquare(int n) {
+        int squareSum = 0;
+        while (n != 0) {
+            squareSum += (n % 10) * (n % 10);
+            n /= 10;
+        }
+        return squareSum;
+    }
+}
+
+public class HappyNumberUnitTest {
+
+    @Test
+    void whenUsingIsHappyNumber_thenGetTheExpectedResult() {
+        assertTrue(HappyNumberDecider.isHappyNumber(7));
+        assertTrue(HappyNumberDecider.isHappyNumber(10));
+        assertTrue(HappyNumberDecider.isHappyNumber(13));
+        assertTrue(HappyNumberDecider.isHappyNumber(19));
+        assertTrue(HappyNumberDecider.isHappyNumber(23));
+
+        assertFalse(HappyNumberDecider.isHappyNumber(4));
+        assertFalse(HappyNumberDecider.isHappyNumber(6));
+        assertFalse(HappyNumberDecider.isHappyNumber(11));
+        assertFalse(HappyNumberDecider.isHappyNumber(15));
+        assertFalse(HappyNumberDecider.isHappyNumber(20));
+
+    }
+
+    @Test
+    void whenUsingIsHappyNumber2_thenGetTheExpectedResult() {
+        assertTrue(HappyNumberDecider.isHappyNumberFloyd(7));
+        assertTrue(HappyNumberDecider.isHappyNumberFloyd(10));
+        assertTrue(HappyNumberDecider.isHappyNumberFloyd(13));
+        assertTrue(HappyNumberDecider.isHappyNumberFloyd(19));
+        assertTrue(HappyNumberDecider.isHappyNumberFloyd(23));
+
+        assertFalse(HappyNumberDecider.isHappyNumberFloyd(4));
+        assertFalse(HappyNumberDecider.isHappyNumberFloyd(6));
+        assertFalse(HappyNumberDecider.isHappyNumberFloyd(11));
+        assertFalse(HappyNumberDecider.isHappyNumberFloyd(15));
+        assertFalse(HappyNumberDecider.isHappyNumberFloyd(20));
+
+    }
+
+}

algorithms-modules/algorithms-miscellaneous-7/src/test/java/com/baeldung/algorithms/largestNumberRemovingK/LargestNumberRemoveKDigitsUnitTest.java

@@ -0,0 +1,25 @@
+package com.baeldung.algorithms.largestNumberRemovingK;
+
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Test;
+
+public class LargestNumberRemoveKDigitsUnitTest {
+
+    @Test
+    public void givenNumber_UsingArithmeticRemoveKDigits_thenReturnLargestNumber(){
+        Assertions.assertEquals(LargestNumberRemoveKDigits.findLargestNumberUsingArithmetic(9461, 1), 961);
+        Assertions.assertEquals(LargestNumberRemoveKDigits.findLargestNumberUsingArithmetic(463, 2), 6);
+        Assertions.assertEquals(LargestNumberRemoveKDigits.findLargestNumberUsingArithmetic(98625410, 6), 98);
+        Assertions.assertEquals(LargestNumberRemoveKDigits.findLargestNumberUsingArithmetic(20, 2), 0);
+        Assertions.assertEquals(LargestNumberRemoveKDigits.findLargestNumberUsingArithmetic(98989, 4), 9);
+    }
+
+    @Test
+    public void givenNumber_UsingStackRemoveKDigits_thenReturnLargestNumber(){
+        Assertions.assertEquals(LargestNumberRemoveKDigits.findLargestNumberUsingStack(9461, 1), 961);
+        Assertions.assertEquals(LargestNumberRemoveKDigits.findLargestNumberUsingStack(463, 2), 6);
+        Assertions.assertEquals(LargestNumberRemoveKDigits.findLargestNumberUsingStack(98625410, 6), 98);
+        Assertions.assertEquals(LargestNumberRemoveKDigits.findLargestNumberUsingStack(20, 2), 0);
+        Assertions.assertEquals(LargestNumberRemoveKDigits.findLargestNumberUsingStack(98989, 4), 9);
+    }
+}

algorithms-modules/algorithms-miscellaneous-7/src/test/java/com/baeldung/algorithms/perfectnumber/PerfectNumberUnitTest.java

@@ -0,0 +1,68 @@
+package com.baeldung.algorithms.perfectnumber;
+
+import org.junit.jupiter.api.Test;
+
+import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+
+class PerfectNumberUnitTest {
+    @Test
+    void givenPerfectNumber_whenCheckingIsPerfectBruteForce_thenReturnTrue() {
+        assertTrue(PerfectNumber.isPerfectBruteForce(6));
+    }
+
+    @Test
+    void givenNonPerfectNumber_whenCheckingIsPerfectBruteForce_thenReturnFalse() {
+        assertFalse(PerfectNumber.isPerfectBruteForce(10));
+    }
+
+    @Test
+    void givenNegativeNumber_whenCheckingIsPerfectBruteForce_thenReturnFalse() {
+        assertFalse(PerfectNumber.isPerfectBruteForce(-28));
+    }
+
+    @Test
+    void givenPerfectNumber_whenCheckingIsPerfectStream_thenReturnTrue() {
+        assertTrue(PerfectNumber.isPerfectStream(28));
+    }
+
+    @Test
+    void givenNonPerfectNumber_whenCheckingIsPerfectStream_thenReturnFalse() {
+        assertFalse(PerfectNumber.isPerfectStream(10));
+    }
+
+    @Test
+    void givenNegativeNumber_whenCheckingIsPerfectStream_thenReturnFalse() {
+        assertFalse(PerfectNumber.isPerfectStream(-6));
+    }
+
+    @Test
+    void givenPerfectNumber_whenCheckingIsPerfectEuclidEuler_thenReturnTrue() {
+        assertTrue(PerfectNumber.isPerfectEuclidEuler(28));
+    }
+
+    @Test
+    void givenNonPerfectNumber_whenCheckingIsPerfectEuclidEuler_thenReturnFalse() {
+        assertFalse(PerfectNumber.isPerfectEuclidEuler(10));
+    }
+
+    @Test
+    void givenNegativeNumber_whenCheckingIsPerfectEuclidEuler_thenReturnFalse() {
+        assertFalse(PerfectNumber.isPerfectEuclidEuler(-6));
+    }
+
+    @Test
+    void givenPerfectNumber_whenCheckingIsPerfectEuclidEulerUsingShift_thenReturnTrue() {
+        assertTrue(PerfectNumber.isPerfectEuclidEulerUsingShift(28));
+    }
+
+    @Test
+    void givenNonPerfectNumber_whenCheckingIsPerfectEuclidEulerUsingShift_thenReturnFalse() {
+        assertFalse(PerfectNumber.isPerfectEuclidEulerUsingShift(10));
+    }
+
+    @Test
+    void givenNegativeNumber_whenCheckingIsPerfectEuclidEulerUsingShift_thenReturnFalse() {
+        assertFalse(PerfectNumber.isPerfectEuclidEulerUsingShift(-6));
+    }
+}

algorithms-modules/algorithms-miscellaneous-8/README.md

@@ -0,0 +1,3 @@
+### Relevant Articles: 
+- [Vigenère Cipher in Java](https://www.baeldung.com/java-vigenere-cipher)
+- [Merge Overlapping Intervals in a Java Collection](https://www.baeldung.com/java-collection-merge-overlapping-intervals)

algorithms-modules/algorithms-miscellaneous-8/pom.xml

@@ -3,19 +3,14 @@
     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>docker-caching</artifactId>
-    <name>docker-caching</name>
-    <packaging>pom</packaging>
+    <artifactId>algorithms-miscellaneous-8</artifactId>
+    <version>0.0.1-SNAPSHOT</version>
+    <name>algorithms-miscellaneous-8</name>
 
     <parent>
-        <artifactId>docker-modules</artifactId>
         <groupId>com.baeldung</groupId>
+        <artifactId>algorithms-modules</artifactId>
         <version>1.0.0-SNAPSHOT</version>
     </parent>
 
-    <modules>
-        <module>single-module-caching</module>
-        <module>multi-module-caching</module>
-    </modules>
-
-</project>
+</project>

algorithms-modules/algorithms-miscellaneous-8/src/main/java/com/baeldung/algorithms/mergeintervals/Interval.java

@@ -0,0 +1,37 @@
+package com.baeldung.algorithms.mergeintervals;
+
+import java.util.Objects;
+
+public class Interval {
+    int start;
+    int end;
+
+    Interval(int start, int end) {
+        this.start = start;
+        this.end = end;
+    }
+
+    public void setEnd(int end) {
+        this.end = end;
+    }
+
+    @Override
+    public String toString() {
+        return "Interval{" + "start=" + start + ", end=" + end + '}';
+    }
+
+    @Override
+    public boolean equals(Object o) {
+        if (this == o)
+            return true;
+        if (o == null || getClass() != o.getClass())
+            return false;
+        Interval interval = (Interval) o;
+        return start == interval.start && end == interval.end;
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(start, end);
+    }
+}

algorithms-modules/algorithms-miscellaneous-8/src/main/java/com/baeldung/algorithms/mergeintervals/MergeOverlappingIntervals.java

@@ -0,0 +1,29 @@
+package com.baeldung.algorithms.mergeintervals;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public class MergeOverlappingIntervals {
+
+    public List<Interval> doMerge(List<Interval> intervals) {
+        // Sort the intervals based on start time
+        intervals.sort((one, two) -> one.start - two.start);
+
+        // Create somewhere to put the merged list, start it off with the earliest starting interval
+        ArrayList<Interval> merged = new ArrayList<>();
+        merged.add(intervals.get(0));
+
+        // Loop over each interval and merge if start time is before the end time of the
+        // previous interval
+        intervals.forEach(interval -> {
+            if (merged.get(merged.size() - 1).end > interval.start) {
+                merged.get(merged.size() - 1).setEnd(interval.end);
+            } else {
+                merged.add(interval);
+            }
+        });
+
+        return merged;
+    }
+
+}

algorithms-modules/algorithms-miscellaneous-8/src/main/java/com/baeldung/algorithms/skiplist/Node.java

@@ -0,0 +1,11 @@
+package com.baeldung.algorithms.skiplist;
+
+class Node {
+    int value;
+    Node[] forward; // array to hold references to different levels
+
+    public Node(int value, int level) {
+        this.value = value;
+        this.forward = new Node[level + 1]; // level + 1 because level is 0-based
+    }
+}

algorithms-modules/algorithms-miscellaneous-8/src/main/java/com/baeldung/algorithms/skiplist/SkipList.java

@@ -0,0 +1,92 @@
+package com.baeldung.algorithms.skiplist;
+
+
+import java.util.Random;
+
+public class SkipList {
+    private Node head;
+    private int maxLevel;
+    private int level;
+    private Random random;
+
+    public SkipList() {
+        maxLevel = 16; // maximum number of levels
+        level = 0; // current level of SkipList
+        head = new Node(Integer.MIN_VALUE, maxLevel);
+        random = new Random();
+    }
+
+    public void insert(int value) {
+        Node[] update = new Node[maxLevel + 1];
+        Node current = this.head;
+
+        for (int i = level; i >= 0; i--) {
+            while (current.forward[i] != null && current.forward[i].value < value) {
+                current = current.forward[i];
+            }
+            update[i] = current;
+        }
+
+        current = current.forward[0];
+
+        if (current == null || current.value != value) {
+            int lvl = randomLevel();
+
+            if (lvl > level) {
+                for (int i = level + 1; i <= lvl; i++) {
+                    update[i] = head;
+                }
+                level = lvl;
+            }
+
+            Node newNode = new Node(value, lvl);
+            for (int i = 0; i <= lvl; i++) {
+                newNode.forward[i] = update[i].forward[i];
+                update[i].forward[i] = newNode;
+            }
+        }
+    }
+
+    public boolean search(int value) {
+        Node current = this.head;
+        for (int i = level; i >= 0; i--) {
+            while (current.forward[i] != null && current.forward[i].value < value) {
+                current = current.forward[i];
+            }
+        }
+        current = current.forward[0];
+        return current != null && current.value == value;
+    }
+
+    public void delete(int value) {
+        Node[] update = new Node[maxLevel + 1];
+        Node current = this.head;
+
+        for (int i = level; i >= 0; i--) {
+            while (current.forward[i] != null && current.forward[i].value < value) {
+                current = current.forward[i];
+            }
+            update[i] = current;
+        }
+        current = current.forward[0];
+
+        if (current != null && current.value == value) {
+            for (int i = 0; i <= level; i++) {
+                if (update[i].forward[i] != current) break;
+                update[i].forward[i] = current.forward[i];
+            }
+
+            while (level > 0 && head.forward[level] == null) {
+                level--;
+            }
+        }
+    }
+
+    private int randomLevel() {
+        int lvl = 0;
+        while (lvl < maxLevel && random.nextDouble() < 0.5) {
+            lvl++;
+        }
+        return lvl;
+    }
+}

algorithms-modules/algorithms-miscellaneous-8/src/test/java/com/baeldung/algorithms/mergeintervals/MergeIntervalsUnitTest.java

@@ -0,0 +1,30 @@
+package com.baeldung.algorithms.mergeintervals;
+
+import static org.junit.jupiter.api.Assertions.assertArrayEquals;
+
+import java.util.ArrayList;
+import java.util.Arrays;
+
+import org.junit.jupiter.api.Test;
+
+class MergeIntervalsUnitTest {
+
+    private ArrayList<Interval> intervals = new ArrayList<>(Arrays.asList(
+      new Interval(2, 5),
+      new Interval(13, 20),
+      new Interval(11, 15),
+      new Interval(1, 3)
+    ));
+    private ArrayList<Interval> intervalsMerged = new ArrayList<>(Arrays.asList(
+      new Interval(1, 5),
+      new Interval(11, 20)
+    ));
+
+    @Test
+    void givenIntervals_whenMerging_thenReturnMergedIntervals() {
+        MergeOverlappingIntervals merger = new MergeOverlappingIntervals();
+        ArrayList<Interval> result = (ArrayList<Interval>) merger.doMerge(intervals);
+        assertArrayEquals(intervalsMerged.toArray(), result.toArray());
+    }
+
+}

algorithms-modules/algorithms-miscellaneous-8/src/test/java/com/baeldung/algorithms/skiplist/SkipListUnitTest.java

@@ -0,0 +1,34 @@
+package com.baeldung.algorithms.skiplist;
+
+import org.junit.jupiter.api.Test;
+
+import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+
+public class SkipListUnitTest {
+
+    @Test
+    public void givenSkipList_WhenInsert_ThenSearchFound() {
+        SkipList skipList = new SkipList();
+
+        skipList.insert(3);
+        assertTrue(skipList.search(3), "Should find 3");
+
+        assertFalse(skipList.search(99), "Should not find 99");
+    }
+
+    @Test
+    public void givenSkipList_WhenDeleteElement_ThenRemoveFromList() {
+        SkipList skipList = new SkipList();
+
+        skipList.insert(3);
+        skipList.insert(7);
+
+        skipList.delete(3);
+        assertFalse(skipList.search(3), "3 should have been deleted");
+
+        skipList.delete(99);
+        assertTrue(skipList.search(7), "7 should still exist");
+    }
+
+}

algorithms-modules/algorithms-miscellaneous-8/src/test/java/com/baeldung/algorithms/vigenere/VigenereCipher.java

@@ -0,0 +1,69 @@
+package com.baeldung.algorithms.vigenere;
+
+public class VigenereCipher {
+    private final String characters;
+
+    public VigenereCipher() {
+        this("ABCDEFGHIJKLMNOPQRSTUVWXYZ");
+    }
+
+    public VigenereCipher(String characters) {
+        this.characters = characters;
+    }
+
+    public String encode(String input, String key) {
+        String result = "";
+
+        int keyPosition = 0;
+        for (char c : input.toCharArray()) {
+            char k = key.charAt(keyPosition % key.length());
+
+            int charIndex = characters.indexOf(c);
+            int keyIndex = characters.indexOf(k);
+
+            if (charIndex >= 0) {
+                if (keyIndex >= 0) {
+                    int newCharIndex = (charIndex + keyIndex + 1) % characters.length();
+                    c = characters.charAt(newCharIndex);
+
+                }
+
+                keyPosition++;
+            }
+
+            result += c;
+        }
+
+        return result;
+    }
+
+    public String decode(String input, String key) {
+        String result = "";
+
+        int keyPosition = 0;
+        for (char c : input.toCharArray()) {
+            char k = key.charAt(keyPosition % key.length());
+
+            int charIndex = characters.indexOf(c);
+            int keyIndex = characters.indexOf(k);
+
+            if (charIndex >= 0) {
+                if (keyIndex >= 0) {
+                    int newCharIndex = charIndex - keyIndex - 1;
+                    if (newCharIndex < 0) {
+                        newCharIndex = characters.length() + newCharIndex;
+                    }
+                    c = characters.charAt(newCharIndex);
+
+                }
+
+                keyPosition++;
+            }
+
+            result += c;
+        }
+
+        return result;
+    }
+
+}

algorithms-modules/algorithms-miscellaneous-8/src/test/java/com/baeldung/algorithms/vigenere/VigenereCipherUnitTest.java

@@ -0,0 +1,76 @@
+package com.baeldung.algorithms.vigenere;
+
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Test;
+
+public class VigenereCipherUnitTest {
+
+    @Test
+    void encodeBaeldung() {
+        VigenereCipher cipher = new VigenereCipher();
+        String output = cipher.encode("BAELDUNG", "HELLO");
+
+        Assertions.assertEquals("JFQXSCSS", output);
+    }
+
+    @Test
+    void encodeBaeldungMixedCharacters() {
+        VigenereCipher cipher = new VigenereCipher("JQFVHPWORZSLNMKYCGBUXIEDTA");
+        String output = cipher.encode("BAELDUNG", "HELLO");
+
+        Assertions.assertEquals("DERDPTZV", output);
+    }
+
+    @Test
+    void encodeArticleTitle() {
+        VigenereCipher cipher = new VigenereCipher();
+        String output = cipher.encode("VIGENERE CIPHER IN JAVA", "BAELDUNG");
+
+        Assertions.assertEquals("XJLQRZFL EJUTIM WU LBAM", output);
+    }
+
+    @Test
+    void encodeArticleTitleMoreCharacters() {
+        VigenereCipher cipher = new VigenereCipher("ABCDEFGHIJKLMNOPQRSTUVWXYZ ");
+        String output = cipher.encode("VIGENERE CIPHER IN JAVA", "BAELDUNG");
+
+        Assertions.assertEquals("XJLQRZELBDNALZEGKOEVEPO", output);
+    }
+
+    @Test
+    void decodeBaeldung() {
+        VigenereCipher cipher = new VigenereCipher();
+        String output = cipher.decode("JFQXSCSS", "HELLO");
+
+        Assertions.assertEquals("BAELDUNG", output);
+    }
+
+    @Test
+    void decodeBaeldungMixedCharacters() {
+        VigenereCipher cipher = new VigenereCipher("JQFVHPWORZSLNMKYCGBUXIEDTA");
+        String output = cipher.decode("DERDPTZV", "HELLO");
+
+        Assertions.assertEquals("BAELDUNG", output);
+    }
+
+    @Test
+    void decodeArticleTitleMoreCharacters() {
+        VigenereCipher cipher = new VigenereCipher("ABCDEFGHIJKLMNOPQRSTUVWXYZ ");
+        String output = cipher.decode("XJLQRZELBDNALZEGKOEVEPO", "BAELDUNG");
+
+        Assertions.assertEquals("VIGENERE CIPHER IN JAVA", output);
+    }
+
+    @Test
+    void encodeDecodeBaeldung() {
+        VigenereCipher cipher = new VigenereCipher();
+
+        String input = "BAELDUNG";
+        String key = "HELLO";
+
+        String encoded = cipher.encode(input, key);
+        String decoded = cipher.decode(encoded, key);
+
+        Assertions.assertEquals(input, decoded);
+    }
+}

algorithms-modules/pom.xml

@@ -22,6 +22,7 @@
         <module>algorithms-miscellaneous-5</module>
         <module>algorithms-miscellaneous-6</module>
         <module>algorithms-miscellaneous-7</module>
+        <module>algorithms-miscellaneous-8</module>
         <module>algorithms-searching</module>
         <module>algorithms-sorting</module>
         <module>algorithms-sorting-2</module>
@@ -34,4 +35,4 @@
         <tradukisto.version>1.0.1</tradukisto.version>
     </properties>
 
-</project>
+</project>

apache-cxf-modules/cxf-spring/pom.xml

@@ -4,8 +4,8 @@
     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
     <modelVersion>4.0.0</modelVersion>
     <artifactId>cxf-spring</artifactId>
-    <name>cxf-spring</name>
     <packaging>war</packaging>
+    <name>cxf-spring</name>
 
     <parent>
         <groupId>com.baeldung</groupId>

apache-cxf-modules/pom.xml

@@ -5,8 +5,9 @@
     <modelVersion>4.0.0</modelVersion>
     <artifactId>apache-cxf-modules</artifactId>
     <version>0.0.1-SNAPSHOT</version>
-    <name>apache-cxf-modules</name>
     <packaging>pom</packaging>
+    <name>apache-cxf-modules</name>
+
 
     <parent>
         <groupId>com.baeldung</groupId>

apache-cxf-modules/sse-jaxrs/pom.xml

@@ -4,8 +4,8 @@
     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>sse-jaxrs</artifactId>
-    <name>sse-jaxrs</name>
     <packaging>pom</packaging>
+    <name>sse-jaxrs</name>
 
     <parent>
         <groupId>com.baeldung</groupId>

apache-cxf-modules/sse-jaxrs/sse-jaxrs-server/pom.xml

@@ -4,8 +4,8 @@
     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>sse-jaxrs-server</artifactId>
-    <name>sse-jaxrs-server</name>
     <packaging>war</packaging>
+    <name>sse-jaxrs-server</name>
 
     <parent>
         <groupId>com.baeldung</groupId>

apache-httpclient4/pom.xml

@@ -5,8 +5,8 @@
     <modelVersion>4.0.0</modelVersion>
     <artifactId>apache-httpclient4</artifactId>
     <version>0.1-SNAPSHOT</version>
-    <name>apache-httpclient4</name>
     <packaging>war</packaging>
+    <name>apache-httpclient4</name>
 
     <parent>
         <groupId>com.baeldung</groupId>
@@ -82,7 +82,7 @@
         <dependency>
             <groupId>org.springframework</groupId>
             <artifactId>spring-oxm</artifactId>
-            <version>${spring.version}</version>
+            <version>${spring-oxm.version}</version>
         </dependency>
         <!-- marshalling -->
         <dependency>
@@ -176,12 +176,6 @@
             <version>${jstl.version}</version>
             <scope>runtime</scope>
         </dependency>
-        <!-- util -->
-        <dependency>
-            <groupId>com.google.guava</groupId>
-            <artifactId>guava</artifactId>
-            <version>${guava.version}</version>
-        </dependency>
         <!-- test scoped -->
         <dependency>
             <groupId>org.springframework</groupId>
@@ -199,7 +193,6 @@
                 <filtering>true</filtering>
             </resource>
         </resources>
-
     </build>
 
     <profiles>
@@ -233,6 +226,7 @@
     </profiles>
 
     <properties>
+        <spring-oxm.version>6.1.4</spring-oxm.version>
         <!-- util -->
         <commons-codec.version>1.16.0</commons-codec.version>
         <httpasyncclient.version>4.1.5</httpasyncclient.version>

apache-kafka-2/README.md

@@ -16,3 +16,4 @@ You can build the project from the command line using: *mvn clean install*, or i
 - [Introduction to Apache Kafka](https://www.baeldung.com/apache-kafka)
 - [Ensuring Message Ordering in Kafka: Strategies and Configurations](https://www.baeldung.com/kafka-message-ordering)
 - [Read Multiple Messages with Apache Kafka](https://www.baeldung.com/kafka-read-multiple-messages)
+- [Creating a Kafka Listener Using the Consumer API](https://www.baeldung.com/kafka-create-listener-consumer-api)

apache-kafka-3/README.md

@@ -0,0 +1,10 @@
+## Apache Kafka
+
+This module contains articles about Apache Kafka.
+
+##### Building the project
+You can build the project from the command line using: *mvn clean install*, or in an IDE.
+
+### Relevant Articles:
+- [Commit Offsets in Kafka](https://www.baeldung.com/kafka-commit-offsets)
+

apache-kafka-3/pom.xml

@@ -0,0 +1,48 @@
+<?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">
+    <modelVersion>4.0.0</modelVersion>
+    <artifactId>apache-kafka-3</artifactId>
+    <name>apache-kafka-3</name>
+
+    <parent>
+        <groupId>com.baeldung</groupId>
+        <artifactId>parent-modules</artifactId>
+        <version>1.0.0-SNAPSHOT</version>
+    </parent>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.apache.kafka</groupId>
+            <artifactId>kafka-clients</artifactId>
+            <version>${kafka.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-api</artifactId>
+            <version>${org.slf4j.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <version>${lombok.version}</version>
+            <scope>provided</scope>
+        </dependency>
+        <dependency>
+            <groupId>com.fasterxml.jackson.core</groupId>
+            <artifactId>jackson-databind</artifactId>
+            <version>${jackson.databind.version}</version>
+        </dependency>
+    </dependencies>
+
+    <properties>
+        <kafka.version>3.6.1</kafka.version>
+        <jackson.databind.version>2.15.2</jackson.databind.version>
+    </properties>
+    <profiles>
+        <profile>
+            <id>integration-jdk9-and-above</id>
+        </profile>
+    </profiles>
+</project>

apache-kafka-3/src/main/java/com/baeldung/kafka/commitoffset/AsyncCommit.java

@@ -0,0 +1,23 @@
+package com.baeldung.kafka.commitoffset;
+
+import com.baeldung.kafka.commitoffset.config.KafkaConfigProperties;
+
+import java.time.Duration;
+
+import org.apache.kafka.clients.consumer.ConsumerRecord;
+import org.apache.kafka.clients.consumer.ConsumerRecords;
+import org.apache.kafka.clients.consumer.KafkaConsumer;
+
+public class AsyncCommit {
+
+    public static void main(String[] args) {
+
+        KafkaConsumer<Long, String> consumer = new KafkaConsumer<>(KafkaConfigProperties.getProperties());
+        consumer.subscribe(KafkaConfigProperties.getTopic());
+        ConsumerRecords<Long, String> messages = consumer.poll(Duration.ofSeconds(10));
+        for (ConsumerRecord<Long, String> message : messages) {
+            // processed message
+            consumer.commitAsync();
+        }
+    }
+}

apache-kafka-3/src/main/java/com/baeldung/kafka/commitoffset/AutomaticCommit.java

@@ -0,0 +1,26 @@
+package com.baeldung.kafka.commitoffset;
+
+import com.baeldung.kafka.commitoffset.config.KafkaConfigProperties;
+
+import java.time.Duration;
+import java.util.Properties;
+
+import org.apache.kafka.clients.consumer.ConsumerConfig;
+import org.apache.kafka.clients.consumer.ConsumerRecord;
+import org.apache.kafka.clients.consumer.ConsumerRecords;
+import org.apache.kafka.clients.consumer.KafkaConsumer;
+
+public class AutomaticCommit {
+
+    public static void main(String[] args) {
+
+        Properties properties = KafkaConfigProperties.getProperties();
+        properties.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, "true");
+        KafkaConsumer<Long, String> consumer = new KafkaConsumer<>(properties);
+        consumer.subscribe(KafkaConfigProperties.getTopic());
+        ConsumerRecords<Long, String> messages = consumer.poll(Duration.ofSeconds(10));
+        for (ConsumerRecord<Long, String> message : messages) {
+            // processed message
+        }
+    }
+}

apache-kafka-3/src/main/java/com/baeldung/kafka/commitoffset/SpecificOffsetCommit.java

@@ -0,0 +1,34 @@
+package com.baeldung.kafka.commitoffset;
+
+import com.baeldung.kafka.commitoffset.config.KafkaConfigProperties;
+
+import java.time.Duration;
+import java.util.HashMap;
+import java.util.Map;
+
+import org.apache.kafka.clients.consumer.ConsumerRecord;
+import org.apache.kafka.clients.consumer.ConsumerRecords;
+import org.apache.kafka.clients.consumer.KafkaConsumer;
+import org.apache.kafka.clients.consumer.OffsetAndMetadata;
+import org.apache.kafka.common.TopicPartition;
+
+public class SpecificOffsetCommit {
+    public static void main(String[] args) {
+
+        KafkaConsumer<Long, String> consumer = new KafkaConsumer<>(KafkaConfigProperties.getProperties());
+        consumer.subscribe(KafkaConfigProperties.getTopic());
+        Map<TopicPartition, OffsetAndMetadata> currentOffsets = new HashMap<>();
+        int messageProcessed = 0;
+        while (true) {
+            ConsumerRecords<Long, String> messages = consumer.poll(Duration.ofSeconds(10));
+            for (ConsumerRecord<Long, String> message : messages) {
+                // processed message
+                messageProcessed++;
+                currentOffsets.put(new TopicPartition(message.topic(), message.partition()), new OffsetAndMetadata(message.offset() + 1));
+                if (messageProcessed % 50 == 0) {
+                    consumer.commitSync(currentOffsets);
+                }
+            }
+        }
+    }
+}

apache-kafka-3/src/main/java/com/baeldung/kafka/commitoffset/SyncCommit.java

@@ -0,0 +1,23 @@
+package com.baeldung.kafka.commitoffset;
+
+import com.baeldung.kafka.commitoffset.config.KafkaConfigProperties;
+
+import java.time.Duration;
+
+import org.apache.kafka.clients.consumer.ConsumerRecord;
+import org.apache.kafka.clients.consumer.ConsumerRecords;
+import org.apache.kafka.clients.consumer.KafkaConsumer;
+
+public class SyncCommit {
+
+    public static void main(String[] args) {
+
+        KafkaConsumer<Long, String> consumer = new KafkaConsumer<>(KafkaConfigProperties.getProperties());
+        consumer.subscribe(KafkaConfigProperties.getTopic());
+        ConsumerRecords<Long, String> messages = consumer.poll(Duration.ofSeconds(10));
+        for (ConsumerRecord<Long, String> message : messages) {
+            // processed message
+            consumer.commitSync();
+        }
+    }
+}

apache-kafka-3/src/main/java/com/baeldung/kafka/commitoffset/config/KafkaConfigProperties.java

@@ -0,0 +1,31 @@
+package com.baeldung.kafka.commitoffset.config;
+
+import java.util.ArrayList;
+import java.util.Properties;
+
+import org.apache.kafka.clients.consumer.ConsumerConfig;
+import org.apache.kafka.common.serialization.StringDeserializer;
+
+/**
+ * @author amitkumar
+ */
+public class KafkaConfigProperties {
+    public static final String MY_TOPIC = "my-topic";
+
+    public static Properties getProperties() {
+
+        Properties props = new Properties();
+        props.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, "false");
+        props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
+        props.put(ConsumerConfig.GROUP_ID_CONFIG, "MyFirstConsumer");
+        props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
+        props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
+        return props;
+    }
+
+    public static ArrayList<String> getTopic() {
+        ArrayList<String> topics = new ArrayList<>();
+        topics.add(MY_TOPIC);
+        return topics;
+    }
+}

apache-kafka-3/src/test/resources/logback.xml

@@ -0,0 +1,11 @@
+<configuration>
+    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
+        <encoder>
+            <pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
+        </encoder>
+    </appender>
+
+    <root level="INFO">
+        <appender-ref ref="STDOUT" />
+    </root>
+</configuration>

apache-kafka/pom.xml

@@ -71,11 +71,6 @@
             <version>${flink.version}</version>
             <scope>test</scope>
         </dependency>
-        <dependency>
-            <groupId>com.google.guava</groupId>
-            <artifactId>guava</artifactId>
-            <version>${guava.version}</version>
-        </dependency>
         <dependency>
             <groupId>org.awaitility</groupId>
             <artifactId>awaitility</artifactId>

apache-libraries-2/README.md

@@ -1,3 +1,6 @@
 ## Relevant Articles
 - [Understanding XSLT Processing in Java](https://www.baeldung.com/java-extensible-stylesheet-language-transformations)
 - [Add Camel Route at Runtime in Java](https://www.baeldung.com/java-camel-dynamic-route)
+- [Logging in Apache Camel](https://www.baeldung.com/java-apache-camel-logging)
+- More articles: [[<-- prev]](../apache-libraries)
+

apache-libraries-2/data/inbox/welcome.txt

@@ -0,0 +1 @@
+Welcome to Baeldung

apache-libraries-2/data/json/name.json

@@ -0,0 +1,4 @@
+{
+  "name" : "phillip",
+  "age" : 5
+}

apache-libraries-2/data/outbox/welcome.txt

@@ -0,0 +1 @@
+WELCOME TO BAELDUNG

apache-libraries-2/data/output/name.json

@@ -0,0 +1 @@
+{"name":"phillip","age":5,"transformedName":"PHILLIP","transformedAge":15}

apache-libraries-2/pom.xml

@@ -24,24 +24,27 @@
             <artifactId>camel-core</artifactId>
             <version>${camel.version}</version>
         </dependency>
-
         <dependency>
             <groupId>org.apache.camel</groupId>
             <artifactId>camel-test-junit5</artifactId>
             <version>${camel.version}</version>
             <scope>test</scope>
         </dependency>
-
         <dependency>
             <groupId>org.apache.camel</groupId>
             <artifactId>camel-main</artifactId>
             <version>${camel.version}</version>
         </dependency>
+        <dependency>
+            <groupId>org.apache.camel</groupId>
+            <artifactId>camel-jackson</artifactId>
+            <version>${camel.version}</version>
+        </dependency>
     </dependencies>
 
     <properties>
         <javax.validation.validation-api.version>2.0.1.Final</javax.validation.validation-api.version>
-        <camel.version>4.3.0</camel.version>
+        <camel.version>4.4.1</camel.version>
     </properties>
 
 </project>

apache-libraries-2/src/main/java/com/baeldung/apachecamellogging/CamelLoggingMainApp.java

@@ -0,0 +1,13 @@
+package com.baeldung.apachecamellogging;
+
+import org.apache.camel.main.Main;
+
+public class CamelLoggingMainApp {
+
+    public static void main(String[] args) throws Exception {
+        Main main = new Main();
+        main.configure()
+            .addRoutesBuilder(new FileCopierCamelRoute());
+        main.run(args);
+    }
+}

apache-libraries-2/src/main/java/com/baeldung/apachecamellogging/FileCopierCamelRoute.java

@@ -0,0 +1,25 @@
+package com.baeldung.apachecamellogging;
+
+import org.apache.camel.LoggingLevel;
+import org.apache.camel.builder.RouteBuilder;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class FileCopierCamelRoute extends RouteBuilder {
+
+    private static final Logger LOGGER = LoggerFactory.getLogger(FileCopierCamelRoute.class);
+
+    public void configure() {
+        from("file:data/inbox?noop=true").log("We got an incoming file ${file:name} containing: ${body}")
+            .to("log:com.baeldung.apachecamellogging?level=INFO")
+            .process(process -> {
+                LOGGER.info("We are passing the message to a FileProcesor bean to capitalize the message body");
+            })
+            .bean(FileProcessor.class)
+            .to("file:data/outbox")
+            .to("log:com.baeldung.apachecamellogging?showBodyType=false&maxChars=20")
+            .log(LoggingLevel.DEBUG, "Output Process", "The Process ${id}")
+            .log("Successfully transfer file: ${file:name}");
+    }
+}

apache-libraries-2/src/main/java/com/baeldung/apachecamellogging/FileCopierTracerCamelRoute.java

@@ -0,0 +1,22 @@
+package com.baeldung.apachecamellogging;
+
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.model.dataformat.JsonLibrary;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class FileCopierTracerCamelRoute extends RouteBuilder {
+
+    Logger logger = LoggerFactory.getLogger(FileCopierTracerCamelRoute.class);
+
+    public void configure() {
+        getContext().setTracing(true);
+        from("file:data/json?noop=true").to("log:input?level=INFO")
+            .unmarshal()
+            .json(JsonLibrary.Jackson)
+            .bean(FileProcessor.class, "transform")
+            .marshal()
+            .json(JsonLibrary.Jackson)
+            .to("file:data/output");
+    }
+}

apache-libraries-2/src/main/java/com/baeldung/apachecamellogging/FileProcessor.java

@@ -0,0 +1,23 @@
+package com.baeldung.apachecamellogging;
+
+import org.apache.camel.Body;
+
+import java.util.Map;
+
+public class FileProcessor {
+
+    public String process(@Body String fileContent) {
+        String processedContent = fileContent.toUpperCase();
+        return processedContent;
+    }
+
+    public Map<String, Object> transform(Map<String, Object> input) {
+        String name = (String) input.get("name");
+        int age = (int) input.get("age");
+
+        input.put("transformedName", name.toUpperCase());
+        input.put("transformedAge", age + 10);
+
+        return input;
+    }
+}

apache-libraries-2/src/test/java/com/baeldung/dynamicrouter/DynamicRouterRouteUnitTest.java

@@ -1,4 +1,4 @@
-package dynamicrouter;
+package com.baeldung.dynamicrouter;
 
 import com.baeldung.dynamicrouter.DynamicRouterRoute;
 import org.apache.camel.RoutesBuilder;

apache-libraries/README.md

@@ -13,3 +13,5 @@ This module contains articles about various Apache libraries and utilities
 - [Introduction to Apache Curator](https://www.baeldung.com/apache-curator)
 - [A Quick Guide to Apache Geode](https://www.baeldung.com/apache-geode)
 - [Guide To Solr in Java With Apache SolrJ](https://www.baeldung.com/apache-solrj)
+
+- More articles: [[next -->]](../apache-libraries-2)

apache-spark/pom.xml

@@ -5,8 +5,8 @@
     <modelVersion>4.0.0</modelVersion>
     <artifactId>apache-spark</artifactId>
     <version>1.0-SNAPSHOT</version>
-    <name>apache-spark</name>
     <packaging>jar</packaging>
+    <name>apache-spark</name>
 
     <parent>
         <groupId>com.baeldung</groupId>

apache-thrift/pom.xml

@@ -5,8 +5,8 @@
     <modelVersion>4.0.0</modelVersion>
     <artifactId>apache-thrift</artifactId>
     <version>0.0.1-SNAPSHOT</version>
-    <name>apache-thrift</name>
     <packaging>pom</packaging>
+    <name>apache-thrift</name>
 
     <parent>
         <groupId>com.baeldung</groupId>

apache-velocity/pom.xml

@@ -5,8 +5,8 @@
     <modelVersion>4.0.0</modelVersion>
     <artifactId>apache-velocity</artifactId>
     <version>0.1-SNAPSHOT</version>
-    <name>apache-velocity</name>
     <packaging>war</packaging>
+    <name>apache-velocity</name>
 
     <parent>
         <groupId>com.baeldung</groupId>
@@ -28,7 +28,7 @@
         <dependency>
             <groupId>org.apache.httpcomponents</groupId>
             <artifactId>httpclient</artifactId>
-            <version>${org.apache.httpcomponents.version}</version>
+            <version>${httpclient.version}</version>
             <scope>test</scope>
             <exclusions>
                 <exclusion>
@@ -60,7 +60,7 @@
     </build>
 
     <properties>
-        <org.apache.httpcomponents.version>4.5.2</org.apache.httpcomponents.version>
+        <httpclient.version>4.5.2</httpclient.version>
         <velocity-version>1.7</velocity-version>
         <velocity-tools-version>2.0</velocity-tools-version>
     </properties>

aws-modules/aws-dynamodb/pom.xml

@@ -5,8 +5,8 @@
     <modelVersion>4.0.0</modelVersion>
     <artifactId>aws-dynamodb</artifactId>
     <version>0.1.0-SNAPSHOT</version>
-    <name>aws-dynamodb</name>
     <packaging>jar</packaging>
+    <name>aws-dynamodb</name>
 
     <parent>
         <groupId>com.baeldung</groupId>

aws-modules/aws-lambda-modules/lambda-function/pom.xml

@@ -4,8 +4,8 @@
     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>lambda-function</artifactId>
-    <version>0.1.0-SNAPSHOT</version>
     <name>lambda-function</name>
+    <version>0.1.0-SNAPSHOT</version>
     <packaging>jar</packaging>
 
     <parent>

aws-modules/aws-lambda-modules/pom.xml

@@ -4,8 +4,8 @@
     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>aws-lambda-modules</artifactId>
-    <name>aws-lambda-modules</name>
     <packaging>pom</packaging>
+    <name>aws-lambda-modules</name>
 
     <parent>
         <groupId>com.baeldung</groupId>

aws-modules/aws-lambda-modules/shipping-tracker-lambda/ShippingFunction/pom.xml

@@ -3,8 +3,8 @@
     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
     <modelVersion>4.0.0</modelVersion>
     <artifactId>ShippingFunction</artifactId>
-    <version>1.0</version>
     <name>ShippingFunction</name>
+    <version>1.0</version>
     <packaging>jar</packaging>
 
     <parent>

aws-modules/aws-lambda-modules/todo-reminder-lambda/ToDoFunction/pom.xml

@@ -4,8 +4,8 @@
     <modelVersion>4.0.0</modelVersion>
     <groupId>helloworld</groupId>
     <artifactId>ToDoFunction</artifactId>
-    <version>1.0</version>
     <name>ToDoFunction</name>
+    <version>1.0</version>
     <packaging>jar</packaging>
 
     <parent>

aws-modules/aws-miscellaneous/pom.xml

@@ -5,8 +5,8 @@
     <modelVersion>4.0.0</modelVersion>
     <artifactId>aws-miscellaneous</artifactId>
     <version>0.1.0-SNAPSHOT</version>
-    <name>aws-miscellaneous</name>
     <packaging>jar</packaging>
+    <name>aws-miscellaneous</name>
 
     <parent>
         <groupId>com.baeldung</groupId>

aws-modules/aws-reactive/pom.xml

@@ -87,6 +87,7 @@
             <plugin>
                 <groupId>org.springframework.boot</groupId>
                 <artifactId>spring-boot-maven-plugin</artifactId>
+                <version>${spring.version}</version>
             </plugin>
         </plugins>
     </build>

aws-modules/aws-s3/README.md

@@ -12,3 +12,4 @@ This module contains articles about Simple Storage Service (S3) on AWS
 - [Update an Existing Amazon S3 Object Using Java](https://www.baeldung.com/java-update-amazon-s3-object)
 - [How To Rename Files and Folders in Amazon S3](https://www.baeldung.com/java-amazon-s3-rename-files-folders)
 - [Update an Existing Amazon S3 Object Using Java](https://www.baeldung.com/java-update-amazon-s3-object)
+- [How to Mock Amazon S3 for Integration Test](https://www.baeldung.com/java-amazon-simple-storage-service-mock-testing)

aws-modules/aws-s3/pom.xml

@@ -5,8 +5,8 @@
     <modelVersion>4.0.0</modelVersion>
     <artifactId>aws-s3</artifactId>
     <version>0.1.0-SNAPSHOT</version>
-    <name>aws-s3</name>
     <packaging>jar</packaging>
+    <name>aws-s3</name>
 
     <parent>
         <groupId>com.baeldung</groupId>
@@ -26,7 +26,6 @@
             <version>${aws.java.sdk.version}</version>
             <scope>test</scope>
         </dependency>
-
         <dependency>
             <groupId>commons-io</groupId>
             <artifactId>commons-io</artifactId>
@@ -56,7 +55,6 @@
             <version>${com.adobe.testing.version}</version>
             <scope>test</scope>
         </dependency>
-
         <dependency>
             <groupId>org.testcontainers</groupId>
             <artifactId>junit-jupiter</artifactId>

aws-modules/pom.xml

@@ -4,6 +4,7 @@
     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>aws-modules</artifactId>
+    <packaging>pom</packaging>
     <name>aws-modules</name>
 
     <parent>
@@ -12,16 +13,6 @@
         <version>1.0.0-SNAPSHOT</version>
     </parent>
 
-    <dependencies>
-        <dependency>
-            <groupId>com.amazonaws</groupId>
-            <artifactId>aws-java-sdk-dynamodb</artifactId>
-            <version>1.12.523</version>
-            <scope>compile</scope>
-        </dependency>
-    </dependencies>
-    <packaging>pom</packaging>
-
     <modules>
         <module>aws-app-sync</module>
         <module>aws-dynamodb</module>
@@ -31,6 +22,15 @@
         <module>aws-s3</module>
     </modules>
 
+    <dependencies>
+        <dependency>
+            <groupId>com.amazonaws</groupId>
+            <artifactId>aws-java-sdk-dynamodb</artifactId>
+            <version>1.12.523</version>
+            <scope>compile</scope>
+        </dependency>
+    </dependencies>
+
     <properties>
         <aws-java-sdk.version>1.12.331</aws-java-sdk.version>
         <aws-java-sdk-v2.version>2.24.9</aws-java-sdk-v2.version>

azure/pom.xml

@@ -5,8 +5,8 @@
     <modelVersion>4.0.0</modelVersion>
     <artifactId>azure</artifactId>
     <version>0.1</version>
-    <name>azure</name>
     <packaging>war</packaging>
+    <name>azure</name>
     <description>Demo project for Spring Boot on Azure</description>
 
     <parent>

checker-framework/pom.xml

@@ -5,8 +5,8 @@
     <modelVersion>4.0.0</modelVersion>
     <artifactId>checker-framework</artifactId>
     <version>1.0-SNAPSHOT</version>
-    <name>checker-framework</name>
     <packaging>jar</packaging>
+    <name>checker-framework</name>
 
     <parent>
         <groupId>com.baeldung</groupId>

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

@@ -4,8 +4,8 @@
     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-10</artifactId>
-    <name>core-java-10</name>
     <packaging>jar</packaging>
+    <name>core-java-10</name>
 
     <parent>
         <groupId>com.baeldung.core-java-modules</groupId>

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

@@ -4,8 +4,8 @@
     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-11-2</artifactId>
-    <name>core-java-11-2</name>
     <packaging>jar</packaging>
+    <name>core-java-11-2</name>
 
     <parent>
         <groupId>com.baeldung</groupId>
@@ -15,11 +15,6 @@
     </parent>
 
     <dependencies>
-        <dependency>
-            <groupId>com.google.guava</groupId>
-            <artifactId>guava</artifactId>
-            <version>${guava.version}</version>
-        </dependency>
         <dependency>
             <groupId>org.mock-server</groupId>
             <artifactId>mockserver-junit-jupiter</artifactId>

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

@@ -4,8 +4,8 @@
     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-11-3</artifactId>
-    <name>core-java-11-3</name>
     <packaging>jar</packaging>
+    <name>core-java-11-3</name>
 
     <parent>
         <groupId>com.baeldung</groupId>

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

@@ -4,8 +4,8 @@
     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-11</artifactId>
-    <name>core-java-11</name>
     <packaging>jar</packaging>
+    <name>core-java-11</name>
 
     <parent>
         <groupId>com.baeldung</groupId>
@@ -15,11 +15,6 @@
     </parent>
 
     <dependencies>
-        <dependency>
-            <groupId>com.google.guava</groupId>
-            <artifactId>guava</artifactId>
-            <version>${guava.version}</version>
-        </dependency>
         <dependency>
             <groupId>org.openjdk.jmh</groupId>
             <artifactId>jmh-core</artifactId>

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

@@ -4,8 +4,8 @@
     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-12</artifactId>
-    <name>core-java-12</name>
     <packaging>jar</packaging>
+    <name>core-java-12</name>
 
     <parent>
         <groupId>com.baeldung.core-java-modules</groupId>

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

@@ -4,8 +4,8 @@
     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-13</artifactId>
-    <name>core-java-13</name>
     <packaging>jar</packaging>
+    <name>core-java-13</name>
 
     <parent>
         <groupId>com.baeldung.core-java-modules</groupId>

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

@@ -4,8 +4,8 @@
     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-14</artifactId>
-    <name>core-java-14</name>
     <packaging>jar</packaging>
+    <name>core-java-14</name>
 
     <parent>
         <groupId>com.baeldung</groupId>

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

@@ -4,8 +4,8 @@
     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-15</artifactId>
-    <name>core-java-15</name>
     <packaging>jar</packaging>
+    <name>core-java-15</name>
 
     <parent>
         <groupId>com.baeldung.core-java-modules</groupId>
@@ -13,7 +13,6 @@
         <version>0.0.1-SNAPSHOT</version>
     </parent>
 
-
     <dependencies>
         <dependency>
             <groupId>org.apache.commons</groupId>

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

@@ -4,8 +4,8 @@
     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-16</artifactId>
-    <name>core-java-16</name>
     <packaging>jar</packaging>
+    <name>core-java-16</name>
 
     <parent>
         <groupId>com.baeldung</groupId>

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

@@ -4,8 +4,8 @@
     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-17</artifactId>
-    <name>core-java-17</name>
     <packaging>jar</packaging>
+    <name>core-java-17</name>
 
     <parent>
         <groupId>com.baeldung</groupId>

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

@@ -4,8 +4,8 @@
     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-18</artifactId>
-    <name>core-java-18</name>
     <packaging>jar</packaging>
+    <name>core-java-18</name>
 
     <parent>
         <groupId>com.baeldung</groupId>

core-java-modules/core-java-18/src/main/java/com/baeldung/inetspi/InetAddressSPI.java

@@ -0,0 +1,44 @@
+package com.baeldung.inetspi;
+
+import java.net.InetAddress;
+import java.net.UnknownHostException;
+import java.util.Arrays;
+import java.util.stream.Stream;
+
+import com.baeldung.inetspi.providers.CustomAddressResolverImpl;
+
+public class InetAddressSPI {
+    public String usingGetByName(String host) throws UnknownHostException {
+        InetAddress inetAddress =  InetAddress.getByName(host);
+        return inetAddress.getHostAddress();
+    }
+
+    public String[] usingGetAllByName(String host) throws UnknownHostException {
+        InetAddress[] inetAddresses =  InetAddress.getAllByName(host);
+        return Arrays.stream(inetAddresses).map(InetAddress::getHostAddress).toArray(String[]::new);
+    }
+
+    public String usingGetByIp(byte[] ip) throws UnknownHostException {
+        InetAddress inetAddress =  InetAddress.getByAddress(ip);
+
+        return inetAddress.getHostName();
+    }
+
+    public String usingGetByIpAndReturnsCannonName(byte[] ip) throws UnknownHostException {
+        InetAddress inetAddress =  InetAddress.getByAddress(ip);
+
+        return inetAddress.getCanonicalHostName();
+    }
+
+    public String getHostUsingCustomImpl(byte[] ip) throws UnknownHostException {
+
+        CustomAddressResolverImpl imp = new CustomAddressResolverImpl();
+        return imp.get(null).lookupByAddress(ip);
+    }
+
+    public Stream<InetAddress> getIpUsingCustomImpl(String host) throws UnknownHostException {
+
+        CustomAddressResolverImpl imp = new CustomAddressResolverImpl();
+        return imp.get(null).lookupByName(host, null);
+    }
+}

core-java-modules/core-java-18/src/main/java/com/baeldung/inetspi/Registry.java

@@ -0,0 +1,56 @@
+package com.baeldung.inetspi;
+
+import java.net.InetAddress;
+import java.net.UnknownHostException;
+import java.util.Arrays;
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+import java.util.logging.Logger;
+import java.util.stream.Stream;
+
+public class Registry {
+    private final Map<String, List<byte[]>> registry;
+
+    private static final Logger LOGGER = Logger.getLogger(Registry.class.getName());
+
+    public Registry() {
+        registry = loadMapWithData();
+    }
+
+    public Stream<InetAddress> getAddressesfromHost(String host) throws UnknownHostException {
+        LOGGER.info("Performing Forward Lookup for HOST : " + host);
+        if (!registry.containsKey(host)) {
+            throw new UnknownHostException("Missing Host information in Resolver");
+        }
+        return registry.get(host)
+          .stream()
+          .map(add -> constructInetAddress(host, add))
+          .filter(Objects::nonNull);
+    }
+
+    public String getHostFromAddress(byte[] arr) throws UnknownHostException {
+        LOGGER.info("Performing Reverse Lookup for Address : " + Arrays.toString(arr));
+        for (Map.Entry<String, List<byte[]>> entry : registry.entrySet()) {
+            if (entry.getValue()
+              .stream()
+              .anyMatch(ba -> Arrays.equals(ba, arr))) {
+                return entry.getKey();
+            }
+        }
+        throw new UnknownHostException("Address Not Found");
+    }
+
+    private Map<String, List<byte[]>> loadMapWithData() {
+        return Map.of("baeldung-local.org", List.of(new byte[] { 1, 2, 3, 4 }));
+    }
+
+    private static InetAddress constructInetAddress(String host, byte[] address) {
+        try {
+            return InetAddress.getByAddress(host, address);
+        } catch (UnknownHostException unknownHostException) {
+            return null;
+        }
+    }
+
+}

core-java-modules/core-java-18/src/main/java/com/baeldung/inetspi/providers/CustomAddressResolverImpl.java

@@ -0,0 +1,42 @@
+package com.baeldung.inetspi.providers;
+
+import java.net.InetAddress;
+import java.net.UnknownHostException;
+import java.net.spi.InetAddressResolver;
+import java.net.spi.InetAddressResolverProvider;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.logging.Logger;
+import java.util.stream.Stream;
+
+import com.baeldung.inetspi.Registry;
+
+public class CustomAddressResolverImpl extends InetAddressResolverProvider {
+
+    private static Logger LOGGER = Logger.getLogger(CustomAddressResolverImpl.class.getName());
+
+    private static Registry registry = new Registry();
+
+    @Override
+    public InetAddressResolver get(Configuration configuration) {
+        LOGGER.info("Using Custom Address Resolver :: " + this.name());
+        LOGGER.info("Registry initialised");
+        return new InetAddressResolver() {
+            @Override
+            public Stream<InetAddress> lookupByName(String host, LookupPolicy lookupPolicy) throws UnknownHostException {
+                return registry.getAddressesfromHost(host);
+            }
+
+            @Override
+            public String lookupByAddress(byte[] addr) throws UnknownHostException {
+                return registry.getHostFromAddress(addr);
+            }
+        };
+    }
+
+    @Override
+    public String name() {
+        return "CustomInternetAddressResolverImpl";
+    }
+}

core-java-modules/core-java-18/src/test/java/com/baeldung/inetspi/InetAddressSPIUnitTest.java

@@ -0,0 +1,31 @@
+package com.baeldung.inetspi;
+
+import java.net.InetAddress;
+import java.net.UnknownHostException;
+import java.util.stream.Stream;
+
+import org.junit.Assert;
+import org.junit.Test;
+
+public class InetAddressSPIUnitTest {
+    @Test
+    public void givenInetAddress_whenUsingInetAddress_thenPerformResolution() throws UnknownHostException {
+        InetAddressSPI spi = new InetAddressSPI();
+        Assert.assertNotNull(spi.usingGetByName("www.google.com"));
+        Assert.assertTrue(spi.usingGetAllByName("www.google.com").length > 1);
+        Assert.assertNotNull(spi.usingGetByIp(InetAddress.getByName("www.google.com")
+          .getAddress()));
+        Assert.assertNotNull(spi.usingGetByIpAndReturnsCannonName(InetAddress.getByName("www.google.com")
+          .getAddress()));
+    }
+
+    @Test
+    public void givenCustomInetAddressImplementation_whenUsingInetAddress_thenPerformResolution() throws UnknownHostException {
+        InetAddressSPI spi = new InetAddressSPI();
+        Assert.assertEquals("baeldung-local.org", spi.getHostUsingCustomImpl(new byte[] { 1, 2, 3, 4 }));
+        Stream<InetAddress> response = spi.getIpUsingCustomImpl("baeldung-local.org");
+        Assert.assertArrayEquals(new byte[] { 1, 2, 3, 4 }, response.findFirst()
+          .get()
+          .getAddress());
+    }
+}

core-java-modules/core-java-21/src/main/java/com/baeldung/java21/PatternCaseLabels.java

@@ -0,0 +1,32 @@
+package com.baeldung.java21;
+
+public class PatternCaseLabels {
+
+    static String processInputOld(String input) {
+        String output;
+        switch (input) {
+        case null -> output = "Oops, null";
+        case String s -> {
+            if ("Yes".equalsIgnoreCase(s)) {
+                output = "It's Yes";
+            } else if ("No".equalsIgnoreCase(s)) {
+                output = "It's No";
+            } else {
+                output = "Try Again";
+            }
+        }
+        }
+        return output;
+    }
+
+    static String processInputNew(String input) {
+        String output;
+        switch (input) {
+        case null -> output = "Oops, null";
+        case String s when "Yes".equalsIgnoreCase(s) -> output = "It's Yes";
+        case String s when "No".equalsIgnoreCase(s) -> output = "It's No";
+        case String s -> output = "Try Again";
+        }
+        return output;
+    }
+}

core-java-modules/core-java-21/src/main/java/com/baeldung/java21/RecordPattern.java

@@ -0,0 +1,36 @@
+package com.baeldung.java21;
+
+public class RecordPattern {
+
+    record Point(int x, int y) {}
+    
+    public static int beforeRecordPattern(Object obj) {
+        int sum = 0;
+        if(obj instanceof Point p) {
+            int x = p.x();
+            int y = p.y();
+            sum = x+y;
+        }
+        return sum;
+    }
+    
+    public static int afterRecordPattern(Object obj) {
+        if(obj instanceof Point(int x, int y)) {
+           return x+y;
+        }
+        return 0;
+    }
+    
+    enum Color {RED, GREEN, BLUE}
+    
+    record ColoredPoint(Point point, Color color) {}
+    
+    record RandomPoint(ColoredPoint cp) {}
+    
+    public static Color getRamdomPointColor(RandomPoint r) {
+        if(r instanceof RandomPoint(ColoredPoint cp)) {
+            return cp.color();
+        }
+        return null;
+    }
+}

core-java-modules/core-java-21/src/main/java/com/baeldung/java21/StringTemplates.java

@@ -0,0 +1,9 @@
+package com.baeldung.java21;
+
+public class StringTemplates {
+
+    public String getStringTemplate() {
+        String name = "Baeldung"; 
+        return STR."Welcome to \{name}"; 
+    }
+}

core-java-modules/core-java-21/src/main/java/com/baeldung/java21/SwitchPattern.java

@@ -0,0 +1,56 @@
+package com.baeldung.java21;
+
+public class SwitchPattern {
+    
+    static class Account{
+        double getBalance() {
+            return 0;
+        }
+    }
+    
+    static class SavingsAccount extends Account {
+        @Override
+        double getBalance() {
+            return 100;
+        } 
+    }
+    
+    static class TermAccount extends Account {
+        @Override
+        double getBalance() {
+            return 1000;
+        } 
+    }
+    static class CurrentAccount extends Account {
+        @Override
+        double getBalance() {
+            return 10000;
+        } 
+    }
+    
+    static double getBalanceWithOutSwitchPattern(Account account) {
+        double balance = 0;
+        if(account instanceof SavingsAccount sa) {
+            balance = sa.getBalance();
+        }
+        else if(account instanceof TermAccount ta) {
+            balance = ta.getBalance();
+        }
+        else if(account instanceof CurrentAccount ca) {
+            balance = ca.getBalance();
+        }
+        return balance;
+    }
+    
+    static double getBalanceWithSwitchPattern(Account account) {
+        double result;
+        switch (account) {
+            case null -> throw new IllegalArgumentException("Oops, account is null");
+            case SavingsAccount sa -> result = sa.getBalance();
+            case TermAccount ta -> result = ta.getBalance();
+            case CurrentAccount ca -> result = ca.getBalance();
+            default -> result = account.getBalance();
+        }
+        return result;
+    }
+}

core-java-modules/core-java-21/src/test/java/com/baeldung/java21/PatternCaseLabelsUnitTest.java

@@ -0,0 +1,48 @@
+package com.baeldung.java21;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import org.junit.jupiter.api.Test;
+
+class PatternCaseLabelsUnitTest {
+
+    @Test
+    void whenProcessInputOldWayWithYes_thenReturnOutput() {
+        assertEquals("It's Yes", PatternCaseLabels.processInputOld("Yes"));
+    }
+    
+    @Test
+    void whenProcessInputOldWayWithNo_thenReturnOutput() {
+        assertEquals("It's No", PatternCaseLabels.processInputOld("No"));
+    }
+    
+    @Test
+    void whenProcessInputOldWayWithNull_thenReturnOutput() {
+        assertEquals("Oops, null", PatternCaseLabels.processInputOld(null));
+    }
+    
+    @Test
+    void whenProcessInputOldWayWithInvalidOption_thenReturnOutput() {
+        assertEquals("Try Again", PatternCaseLabels.processInputOld("Invalid Option"));
+    }
+    
+    @Test
+    void whenProcessInputNewWayWithYes_thenReturnOutput() {
+        assertEquals("It's Yes", PatternCaseLabels.processInputNew("Yes"));
+    }
+    
+    @Test
+    void whenProcessInputNewWayWithNo_thenReturnOutput() {
+        assertEquals("It's No", PatternCaseLabels.processInputNew("No"));
+    }
+    
+    @Test
+    void whenProcessInputNewWayWithNull_thenReturnOutput() {
+        assertEquals("Oops, null", PatternCaseLabels.processInputNew(null));
+    }
+    
+    @Test
+    void whenProcessInputNewWayWithInvalidOption_thenReturnOutput() {
+        assertEquals("Try Again", PatternCaseLabels.processInputNew("Invalid Option"));
+    }
+   
+}

core-java-modules/core-java-21/src/test/java/com/baeldung/java21/RecordPatternUnitTest.java

@@ -0,0 +1,29 @@
+package com.baeldung.java21;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import org.junit.jupiter.api.Test;
+
+import com.baeldung.java21.RecordPattern.Color;
+import com.baeldung.java21.RecordPattern.ColoredPoint;
+import com.baeldung.java21.RecordPattern.Point;
+import com.baeldung.java21.RecordPattern.RandomPoint;
+
+class RecordPatternUnitTest {
+
+    @Test
+    void whenNoRecordPattern_thenReturnOutput() {
+        assertEquals(5, RecordPattern.beforeRecordPattern(new Point(2, 3)));
+    }
+    
+    @Test
+    void whenRecordPattern_thenReturnOutput() {
+        assertEquals(5, RecordPattern.afterRecordPattern(new Point(2, 3)));
+    }
+    
+    @Test
+    void whenRecordPattern_thenReturnColorOutput() {
+        ColoredPoint coloredPoint = new ColoredPoint(new Point(2, 3), Color.GREEN);
+        RandomPoint randomPoint = new RandomPoint(coloredPoint);
+        assertEquals(Color.GREEN, RecordPattern.getRamdomPointColor(randomPoint));
+    }
+}

core-java-modules/core-java-21/src/test/java/com/baeldung/java21/StringTemplateUnitTest.java

@@ -0,0 +1,13 @@
+package com.baeldung.java21;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import org.junit.jupiter.api.Test;
+
+class StringTemplateUnitTest {
+
+    @Test
+    void whenNoSwitchPattern_thenReturnSavingsAccountBalance() {
+        StringTemplates stringTemplates = new StringTemplates();
+        assertEquals("Welcome to Baeldung", stringTemplates.getStringTemplate());
+    }
+}

core-java-modules/core-java-21/src/test/java/com/baeldung/java21/SwitchPatternUnitTest.java

@@ -0,0 +1,19 @@
+package com.baeldung.java21;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import org.junit.jupiter.api.Test;
+
+class SwitchPatternUnitTest {
+
+    @Test
+    void whenNoSwitchPattern_thenReturnSavingsAccountBalance() {
+        SwitchPattern.SavingsAccount savingsAccount = new SwitchPattern.SavingsAccount();
+        assertEquals(100, SwitchPattern.getBalanceWithOutSwitchPattern(savingsAccount), 0);
+    }
+    
+    @Test
+    void whenSwitchPattern_thenReturnSavingsAccountBalance() {
+        SwitchPattern.SavingsAccount savingsAccount = new SwitchPattern.SavingsAccount();
+        assertEquals(100, SwitchPattern.getBalanceWithSwitchPattern(savingsAccount), 0);
+    }
+}

core-java-modules/core-java-8-datetime-2/README.md

@@ -13,4 +13,5 @@
 - [Format LocalDate to ISO 8601 With T and Z](https://www.baeldung.com/java-format-localdate-iso-8601-t-z)
 - [Check if Two Date Ranges Overlap](https://www.baeldung.com/java-check-two-date-ranges-overlap)
 - [Difference between ZoneOffset.UTC and ZoneId.of(“UTC”)](https://www.baeldung.com/java-zoneoffset-utc-zoneid-of)
+- [Check if a Given Time Lies Between Two Times Regardless of Date](https://www.baeldung.com/java-check-between-two-times)
 - [[<-- Prev]](/core-java-modules/core-java-datetime-java8-1)

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

@@ -4,8 +4,8 @@
     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-8-datetime-2</artifactId>
-    <name>core-java-8-datetime-2</name>
     <packaging>jar</packaging>
+    <name>core-java-8-datetime-2</name>
 
     <parent>
         <groupId>com.baeldung.core-java-modules</groupId>

core-java-modules/core-java-8-datetime-2/src/test/java/com/baeldung/checkiftimebetweentwotimes/CheckIfTimeBetweenTwoTimesUnitTest.java

@@ -0,0 +1,45 @@
+package com.baeldung.checkiftimebetweentwotimes;
+
+import org.junit.Test;
+
+import java.time.LocalTime;
+import java.util.Calendar;
+import java.util.Date;
+
+import static org.junit.Assert.assertTrue;
+
+public class CheckIfTimeBetweenTwoTimesUnitTest {
+    private LocalTime startTime = LocalTime.parse("09:00:00");
+    private LocalTime endTime = LocalTime.parse("17:00:00");
+    private LocalTime targetTime = LocalTime.parse("12:30:00");
+
+    @Test
+    public void givenLocalTime_whenUsingIsAfterIsBefore_thenTimeIsBetween() {
+        assertTrue(!targetTime.isBefore(startTime) && !targetTime.isAfter(endTime));
+    }
+
+    @Test
+    public void givenLocalTime_whenUsingCompareTo_thenTimeIsBetween() {
+        assertTrue(targetTime.compareTo(startTime) >= 0 && targetTime.compareTo(endTime) <= 0);
+    }
+
+    @Test
+    public void givenDate_whenUsingAfterBefore_thenTimeIsBetween() {
+        Calendar startCalendar = Calendar.getInstance();
+        startCalendar.set(Calendar.HOUR_OF_DAY, 9);
+        startCalendar.set(Calendar.MINUTE, 0);
+        Date startTime = startCalendar.getTime();
+
+        Calendar endCalendar = Calendar.getInstance();
+        endCalendar.set(Calendar.HOUR_OF_DAY, 17);
+        endCalendar.set(Calendar.MINUTE, 0);
+        Date endTime = endCalendar.getTime();
+
+        Calendar targetCalendar = Calendar.getInstance();
+        targetCalendar.set(Calendar.HOUR_OF_DAY, 12);
+        targetCalendar.set(Calendar.MINUTE, 30);
+        Date targetTime = targetCalendar.getTime();
+
+        assertTrue(!targetTime.before(startTime) && !targetTime.after(endTime));
+    }
+}

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

@@ -4,8 +4,8 @@
     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-8-datetime</artifactId>
-    <name>core-java-8-datetime</name>
     <packaging>jar</packaging>
+    <name>core-java-8-datetime</name>
 
     <parent>
         <groupId>com.baeldung.core-java-modules</groupId>

core-java-modules/core-java-9-jigsaw/README.md

@@ -5,7 +5,7 @@ This module contains articles about Project Jigsaw and the Java Platform Module
 ### Relevant Articles:
 
 - [Introduction to Project Jigsaw](http://www.baeldung.com/project-jigsaw-java-modularity)
-- [A Guide to Java 9 Modularity](https://www.baeldung.com/java-9-modularity)
+- [A Guide to Java Modularity](https://www.baeldung.com/java-modularity)
 - [Java 9 java.lang.Module API](https://www.baeldung.com/java-9-module-api)
 - [Java 9 Illegal Reflective Access Warning](https://www.baeldung.com/java-illegal-reflective-access)
 - [Java Modularity and Unit Testing](https://www.baeldung.com/java-modularity-unit-testing)

core-java-modules/core-java-9-jigsaw/library-core/pom.xml

@@ -3,20 +3,14 @@
     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>library-core</artifactId>
+
     <parent>
         <groupId>com.baeldung.core-java-modules</groupId>
         <artifactId>core-java-9-jigsaw</artifactId>
         <version>0.0.1-SNAPSHOT</version>
     </parent>
 
-    <artifactId>library-core</artifactId>
-
-    <properties>
-        <maven.compiler.source>19</maven.compiler.source>
-        <maven.compiler.target>19</maven.compiler.target>
-        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
-    </properties>
-
     <dependencies>
         <dependency>
             <groupId>org.junit.jupiter</groupId>
@@ -52,4 +46,11 @@
             </plugin>
         </plugins>
     </build>
+
+    <properties>
+        <maven.compiler.source>19</maven.compiler.source>
+        <maven.compiler.target>19</maven.compiler.target>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    </properties>
+    
 </project>

core-java-modules/core-java-9-jigsaw/pom.xml

@@ -4,8 +4,9 @@
     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-9-jigsaw</artifactId>
-    <name>core-java-9-jigsaw</name>
     <packaging>pom</packaging>
+    <name>core-java-9-jigsaw</name>
+
     <modules>
         <module>library-core</module>
     </modules>

core-java-modules/core-java-9-streams/pom.xml

@@ -4,8 +4,8 @@
     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-9-streams</artifactId>
-    <name>core-java-9-streams</name>
     <packaging>jar</packaging>
+    <name>core-java-9-streams</name>
 
     <parent>
         <groupId>com.baeldung.core-java-modules</groupId>

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

@@ -4,8 +4,8 @@
     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>
-    <name>core-java-annotations</name>
     <packaging>jar</packaging>
+    <name>core-java-annotations</name>
 
     <parent>
         <groupId>com.baeldung.core-java-modules</groupId>

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

@@ -4,8 +4,8 @@
     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-arrays-convert</artifactId>
-    <name>core-java-arrays-convert</name>
     <packaging>jar</packaging>
+    <name>core-java-arrays-convert</name>
 
     <parent>
         <artifactId>core-java-modules</artifactId>
@@ -20,4 +20,5 @@
             <version>${commons-lang3.version}</version>
         </dependency>
     </dependencies>
+
 </project>