Merge branch 'master' of https://github.com/eugenp/tutorials

core-java-8/src/test/java/com/baeldung/streamordering/BenchmarkUnitTest.java

@@ -1,97 +0,0 @@
-package com.baeldung.streamordering;
-
-import org.junit.Test;
-import org.openjdk.jmh.annotations.*;
-import org.openjdk.jmh.infra.Blackhole;
-import org.openjdk.jmh.runner.Runner;
-import org.openjdk.jmh.runner.options.Options;
-import org.openjdk.jmh.runner.options.OptionsBuilder;
-import org.openjdk.jmh.runner.options.TimeValue;
-
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Random;
-import java.util.concurrent.TimeUnit;
-import java.util.stream.IntStream;
-
-
-public class BenchmarkUnitTest
-{
-
-  @Test
-  public void
-  launchBenchmark() throws Exception {
-
-    Options opt = new OptionsBuilder()
-      // Specify which benchmarks to run.
-      // You can be more specific if you'd like to run only one benchmark per test.
-      .include(this.getClass().getName() + ".*")
-      // Set the following options as needed
-      .mode (Mode.AverageTime)
-      .timeUnit(TimeUnit.MICROSECONDS)
-      .warmupTime(TimeValue.seconds(1))
-      .warmupIterations(2)
-      .measurementTime(TimeValue.seconds(1))
-      .measurementIterations(2)
-      .threads(2)
-      .forks(1)
-      .shouldFailOnError(true)
-      .shouldDoGC(true)
-      //.jvmArgs("-XX:+UnlockDiagnosticVMOptions", "-XX:+PrintInlining")
-      //.addProfiler(WinPerfAsmProfiler.class)
-      .build();
-
-    new Runner(opt).run();
-
-
-  }
-
-  @Benchmark
-  public void givenOrderedStreamInput_whenStreamFiltered_showOpsPerMS(){
-    IntStream.range(1, 100_000_000).parallel().filter(i -> i % 10 == 0).toArray();
-  }
-
-  @Benchmark
-  public void givenUnorderedStreamInput_whenStreamFiltered_showOpsPerMS(){
-    IntStream.range(1,100_000_000).unordered().parallel().filter(i -> i % 10 == 0).toArray();
-  }
-
-  @Benchmark
-  public void givenUnorderedStreamInput_whenStreamDistinct_showOpsPerMS(){
-    IntStream.range(1, 1_000_000).unordered().parallel().distinct().toArray();
-  }
-
-  @Benchmark
-  public void givenOrderedStreamInput_whenStreamDistinct_showOpsPerMS() {
-    //section 5.1.
-    IntStream.range(1, 1_000_000).parallel().distinct().toArray();
-  }
-
-
-  // The JMH samples are the best documentation for how to use it
-  // http://hg.openjdk.java.net/code-tools/jmh/file/tip/jmh-samples/src/main/java/org/openjdk/jmh/samples/
-  @State(Scope.Thread)
-  public static class BenchmarkState
-  {
-    List<Integer> list;
-
-    @Setup(Level.Trial) public void
-    initialize() {
-
-      Random rand = new Random();
-
-      list = new ArrayList<>();
-      for (int i = 0; i < 1000; i++)
-        list.add (rand.nextInt());
-    }
-  }
-
-  @Benchmark public void
-  benchmark1 (BenchmarkState state, Blackhole bh) {
-
-    List<Integer> list = state.list;
-
-    for (int i = 0; i < 1000; i++)
-      bh.consume (list.get (i));
-  }
-}

core-java-8/src/test/java/com/baeldung/streamordering/StreamsOrderingUnitTest.java

@@ -1,149 +0,0 @@
-package com.baeldung.streamordering;
-
-import org.junit.Before;
-import org.junit.Test;
-
-import java.util.*;
-import java.util.function.Function;
-import java.util.logging.Level;
-import java.util.logging.Logger;
-import java.util.stream.Collectors;
-import java.util.stream.IntStream;
-
-import static org.junit.Assert.assertEquals;
-
-public class StreamsOrderingUnitTest {
-
-  Logger logger = Logger.getLogger( StreamsOrderingUnitTest.class.getName());
-
-  @Before
-  public void setUp() throws Exception {
-    logger.setLevel(Level.ALL);
-  }
-
-  @Test
-  public void givenTwoCollections_whenStreamed_thenCheckOutputDifferent(){
-
-    List<String> list = Arrays.asList("B", "A", "C", "D", "F");
-    Set<String> set = new TreeSet<>(Arrays.asList("B", "A", "C", "D", "F"));
-
-    Object[] listOutput = list.stream().toArray();
-    Object[] setOutput = set.stream().toArray();
-
-    assertEquals("[B, A, C, D, F]", Arrays.toString(listOutput));
-    assertEquals("[A, B, C, D, F]", Arrays.toString(setOutput));
-
-  }
-
-  @Test
-  public void givenTwoCollections_whenStreamedInParallel_thenCheckOutputDifferent(){
-
-    List<String> list = Arrays.asList("B", "A", "C", "D", "F");
-    Set<String> set = new TreeSet<>(Arrays.asList("B", "A", "C", "D", "F"));
-
-    Object[] listOutput = list.stream().parallel().toArray();
-    Object[] setOutput = set.stream().parallel().toArray();
-
-    assertEquals("[B, A, C, D, F]", Arrays.toString(listOutput));
-    assertEquals("[A, B, C, D, F]", Arrays.toString(setOutput));
-
-  }
-
-
-
-  @Test
-  public void givenOrderedInput_whenUnorderedAndOrderedCompared_thenCheckUnorderedOutputChanges(){
-    Set<Integer> set = new TreeSet<>(
-      Arrays.asList(-9, -5, -4, -2, 1, 2, 4, 5, 7, 9, 12, 13, 16, 29, 23, 34, 57, 68, 90, 102, 230));
-
-      Object[] orderedArray = set.stream()
-        .parallel()
-        .limit(5)
-        .toArray();
-      Object[] unorderedArray = set.stream()
-        .unordered()
-        .parallel()
-        .limit(5)
-        .toArray();
-
-     logger.info(Arrays.toString(orderedArray));
-     logger.info(Arrays.toString(unorderedArray));
-  }
-
-
-  @Test
-  public void givenUnsortedStreamInput_whenStreamSorted_thenCheckOrderChanged(){
-
-    List<Integer> list = Arrays.asList(-3,10,-4,1,3);
-
-    Object[] listOutput = list.stream().toArray();
-    Object[] listOutputSorted = list.stream().sorted().toArray();
-
-    assertEquals("[-3, 10, -4, 1, 3]", Arrays.toString(listOutput));
-    assertEquals("[-4, -3, 1, 3, 10]", Arrays.toString(listOutputSorted));
-
-  }
-
-  @Test
-  public void givenUnsortedStreamInput_whenStreamDistinct_thenShowTimeTaken(){
-    long start, end;
-    start = System.currentTimeMillis();
-    IntStream.range(1,1_000_000).unordered().parallel().distinct().toArray();
-    end = System.currentTimeMillis();
-    System.out.println(String.format("Time taken when unordered: %d ms", (end - start)));
-  }
-
-
-  @Test
-  public void givenSameCollection_whenStreamTerminated_thenCheckEachVsEachOrdered(){
-
-    List<String> list = Arrays.asList("B", "A", "C", "D", "F");
-
-    list.stream().parallel().forEach(e -> logger.log(Level.INFO, e));
-    list.stream().parallel().forEachOrdered(e -> logger.log(Level.INFO, e));
-
-  }
-
-  @Test
-  public void givenSameCollection_whenStreamCollected_thenCheckOutput(){
-
-    List<String> list = Arrays.asList("B", "A", "C", "D", "F");
-
-    List<String> collectionList = list.stream().parallel().collect(Collectors.toList());
-    Set<String> collectionSet = list.stream().parallel().collect(Collectors.toCollection(TreeSet::new));
-
-    assertEquals("[B, A, C, D, F]", collectionList.toString());
-    assertEquals("[A, B, C, D, F]", collectionSet.toString());
-
-  }
-
-
-  @Test
-  public void givenListIterationOrder_whenStreamCollectedToMap_thenCeckOrderChanged() {
-    List<String> list = Arrays.asList("A", "BB", "CCC");
-
-    Map<String, Integer> hashMap = list.stream().collect(Collectors.toMap(Function.identity(), String::length));
-
-    Object[] keySet = hashMap.keySet().toArray();
-
-    assertEquals("[BB, A, CCC]", Arrays.toString(keySet));
-
-  }
-
-  @Test
-  public void givenListIteration_whenStreamCollectedtoHashMap_thenCheckOrderMaintained() {
-    List<String> list = Arrays.asList("A", "BB", "CCC", "CCC");
-
-    Map<String, Integer> linkedHashMap = list.stream().collect(Collectors.toMap(
-      Function.identity(),
-      String::length,
-      (u, v) -> u,
-      LinkedHashMap::new
-    ));
-
-    Object[] keySet = linkedHashMap.keySet().toArray();
-
-    assertEquals("[A, BB, CCC]", Arrays.toString(keySet));
-  }
-
-}

core-java/src/main/java/com/baeldung/string/AppendCharAtPositionX.java

@@ -0,0 +1,45 @@
+/**
+ * 
+ */
+package com.baeldung.string;
+
+/**
+ * @author swpraman
+ *
+ */
+public class AppendCharAtPositionX {
+    
+    public String addCharUsingCharArray(String str, char ch, int position) {
+        validate(str, position);
+        int len = str.length();
+        char[] updatedArr = new char[len + 1];
+        str.getChars(0, position, updatedArr, 0);
+        updatedArr[position] = ch;
+        str.getChars(position, len, updatedArr, position + 1);
+        return new String(updatedArr);
+    }
+
+    public String addCharUsingSubstring(String str, char ch, int position) {
+        validate(str, position);
+        return str.substring(0, position) + ch + str.substring(position);
+    }
+
+    public String addCharUsingStringBuilder(String str, char ch, int position) {
+        validate(str, position);
+        StringBuilder sb = new StringBuilder(str);
+        sb.insert(position, ch);
+        return sb.toString();
+    }
+    
+    private void validate(String str, int position) {
+        if (str == null) {
+            throw new IllegalArgumentException("Str should not be null");
+        }
+        int len = str.length();
+        if (position < 0 || position > len) {
+            throw new IllegalArgumentException("position[" + position + "] should be " 
+                            + "in the range 0.." + len + " for string " + str);
+        }
+    }
+
+}

core-java/src/test/java/com/baeldung/linesintersection/LinesIntersectionServiceUnitTest.java

@@ -23,7 +23,7 @@ public class LinesIntersectionServiceUnitTest {
 
         assertTrue(point.isPresent());
         assertEquals(point.get().getX(), 1, 0.001);
-        assertEquals(point.get().getX(), 1, 0.001);
+        assertEquals(point.get().getY(), 0, 0.001);
     }
 
     @Test

core-java/src/test/java/com/baeldung/string/AppendCharAtPositionXUnitTest.java

@@ -0,0 +1,110 @@
+/**
+ * 
+ */
+package com.baeldung.string;
+
+import static org.junit.Assert.assertEquals;
+
+import org.junit.Test;
+
+/**
+ * @author swpraman
+ *
+ */
+public class AppendCharAtPositionXUnitTest {
+    
+    private AppendCharAtPositionX appendCharAtPosition = new AppendCharAtPositionX();
+    private String word = "Titanc";
+    private char letter = 'i';
+    
+    @Test
+    public void whenUsingCharacterArrayAndCharacterAddedAtBeginning_shouldAddCharacter() {
+        assertEquals("iTitanc", appendCharAtPosition.addCharUsingCharArray(word, letter, 0));
+    }
+    
+    @Test
+    public void whenUsingSubstringAndCharacterAddedAtBeginning_shouldAddCharacter() {
+        assertEquals("iTitanc", appendCharAtPosition.addCharUsingSubstring(word, letter, 0));
+    }  
+    
+    @Test
+    public void whenUsingStringBuilderAndCharacterAddedAtBeginning_shouldAddCharacter() {
+        assertEquals("iTitanc", appendCharAtPosition.addCharUsingStringBuilder(word, letter, 0));
+    }
+    
+    @Test
+    public void whenUsingCharacterArrayAndCharacterAddedAtMiddle_shouldAddCharacter() {
+        assertEquals("Titianc", appendCharAtPosition.addCharUsingCharArray(word, letter, 3));
+    }
+    
+    @Test
+    public void whenUsingSubstringAndCharacterAddedAtMiddle_shouldAddCharacter() {
+        assertEquals("Titianc", appendCharAtPosition.addCharUsingSubstring(word, letter, 3));
+    }  
+    
+    @Test
+    public void whenUsingStringBuilderAndCharacterAddedAtMiddle_shouldAddCharacter() {
+        assertEquals("Titianc", appendCharAtPosition.addCharUsingStringBuilder(word, letter, 3));
+    }
+    
+    @Test
+    public void whenUsingCharacterArrayAndCharacterAddedAtEnd_shouldAddCharacter() {
+        assertEquals("Titanci", appendCharAtPosition.addCharUsingCharArray(word, letter, word.length()));
+    }
+    
+    @Test
+    public void whenUsingSubstringAndCharacterAddedAtEnd_shouldAddCharacter() {
+        assertEquals("Titanci", appendCharAtPosition.addCharUsingSubstring(word, letter, word.length()));
+    }  
+    
+    @Test
+    public void whenUsingStringBuilderAndCharacterAddedAtEnd_shouldAddCharacter() {
+        assertEquals("Titanci", appendCharAtPosition.addCharUsingStringBuilder(word, letter, word.length()));
+    }
+    
+    @Test(expected=IllegalArgumentException.class)
+    public void whenUsingCharacterArrayAndCharacterAddedAtNegativePosition_shouldThrowException() {
+        appendCharAtPosition.addCharUsingStringBuilder(word, letter, -1);
+    }
+    
+    @Test(expected=IllegalArgumentException.class)
+    public void whenUsingSubstringAndCharacterAddedAtNegativePosition_shouldThrowException() {
+        appendCharAtPosition.addCharUsingStringBuilder(word, letter, -1);
+    }  
+    
+    @Test(expected=IllegalArgumentException.class)
+    public void whenUsingStringBuilderAndCharacterAddedAtNegativePosition_shouldThrowException() {
+        appendCharAtPosition.addCharUsingStringBuilder(word, letter, -1);
+    }
+    
+    @Test(expected=IllegalArgumentException.class)
+    public void whenUsingCharacterArrayAndCharacterAddedAtInvalidPosition_shouldThrowException() {
+        appendCharAtPosition.addCharUsingStringBuilder(word, letter, word.length() + 2);
+    }
+    
+    @Test(expected=IllegalArgumentException.class)
+    public void whenUsingSubstringAndCharacterAddedAtInvalidPosition_shouldThrowException() {
+        appendCharAtPosition.addCharUsingStringBuilder(word, letter, word.length() + 2);
+    }  
+    
+    @Test(expected=IllegalArgumentException.class)
+    public void whenUsingStringBuilderAndCharacterAddedAtInvalidPosition_shouldThrowException() {
+        appendCharAtPosition.addCharUsingStringBuilder(word, letter, word.length() + 2);
+    }
+    
+    @Test(expected=IllegalArgumentException.class)
+    public void whenUsingCharacterArrayAndCharacterAddedAtPositionXAndStringIsNull_shouldThrowException() {
+        appendCharAtPosition.addCharUsingStringBuilder(null, letter, 3);
+    }
+    
+    @Test(expected=IllegalArgumentException.class)
+    public void whenUsingSubstringAndCharacterAddedAtPositionXAndStringIsNull_shouldThrowException() {
+        appendCharAtPosition.addCharUsingStringBuilder(null, letter, 3);
+    }  
+    
+    @Test(expected=IllegalArgumentException.class)
+    public void whenUsingStringBuilderAndCharacterAddedAtPositionXAndStringIsNull_shouldThrowException() {
+        appendCharAtPosition.addCharUsingStringBuilder(null, letter, 3);
+    }
+ 
+}

java-streams/src/test/java/com/baeldung/streamordering/BenchmarkUnitTest.java

@@ -18,7 +18,6 @@ import java.util.stream.IntStream;
 public class BenchmarkUnitTest
 {
 
-  @Test
   public void
   launchBenchmark() throws Exception {
 

java-strings/src/test/java/com/baeldung/string/formatter/DateToStringFormatterUnitTest.java

@@ -0,0 +1,67 @@
+package com.baeldung.string.formatter;
+
+import org.junit.BeforeClass;
+import org.junit.Test;
+
+import java.text.DateFormat;
+import java.text.SimpleDateFormat;
+import java.time.Instant;
+import java.time.LocalDateTime;
+import java.time.ZoneId;
+import java.time.format.DateTimeFormatter;
+import java.util.Calendar;
+import java.util.Date;
+import java.util.TimeZone;
+
+import static org.junit.Assert.assertEquals;
+
+public class DateToStringFormatterUnitTest {
+
+    private static final String DATE_FORMAT = "MMM d, yyyy HH:mm a";
+    private static final String EXPECTED_STRING_DATE = "Aug 1, 2018 12:00 PM";
+    private static Date date;
+
+    @BeforeClass
+    public static void setUp() {
+        TimeZone.setDefault(TimeZone.getTimeZone("CET"));
+        Calendar calendar = Calendar.getInstance();
+        calendar.set(2018, Calendar.AUGUST, 1, 12, 0);
+        date = calendar.getTime();
+    }
+
+    @Test
+    public void whenDateConvertedUsingSimpleDateFormatToString_thenCorrect() {
+        DateFormat formatter = new SimpleDateFormat(DATE_FORMAT);
+        String formattedDate = formatter.format(date);
+
+        assertEquals(EXPECTED_STRING_DATE, formattedDate);
+    }
+
+    @Test
+    public void whenDateConvertedUsingDateFormatToString_thenCorrect() {
+        String formattedDate = DateFormat
+          .getDateTimeInstance(DateFormat.MEDIUM, DateFormat.SHORT)
+          .format(date);
+
+        assertEquals(EXPECTED_STRING_DATE, formattedDate);
+    }
+
+    @Test
+    public void whenDateConvertedUsingFormatterToString_thenCorrect() {
+        String formattedDate = String.format("%1$tb %1$te, %1$tY %1$tI:%1$tM %1$Tp", date);
+
+        assertEquals(EXPECTED_STRING_DATE, formattedDate);
+    }
+
+    @Test
+    public void whenDateConvertedUsingDateTimeApiToString_thenCorrect() {
+        DateTimeFormatter fmt = DateTimeFormatter.ofPattern(DATE_FORMAT);
+        Instant instant = date.toInstant();
+        LocalDateTime ldt = instant
+          .atZone(ZoneId.of("CET"))
+          .toLocalDateTime();
+        String formattedDate = ldt.format(fmt);
+
+        assertEquals(EXPECTED_STRING_DATE, formattedDate);
+    }
+}

jersey/src/main/java/com/baeldung/jersey/server/Responder.java

@@ -0,0 +1,102 @@
+package com.baeldung.jersey.server;
+
+import com.baeldung.jersey.server.model.Person;
+
+import javax.ws.rs.GET;
+import javax.ws.rs.Path;
+import javax.ws.rs.Produces;
+import javax.ws.rs.core.MediaType;
+import javax.ws.rs.core.Response;
+
+@Path("/response")
+public class Responder {
+
+    @GET
+    @Path("/ok")
+    public Response getOkResponse() {
+
+        String message = "This is a text response";
+
+        return Response
+          .status(Response.Status.OK)
+          .entity(message)
+          .build();
+    }
+
+    @GET
+    @Path("/not_ok")
+    public Response getNOkTextResponse() {
+
+        String message = "There was an internal server error";
+
+        return Response
+          .status(Response.Status.INTERNAL_SERVER_ERROR)
+          .entity(message)
+          .build();
+    }
+
+    @GET
+    @Path("/text_plain")
+    public Response getTextResponseTypeDefined() {
+
+        String message = "This is a plain text response";
+
+        return Response
+          .status(Response.Status.OK)
+          .entity(message)
+          .type(MediaType.TEXT_PLAIN)
+          .build();
+    }
+
+    @GET
+    @Path("/text_plain_annotation")
+    @Produces({ MediaType.TEXT_PLAIN })
+    public Response getTextResponseTypeAnnotated() {
+
+        String message = "This is a plain text response via annotation";
+
+        return Response
+          .status(Response.Status.OK)
+          .entity(message)
+          .build();
+    }
+
+    @GET
+    @Path("/pojo")
+    public Response getPojoResponse() {
+
+        Person person = new Person("Abh", "Nepal");
+
+        return Response
+          .status(Response.Status.OK)
+          .entity(person)
+          .build();
+    }
+
+    @GET
+    @Path("/json")
+    public Response getJsonResponse() {
+
+        String message = "{\"hello\": \"This is a JSON response\"}";
+
+        return Response
+          .status(Response.Status.OK)
+          .entity(message)
+          .type(MediaType.APPLICATION_JSON)
+          .build();
+    }
+
+    @GET
+    @Path("/xml")
+    @Produces(MediaType.TEXT_XML)
+    public String sayXMLHello() {
+        return "<?xml version=\"1.0\"?>" + "<hello> This is a xml response </hello>";
+    }
+
+    @GET
+    @Path("/html")
+    @Produces(MediaType.TEXT_HTML)
+    public String sayHtmlHello() {
+        return "<html> " + "<title>" + " This is a html title  </title>" + "<body><h1>" + " This is a html response body " + "</body></h1>" + "</html> ";
+    }
+}

jersey/src/main/java/com/baeldung/jersey/server/model/Person.java

@@ -0,0 +1,32 @@
+package com.baeldung.jersey.server.model;
+
+public class Person {
+    String name;
+    String address;
+
+    public Person(String name, String address) {
+        this.name = name;
+        this.address = address;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public String getAddress() {
+        return address;
+    }
+
+    public void setAddress(String address) {
+        this.address = address;
+    }
+
+    @Override
+    public String toString() {
+        return "Person [name: " + getName() + " address: " + getAddress() + "]";
+    }
+}

jpa-storedprocedure/README.md

@@ -1,2 +0,0 @@
-### Relevant Articles:
-- [A Guide to Stored Procedures with JPA](http://www.baeldung.com/jpa-stored-procedures)

jpa-storedprocedure/pom.xml

@@ -1,65 +0,0 @@
-<?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>
-    <groupId>com.baeldung</groupId>
-    <artifactId>jpa-storedprocedure</artifactId>
-    <version>1.0</version>
-    <packaging>jar</packaging>
-
-    <parent>
-        <groupId>com.baeldung</groupId>
-        <artifactId>parent-modules</artifactId>
-        <version>1.0.0-SNAPSHOT</version>
-    </parent>
-
-    <dependencies>
-        <!-- core library -->
-        <dependency>
-            <groupId>javax</groupId>
-            <artifactId>javaee-api</artifactId>
-            <version>${jee.version}</version>
-            <scope>provided</scope>
-        </dependency>
-        <dependency>
-            <groupId>org.hibernate</groupId>
-            <artifactId>hibernate-entitymanager</artifactId>
-            <version>${hibernate.version}</version>
-        </dependency>
-        <!-- MySql JDBC -->
-        <dependency>
-            <groupId>mysql</groupId>
-            <artifactId>mysql-connector-java</artifactId>
-            <version>${mysql.version}</version>
-        </dependency>
-        <dependency>
-            <groupId>commons-io</groupId>
-            <artifactId>commons-io</artifactId>
-            <version>${commons-io.version}</version>
-        </dependency>
-    </dependencies>
-
-    <build>
-        <finalName>JpaStoredProcedure</finalName>
-        <plugins>
-            <plugin>
-                <artifactId>maven-assembly-plugin</artifactId>
-                <configuration>
-                    <archiveBaseDirectory>${project.basedir}</archiveBaseDirectory>
-                    <!--archive> <manifest> <mainClass>fully.qualified.MainClass</mainClass> </manifest> </archive -->
-                    <descriptorRefs>
-                        <descriptorRef>jar-with-dependencies</descriptorRef>
-                    </descriptorRefs>
-                </configuration>
-            </plugin>
-        </plugins>
-    </build>
-
-    <properties>
-        <jee.version>7.0</jee.version>
-        <hibernate.version>5.2.5.Final</hibernate.version>
-        <mysql.version>6.0.5</mysql.version>
-        <commons-io.version>2.5</commons-io.version>
-    </properties>
-
-</project>

jpa-storedprocedure/src/main/resources/META-INF/persistence.xml

@@ -1,20 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<persistence xmlns="http://xmlns.jcp.org/xml/ns/persistence"
-			 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-			 xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/persistence
-             http://xmlns.jcp.org/xml/ns/persistence/persistence_2_1.xsd"
-			 version="2.1">
-
-	<persistence-unit name="jpa-db">
-		<provider>org.hibernate.jpa.HibernatePersistenceProvider</provider>
-		<class>com.baeldung.jpa.model.Car</class>
-		<properties>
-			<property name="javax.persistence.jdbc.driver" value="com.mysql.jdbc.Driver" />
-			<property name="javax.persistence.jdbc.url" value="jdbc:mysql://127.0.0.1:3306/baeldung" />
-			<property name="javax.persistence.jdbc.user" value="baeldung" />
-			<property name="javax.persistence.jdbc.password" value="YourPassword" />
-			<property name="hibernate.dialect" value="org.hibernate.dialect.MySQLDialect" />
-			<property name="hibernate.show_sql" value="true" />
-		</properties>
-	</persistence-unit>
-</persistence>

jpa-storedprocedure/src/main/resources/logback.xml

@@ -1,13 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<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>

libraries-server/README.md

@@ -0,0 +1,9 @@
+### Relevant articles
+
+- [Embedded Jetty Server in Java](http://www.baeldung.com/jetty-embedded)
+- [Introduction to Netty](http://www.baeldung.com/netty)
+- [Exceptions in Netty](http://www.baeldung.com/netty-exception-handling)
+- [Programatically Create, Configure, and Run a Tomcat Server](http://www.baeldung.com/tomcat-programmatic-setup)
+- [Creating and Configuring Jetty 9 Server in Java](http://www.baeldung.com/jetty-java-programmatic)
+- [Testing Netty with EmbeddedChannel](http://www.baeldung.com/testing-netty-embedded-channel)
+

libraries-server/pom.xml

@@ -15,5 +15,72 @@
             <artifactId>org.eclipse.paho.client.mqttv3</artifactId>
             <version>1.2.0</version>
         </dependency>
+        <!-- https://mvnrepository.com/artifact/org.assertj/assertj-core -->
+        <dependency>
+            <groupId>org.assertj</groupId>
+            <artifactId>assertj-core</artifactId>
+            <version>${assertj.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.eclipse.jetty</groupId>
+            <artifactId>jetty-server</artifactId>
+            <version>${jetty.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.eclipse.jetty</groupId>
+            <artifactId>jetty-servlet</artifactId>
+            <version>${jetty.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.eclipse.jetty</groupId>
+            <artifactId>jetty-webapp</artifactId>
+            <version>${jetty.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.httpcomponents</groupId>
+            <artifactId>httpclient</artifactId>
+            <version>${httpclient.version}</version>
+            <exclusions>
+                <exclusion>
+                    <artifactId>commons-logging</artifactId>
+                    <groupId>commons-logging</groupId>
+                </exclusion>
+            </exclusions>
+        </dependency>
+        <dependency>
+            <groupId>commons-io</groupId>
+            <artifactId>commons-io</artifactId>
+            <version>${commons.io.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>io.netty</groupId>
+            <artifactId>netty-all</artifactId>
+            <version>${netty.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+            <version>${junit.version}</version>
+            <scope>test</scope>
+        </dependency>
+		
+        <!-- tomcat -->
+        <dependency>
+            <groupId>org.apache.tomcat</groupId>
+            <artifactId>tomcat-catalina</artifactId>
+            <version>${tomcat.version}</version>
+        </dependency>
     </dependencies>
+
+    <properties>
+        <assertj.version>3.6.2</assertj.version>
+        <httpclient.version>4.5.3</httpclient.version>
+        <commons.io.version>2.5</commons.io.version>
+        <jetty.version>9.4.8.v20171121</jetty.version>
+        <netty.version>4.1.20.Final</netty.version>
+        <commons.collections.version>4.1</commons.collections.version>
+        <junit.version>4.12</junit.version>
+        <tomcat.version>8.5.24</tomcat.version>
+    </properties>
+
 </project>

libraries/README.md

@@ -5,13 +5,11 @@
 - [String Processing with Apache Commons Lang 3](http://www.baeldung.com/string-processing-commons-lang)
 - [Introduction to Javatuples](http://www.baeldung.com/java-tuples)
 - [Introduction to Javassist](http://www.baeldung.com/javassist)
-- [Embedded Jetty Server in Java](http://www.baeldung.com/jetty-embedded)
 - [Introduction to Apache Flink with Java](http://www.baeldung.com/apache-flink)
 - [Introduction to JSONassert](http://www.baeldung.com/jsonassert)
 - [Intro to JaVers](http://www.baeldung.com/javers)
 - [Introduction to Apache Commons Math](http://www.baeldung.com/apache-commons-math)
 - [Intro to Serenity BDD](http://www.baeldung.com/serenity-bdd)
-- [Introduction to Netty](http://www.baeldung.com/netty)
 - [Merging Streams in Java](http://www.baeldung.com/java-merge-streams)
 - [Serenity BDD and Screenplay](http://www.baeldung.com/serenity-screenplay)
 - [Introduction to Quartz](http://www.baeldung.com/quartz)
@@ -54,10 +52,7 @@
 - [Introduction to BouncyCastle with Java](http://www.baeldung.com/java-bouncy-castle)
 - [Guide to google-http-client](http://www.baeldung.com/google-http-client)
 - [Interact with Google Sheets from Java](http://www.baeldung.com/google-sheets-java-client)
-- [Programatically Create, Configure, and Run a Tomcat Server](http://www.baeldung.com/tomcat-programmatic-setup)
 - [A Docker Guide for Java](http://www.baeldung.com/docker-java-api)
-- [Exceptions in Netty](http://www.baeldung.com/netty-exception-handling)
-- [Creating and Configuring Jetty 9 Server in Java](http://www.baeldung.com/jetty-java-programmatic)
 - [Introduction To OpenCSV](http://www.baeldung.com/opencsv)
 - [Introduction to Akka Actors in Java](http://www.baeldung.com/akka-actors-java)
 - [Asynchronous HTTP with async-http-client in Java](http://www.baeldung.com/async-http-client)
@@ -77,7 +72,6 @@
 - [Publish and Receive Messages with Nats Java Client](http://www.baeldung.com/nats-java-client)
 - [Java Concurrency Utility with JCTools](http://www.baeldung.com/java-concurrency-jc-tools)
 - [Apache Commons Collections MapUtils](http://www.baeldung.com/apache-commons-map-utils)
-- [Testing Netty with EmbeddedChannel](http://www.baeldung.com/testing-netty-embedded-channel)
 - [Creating REST Microservices with Javalin](http://www.baeldung.com/javalin-rest-microservices)
 - [Introduction to JavaPoet](http://www.baeldung.com/java-poet)
 - [Introduction to Joda-Time](http://www.baeldung.com/joda-time)

libraries/pom.xml

@@ -106,21 +106,6 @@
             <artifactId>javers-core</artifactId>
             <version>${javers.version}</version>
         </dependency>
-        <dependency>
-            <groupId>org.eclipse.jetty</groupId>
-            <artifactId>jetty-server</artifactId>
-            <version>${jetty.version}</version>
-        </dependency>
-        <dependency>
-            <groupId>org.eclipse.jetty</groupId>
-            <artifactId>jetty-servlet</artifactId>
-            <version>${jetty.version}</version>
-        </dependency>
-        <dependency>
-            <groupId>org.eclipse.jetty</groupId>
-            <artifactId>jetty-webapp</artifactId>
-            <version>${jetty.version}</version>
-        </dependency>
 
         <dependency>
             <groupId>io.nats</groupId>
@@ -379,11 +364,6 @@
             <artifactId>jmh-generator-annprocess</artifactId>
             <version>${jmh.version}</version>
         </dependency>
-        <dependency>
-            <groupId>io.netty</groupId>
-            <artifactId>netty-all</artifactId>
-            <version>${netty.version}</version>
-        </dependency>
         <dependency>
             <groupId>junit</groupId>
             <artifactId>junit</artifactId>
@@ -659,12 +639,6 @@
             <scope>test</scope>
         </dependency>
 		
-        <!-- tomcat -->
-        <dependency>
-            <groupId>org.apache.tomcat</groupId>
-            <artifactId>tomcat-catalina</artifactId>
-            <version>${tomcat.version}</version>
-        </dependency>
         <dependency>
             <groupId>org.milyn</groupId>
             <artifactId>milyn-smooks-all</artifactId>
@@ -924,7 +898,6 @@
         <commons.io.version>2.5</commons.io.version>
         <commons.dbutils.version>1.6</commons.dbutils.version>
         <h2.version>1.4.196</h2.version>
-        <jetty.version>9.4.8.v20171121</jetty.version>
         <jnats.version>1.0</jnats.version>
 
         <httpclient.version>4.5.3</httpclient.version>
@@ -937,7 +910,6 @@
         <serenity.jira.version>1.9.0</serenity.jira.version>
         <serenity.plugin.version>1.9.27</serenity.plugin.version>
         <jUnitParams.version>1.1.0</jUnitParams.version>
-        <netty.version>4.1.20.Final</netty.version>
         <commons.collections.version>4.1</commons.collections.version>
         <junit.version>4.12</junit.version>
         <java-lsh.version>0.10</java-lsh.version>
@@ -966,7 +938,6 @@
         <kafka.version>1.0.0</kafka.version>
         <smooks.version>1.7.0</smooks.version>
         <docker.version>3.0.14</docker.version>
-        <tomcat.version>8.5.24</tomcat.version>
         <async.http.client.version>2.2.0</async.http.client.version>
         <infinispan.version>9.1.5.Final</infinispan.version>
         <opencsv.version>4.1</opencsv.version>

persistence-modules/java-jpa/README.md

@@ -1,3 +1,4 @@
 # Relevant Articles
 
-* [A Guide to SqlResultSetMapping](http://www.baeldung.com/jpa-sql-resultset-mapping)
+- [A Guide to SqlResultSetMapping](http://www.baeldung.com/jpa-sql-resultset-mapping)
+- [A Guide to Stored Procedures with JPA](http://www.baeldung.com/jpa-stored-procedures)

persistence-modules/java-jpa/src/main/resources/META-INF/persistence.xml

@@ -20,4 +20,18 @@
             <property name="hibernate.temp.use_jdbc_metadata_defaults" value="false"/>
         </properties>
     </persistence-unit>
+    
+    <persistence-unit name="jpa-db">
+        <provider>org.hibernate.jpa.HibernatePersistenceProvider</provider>
+        <class>com.baeldung.jpa.model.Car</class>
+        <properties>
+            <property name="javax.persistence.jdbc.driver" value="com.mysql.jdbc.Driver" />
+            <property name="javax.persistence.jdbc.url" value="jdbc:mysql://127.0.0.1:3306/baeldung" />
+            <property name="javax.persistence.jdbc.user" value="baeldung" />
+            <property name="javax.persistence.jdbc.password" value="YourPassword" />
+            <property name="hibernate.dialect" value="org.hibernate.dialect.MySQLDialect" />
+            <property name="hibernate.show_sql" value="true" />
+        </properties>
+    </persistence-unit>
+	
 </persistence>

pom.xml

@@ -398,7 +398,6 @@
 				<module>jee-7</module>
 				<module>jhipster/jhipster-monolithic</module>
 				<module>jjwt</module>
-				<module>jpa-storedprocedure</module>
 				<module>jsf</module>
 				<module>json-path</module>
 				<module>json</module>
@@ -949,7 +948,6 @@
 				<module>jgroups</module>
 				<module>jee-7</module>
 				<module>jjwt</module>
-				<module>jpa-storedprocedure</module>
 				<module>jsf</module>
 				<module>json-path</module>
 				<module>json</module>

spring-5-mvc/src/main/java/com/baeldung/web/ResponseBodyEmitterController.java

@@ -13,7 +13,7 @@ import org.springframework.web.servlet.mvc.method.annotation.ResponseBodyEmitter
 
 @Controller
 public class ResponseBodyEmitterController {
-    private ExecutorService nonBlockingService = Executors.newSingleThreadExecutor();
+    private ExecutorService nonBlockingService = Executors.newCachedThreadPool();
 
     @GetMapping(Constants.API_RBE)
     public ResponseEntity<ResponseBodyEmitter> handleRbe() {