Merge branch 'master' of https://github.com/eugenp/tutorials into BAEL-14776

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

@@ -1,3 +0,0 @@
-## Relevant articles:
-
-- [Why Do Local Variables Used in Lambdas Have to Be Final or Effectively Final?](https://www.baeldung.com/java-lambda-effectively-final-local-variables)

java-collections-conversions/src/test/java/org/baeldung/java/collections/IterableToCollectionUnitTest.java

@@ -0,0 +1,122 @@
+package org.baeldung.java.collections;
+
+import static org.hamcrest.Matchers.contains;
+import static org.junit.Assert.assertThat;
+
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Spliterator;
+import java.util.Spliterators;
+import java.util.stream.Collectors;
+import java.util.stream.StreamSupport;
+
+import org.apache.commons.collections4.IterableUtils;
+import org.apache.commons.collections4.IteratorUtils;
+import org.junit.Test;
+
+import com.google.common.collect.ImmutableList;
+import com.google.common.collect.Lists;
+
+public class IterableToCollectionUnitTest {
+
+    Iterable<String> iterable = Arrays.asList("john", "tom", "jane");
+    Iterator<String> iterator = iterable.iterator();
+
+    @Test
+    public void whenConvertIterableToListUsingJava_thenSuccess() {
+        List<String> result = new ArrayList<String>();
+        for (String str : iterable) {
+            result.add(str);
+        }
+
+        assertThat(result, contains("john", "tom", "jane"));
+    }
+
+    @Test
+    public void whenConvertIterableToListUsingJava8_thenSuccess() {
+        List<String> result = new ArrayList<String>();
+        iterable.forEach(result::add);
+
+        assertThat(result, contains("john", "tom", "jane"));
+    }
+
+    @Test
+    public void whenConvertIterableToListUsingJava8WithSpliterator_thenSuccess() {
+        List<String> result = StreamSupport.stream(iterable.spliterator(), false)
+            .collect(Collectors.toList());
+
+        assertThat(result, contains("john", "tom", "jane"));
+    }
+
+    @Test
+    public void whenConvertIterableToListUsingGuava_thenSuccess() {
+        List<String> result = Lists.newArrayList(iterable);
+
+        assertThat(result, contains("john", "tom", "jane"));
+    }
+
+    @Test
+    public void whenConvertIterableToImmutableListUsingGuava_thenSuccess() {
+        List<String> result = ImmutableList.copyOf(iterable);
+
+        assertThat(result, contains("john", "tom", "jane"));
+    }
+
+    @Test
+    public void whenConvertIterableToListUsingApacheCommons_thenSuccess() {
+        List<String> result = IterableUtils.toList(iterable);
+
+        assertThat(result, contains("john", "tom", "jane"));
+    }
+
+    // ======================== Iterator
+
+    @Test
+    public void whenConvertIteratorToListUsingJava_thenSuccess() {
+        List<String> result = new ArrayList<String>();
+        while (iterator.hasNext()) {
+            result.add(iterator.next());
+        }
+
+        assertThat(result, contains("john", "tom", "jane"));
+    }
+
+    @Test
+    public void whenConvertIteratorToListUsingJava8_thenSuccess() {
+        List<String> result = new ArrayList<String>();
+        iterator.forEachRemaining(result::add);
+
+        assertThat(result, contains("john", "tom", "jane"));
+    }
+
+    @Test
+    public void whenConvertIteratorToListUsingJava8WithSpliterator_thenSuccess() {
+        List<String> result = StreamSupport.stream(Spliterators.spliteratorUnknownSize(iterator, Spliterator.ORDERED), false)
+            .collect(Collectors.toList());
+
+        assertThat(result, contains("john", "tom", "jane"));
+    }
+
+    @Test
+    public void whenConvertIteratorToListUsingGuava_thenSuccess() {
+        List<String> result = Lists.newArrayList(iterator);
+
+        assertThat(result, contains("john", "tom", "jane"));
+    }
+
+    @Test
+    public void whenConvertIteratorToImmutableListUsingGuava_thenSuccess() {
+        List<String> result = ImmutableList.copyOf(iterator);
+
+        assertThat(result, contains("john", "tom", "jane"));
+    }
+
+    @Test
+    public void whenConvertIteratorToListUsingApacheCommons_thenSuccess() {
+        List<String> result = IteratorUtils.toList(iterator);
+
+        assertThat(result, contains("john", "tom", "jane"));
+    }
+}

libraries-2/pom.xml

@@ -55,6 +55,17 @@
 			<artifactId>spring-boot-starter</artifactId>
 			<version>${spring-boot-starter.version}</version>
 		</dependency>
+		<dependency>
+			<groupId>net.openhft</groupId>
+			<artifactId>chronicle-map</artifactId>
+			<version>${chronicle.map.version}</version>
+			<exclusions>
+				<exclusion>
+					<groupId>com.sun.java</groupId>
+					<artifactId>tools</artifactId>
+				</exclusion>
+			</exclusions>
+		</dependency>
 
 		<!-- Dependencies for response decoder with okhttp -->
 		<dependency>
@@ -95,6 +106,7 @@
 		<classgraph.version>4.8.28</classgraph.version>
 		<jbpm.version>6.0.0.Final</jbpm.version>
 		<picocli.version>3.9.6</picocli.version>
+		<chronicle.map.version>3.17.2</chronicle.map.version>
         <crawler4j.version>4.4.0</crawler4j.version>
 		<spring-boot-starter.version>2.1.4.RELEASE</spring-boot-starter.version>
 	</properties>

libraries-2/src/test/java/com/baeldung/chroniclemap/ChronicleMapUnitTest.java

@@ -0,0 +1,132 @@
+package com.baeldung.chroniclemap;
+
+import static org.hamcrest.CoreMatchers.equalTo;
+import static org.hamcrest.CoreMatchers.is;
+import static org.junit.Assert.assertThat;
+
+import java.io.File;
+import java.util.HashSet;
+import java.util.Set;
+import java.util.stream.Collectors;
+import java.util.stream.IntStream;
+
+import org.junit.AfterClass;
+import org.junit.BeforeClass;
+import org.junit.Test;
+
+import net.openhft.chronicle.core.values.LongValue;
+import net.openhft.chronicle.map.ChronicleMap;
+import net.openhft.chronicle.map.ExternalMapQueryContext;
+import net.openhft.chronicle.map.MapEntry;
+import net.openhft.chronicle.values.Values;
+
+public class ChronicleMapUnitTest {
+
+    static ChronicleMap<LongValue, CharSequence> persistedCountryMap = null;
+
+    static ChronicleMap<LongValue, CharSequence> inMemoryCountryMap = null;
+
+    static ChronicleMap<Integer, Set<Integer>> multiMap = null;
+
+    @SuppressWarnings({ "unchecked", "rawtypes" })
+    @BeforeClass
+    public static void init() {
+        try {
+            inMemoryCountryMap = ChronicleMap.of(LongValue.class, CharSequence.class)
+                .name("country-map")
+                .entries(50)
+                .averageValue("America")
+                .create();
+
+            persistedCountryMap = ChronicleMap.of(LongValue.class, CharSequence.class)
+                .name("country-map")
+                .entries(50)
+                .averageValue("America")
+                .createPersistedTo(new File(System.getProperty("user.home") + "/country-details.dat"));
+
+            Set<Integer> averageValue = IntStream.of(1, 2)
+                .boxed()
+                .collect(Collectors.toSet());
+            multiMap = ChronicleMap.of(Integer.class, (Class<Set<Integer>>) (Class) Set.class)
+                .name("multi-map")
+                .entries(50)
+                .averageValue(averageValue)
+                .create();
+
+            LongValue qatarKey = Values.newHeapInstance(LongValue.class);
+            qatarKey.setValue(1);
+            inMemoryCountryMap.put(qatarKey, "Qatar");
+
+            LongValue key = Values.newHeapInstance(LongValue.class);
+            key.setValue(1);
+            persistedCountryMap.put(key, "Romania");
+            key.setValue(2);
+            persistedCountryMap.put(key, "India");
+
+            Set<Integer> set1 = new HashSet<>();
+            set1.add(1);
+            set1.add(2);
+            multiMap.put(1, set1);
+
+            Set<Integer> set2 = new HashSet<>();
+            set2.add(3);
+            multiMap.put(2, set2);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+
+    @Test
+    public void givenGetQuery_whenCalled_shouldReturnResult() {
+        LongValue key = Values.newHeapInstance(LongValue.class);
+        key.setValue(1);
+        CharSequence country = inMemoryCountryMap.get(key);
+        assertThat(country.toString(), is(equalTo("Qatar")));
+    }
+
+    @Test
+    public void givenGetUsingQuery_whenCalled_shouldReturnResult() {
+        LongValue key = Values.newHeapInstance(LongValue.class);
+        StringBuilder country = new StringBuilder();
+        key.setValue(1);
+        persistedCountryMap.getUsing(key, country);
+        assertThat(country.toString(), is(equalTo("Romania")));
+        key.setValue(2);
+        persistedCountryMap.getUsing(key, country);
+        assertThat(country.toString(), is(equalTo("India")));
+    }
+
+    @Test
+    public void  givenMultipleKeyQuery_whenProcessed_shouldChangeTheValue() {
+        try (ExternalMapQueryContext<Integer, Set<Integer>, ?> fistContext = multiMap.queryContext(1)) {
+            try (ExternalMapQueryContext<Integer, Set<Integer>, ?> secondContext = multiMap.queryContext(2)) {
+                fistContext.updateLock()
+                    .lock();
+                secondContext.updateLock()
+                    .lock();
+                MapEntry<Integer, Set<Integer>> firstEntry = fistContext.entry();
+                Set<Integer> firstSet = firstEntry.value()
+                    .get();
+                firstSet.remove(2);
+                MapEntry<Integer, Set<Integer>> secondEntry = secondContext.entry();
+                Set<Integer> secondSet = secondEntry.value()
+                    .get();
+                secondSet.add(4);
+                firstEntry.doReplaceValue(fistContext.wrapValueAsData(firstSet));
+                secondEntry.doReplaceValue(secondContext.wrapValueAsData(secondSet));
+            }
+        } finally {
+            assertThat(multiMap.get(1)
+                .size(), is(equalTo(1)));
+            assertThat(multiMap.get(2)
+                .size(), is(equalTo(2)));
+        }
+    }
+
+    @AfterClass
+    public static void finish() {
+        persistedCountryMap.close();
+        inMemoryCountryMap.close();
+        multiMap.close();
+    }
+}

persistence-modules/elasticsearch/.gitignore

@@ -0,0 +1,29 @@
+HELP.md
+/target/
+!.mvn/wrapper/maven-wrapper.jar
+
+### STS ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+
+### IntelliJ IDEA ###
+.idea
+*.iws
+*.iml
+*.ipr
+
+### NetBeans ###
+/nbproject/private/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
+/build/
+
+### VS Code ###
+.vscode/

persistence-modules/elasticsearch/pom.xml

@@ -0,0 +1,31 @@
+<?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>elasticsearch</artifactId>
+    <version>0.0.1-SNAPSHOT</version>
+    <name>elasticsearch</name>
+    <description>Demo project for Java Elasticsearch libraries</description>
+
+    <parent>
+        <groupId>com.baeldung</groupId>
+        <artifactId>parent-modules</artifactId>
+        <version>1.0.0-SNAPSHOT</version>
+        <relativePath>../../</relativePath>
+    </parent>
+
+    <dependencies>
+
+        <dependency>
+            <groupId>io.searchbox</groupId>
+            <artifactId>jest</artifactId>
+            <version>6.3.1</version>
+        </dependency>
+        <dependency>
+            <groupId>com.fasterxml.jackson.core</groupId>
+            <artifactId>jackson-databind</artifactId>
+            <version>2.9.6</version>
+        </dependency>
+    </dependencies>
+</project>

persistence-modules/elasticsearch/src/main/java/com/baeldung/jest/Employee.java

@@ -0,0 +1,42 @@
+package com.baeldung.jest;
+
+import java.util.List;
+
+public class Employee {
+    String name;
+    String title;
+    List<String> skills;
+    int yearsOfService;
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public String getTitle() {
+        return title;
+    }
+
+    public void setTitle(String title) {
+        this.title = title;
+    }
+
+    public List<String> getSkills() {
+        return skills;
+    }
+
+    public void setSkills(List<String> skills) {
+        this.skills = skills;
+    }
+
+    public int getYearsOfService() {
+        return yearsOfService;
+    }
+
+    public void setYearsOfService(int yearsOfService) {
+        this.yearsOfService = yearsOfService;
+    }
+}

persistence-modules/elasticsearch/src/main/java/com/baeldung/jest/JestDemoApplication.java

@@ -0,0 +1,174 @@
+package com.baeldung.jest;
+
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import io.searchbox.client.JestClient;
+import io.searchbox.client.JestClientFactory;
+import io.searchbox.client.JestResult;
+import io.searchbox.client.JestResultHandler;
+import io.searchbox.client.config.HttpClientConfig;
+import io.searchbox.core.*;
+import io.searchbox.indices.CreateIndex;
+import io.searchbox.indices.IndicesExists;
+import io.searchbox.indices.aliases.AddAliasMapping;
+import io.searchbox.indices.aliases.ModifyAliases;
+import io.searchbox.indices.aliases.RemoveAliasMapping;
+
+import java.io.IOException;
+import java.util.*;
+
+public class JestDemoApplication {
+
+    public static void main(String[] args) throws IOException {
+
+        // Demo the JestClient
+        JestClient jestClient = jestClient();
+
+        // Check an index
+        JestResult result = jestClient.execute(new IndicesExists.Builder("employees").build());
+        if(!result.isSucceeded()) {
+            System.out.println(result.getErrorMessage());
+        }
+
+        // Create an index
+        jestClient.execute(new CreateIndex.Builder("employees").build());
+
+        // Create an index with options
+        Map<String, Object> settings = new HashMap<>();
+        settings.put("number_of_shards", 11);
+        settings.put("number_of_replicas", 2);
+        jestClient.execute(new CreateIndex.Builder("employees").settings(settings).build());
+
+        // Create an alias, then remove it
+        jestClient.execute(new ModifyAliases.Builder(
+                new AddAliasMapping.Builder(
+                        "employees",
+                        "e")
+                        .build())
+                .build());
+        JestResult jestResult = jestClient.execute(new ModifyAliases.Builder(
+                new RemoveAliasMapping.Builder(
+                        "employees",
+                        "e")
+                        .build())
+                .build());
+
+        if(jestResult.isSucceeded()) {
+            System.out.println("Success!");
+        }
+        else {
+            System.out.println(jestResult.getErrorMessage());
+        }
+
+        // Sample JSON for indexing
+
+        // {
+        //  "name": "Michael Pratt",
+        //  "title": "Java Developer",
+        //  "skills": ["java", "spring", "elasticsearch"],
+        //  "yearsOfService": 2
+        // }
+
+        // Index a document from String
+        ObjectMapper mapper = new ObjectMapper();
+        JsonNode employeeJsonNode = mapper.createObjectNode()
+                .put("name", "Michael Pratt")
+                .put("title", "Java Developer")
+                .put("yearsOfService", 2)
+                .set("skills", mapper.createArrayNode()
+                        .add("java")
+                        .add("spring")
+                        .add("elasticsearch"));
+        jestClient.execute(new Index.Builder(employeeJsonNode.toString()).index("employees").build());
+
+        // Index a document from Map
+        Map<String, Object> employeeHashMap = new LinkedHashMap<>();
+        employeeHashMap.put("name", "Michael Pratt");
+        employeeHashMap.put("title", "Java Developer");
+        employeeHashMap.put("yearsOfService", 2);
+        employeeHashMap.put("skills", Arrays.asList("java", "spring", "elasticsearch"));
+        jestClient.execute(new Index.Builder(employeeHashMap).index("employees").build());
+
+        // Index a document from POJO
+        Employee employee = new Employee();
+        employee.setName("Michael Pratt");
+        employee.setTitle("Java Developer");
+        employee.setYearsOfService(2);
+        employee.setSkills(Arrays.asList("java", "spring", "elasticsearch"));
+        jestClient.execute(new Index.Builder(employee).index("employees").build());
+
+        // Read document by ID
+        Employee getResult = jestClient.execute(new Get.Builder("employees", "1").build()).getSourceAsObject(Employee.class);
+
+        // Search documents
+        String search = "{\n" +
+                "  \"query\": {\n" +
+                "    \"bool\": {\n" +
+                "      \"must\": [\n" +
+                "        { \"match\": { \"name\":   \"Michael Pratt\" }}\n" +
+                "      ]\n" +
+                "    }\n" +
+                "  }\n" +
+                "}";
+        List<SearchResult.Hit<Employee, Void>> searchResults =
+           jestClient.execute(new Search.Builder(search).build())
+           .getHits(Employee.class);
+
+        searchResults.forEach(hit -> {
+            System.out.println(String.format("Document %s has score %s", hit.id, hit.score));
+        });
+
+        // Update document
+        employee.setYearsOfService(3);
+        jestClient.execute(new Update.Builder(employee).index("employees").id("1").build());
+
+        // Delete documents
+        jestClient.execute(new Delete.Builder("2") .index("employees") .build());
+
+        // Bulk operations
+        Employee employeeObject1 = new Employee();
+        employee.setName("John Smith");
+        employee.setTitle("Python Developer");
+        employee.setYearsOfService(10);
+        employee.setSkills(Arrays.asList("python"));
+
+        Employee employeeObject2 = new Employee();
+        employee.setName("Kate Smith");
+        employee.setTitle("Senior JavaScript Developer");
+        employee.setYearsOfService(10);
+        employee.setSkills(Arrays.asList("javascript", "angular"));
+
+        jestClient.execute(new Bulk.Builder().defaultIndex("employees")
+                .addAction(new Index.Builder(employeeObject1).build())
+                .addAction(new Index.Builder(employeeObject2).build())
+                .addAction(new Delete.Builder("3").build()) .build());
+
+        // Async operations
+        Employee employeeObject3 = new Employee();
+        employee.setName("Jane Doe");
+        employee.setTitle("Manager");
+        employee.setYearsOfService(20);
+        employee.setSkills(Arrays.asList("managing"));
+
+        jestClient.executeAsync( new Index.Builder(employeeObject3).build(), new JestResultHandler<JestResult>() {
+            @Override public void completed(JestResult result) {
+                // handle result
+            }
+            @Override public void failed(Exception ex) {
+                // handle exception
+            }
+        });
+    }
+
+    private static JestClient jestClient()
+    {
+        JestClientFactory factory = new JestClientFactory();
+        factory.setHttpClientConfig(
+           new HttpClientConfig.Builder("http://localhost:9200")
+              .multiThreaded(true)
+              .defaultMaxTotalConnectionPerRoute(2)
+              .maxTotalConnection(20)
+              .build());
+        return factory.getObject();
+    }
+}

persistence-modules/pom.xml

@@ -18,6 +18,7 @@
         <module>apache-cayenne</module>
         <module>core-java-persistence</module>
         <module>deltaspike</module>
+        <module>elasticsearch</module>
         <module>flyway</module>
         <module>hbase</module>
         <module>hibernate5</module>

persistence-modules/spring-data-cassandra-reactive/pom.xml

@@ -46,6 +46,13 @@
             <artifactId>reactor-test</artifactId>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>org.cassandraunit</groupId>
+            <artifactId>cassandra-unit-spring</artifactId>
+            <version>${cassandra-unit-spring.version}</version>
+            <scope>test</scope>
+        </dependency>
+        
     </dependencies>
 
     <properties>
@@ -53,6 +60,7 @@
         <project.reporting.outputEncoding>UTF-8
         </project.reporting.outputEncoding>
         <spring-data-cassandra.version>2.1.2.RELEASE</spring-data-cassandra.version>
+        <cassandra-unit-spring.version>3.11.2.0</cassandra-unit-spring.version>
     </properties>
 
 </project>

persistence-modules/spring-data-cassandra-reactive/src/test/java/com/baeldung/cassandra/reactive/ReactiveEmployeeRepositoryIntegrationTest.java

@@ -1,13 +1,23 @@
 package com.baeldung.cassandra.reactive;
 
-import com.baeldung.cassandra.reactive.model.Employee;
+import org.cassandraunit.spring.CassandraDataSet;
-import com.baeldung.cassandra.reactive.repository.EmployeeRepository;
+import org.cassandraunit.spring.CassandraUnitDependencyInjectionTestExecutionListener;
+import org.cassandraunit.spring.CassandraUnitTestExecutionListener;
+import org.cassandraunit.spring.EmbeddedCassandra;
 import org.junit.Before;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.TestExecutionListeners;
 import org.springframework.test.context.junit4.SpringRunner;
+import org.springframework.test.context.support.DependencyInjectionTestExecutionListener;
+import org.springframework.test.context.support.DirtiesContextTestExecutionListener;
+import org.springframework.test.context.web.ServletTestExecutionListener;
+
+import com.baeldung.cassandra.reactive.model.Employee;
+import com.baeldung.cassandra.reactive.repository.EmployeeRepository;
+
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 import reactor.test.StepVerifier;
@@ -15,6 +25,15 @@ import reactor.test.StepVerifier;
 
 @RunWith(SpringRunner.class)
 @SpringBootTest
+@TestExecutionListeners(listeners = {
+        CassandraUnitDependencyInjectionTestExecutionListener.class,
+        CassandraUnitTestExecutionListener.class,
+        ServletTestExecutionListener.class,
+        DependencyInjectionTestExecutionListener.class,
+        DirtiesContextTestExecutionListener.class
+})
+@EmbeddedCassandra(timeout = 60000, configuration = "cassandra-server.yaml")
+@CassandraDataSet(value = {"cassandra-init.cql"}, keyspace = "practice")
 public class ReactiveEmployeeRepositoryIntegrationTest {
 
 	@Autowired

persistence-modules/spring-data-cassandra-reactive/src/test/resources/cassandra-init.cql

@@ -0,0 +1,7 @@
+CREATE TABLE employee(
+    id int PRIMARY KEY,
+    name text,
+    address text,
+    email text,
+    age int
+);

persistence-modules/spring-data-cassandra-reactive/src/test/resources/cassandra-server.yaml

@@ -0,0 +1,590 @@
+# Cassandra storage config YAML
+
+# NOTE:
+#   See http://wiki.apache.org/cassandra/StorageConfiguration for
+#   full explanations of configuration directives
+# /NOTE
+
+# The name of the cluster. This is mainly used to prevent machines in
+# one logical cluster from joining another.
+cluster_name: 'Test Cluster'
+
+# You should always specify InitialToken when setting up a production
+# cluster for the first time, and often when adding capacity later.
+# The principle is that each node should be given an equal slice of
+# the token ring; see http://wiki.apache.org/cassandra/Operations
+# for more details.
+#
+# If blank, Cassandra will request a token bisecting the range of
+# the heaviest-loaded existing node.  If there is no load information
+# available, such as is the case with a new cluster, it will pick
+# a random token, which will lead to hot spots.
+#initial_token:
+
+# See http://wiki.apache.org/cassandra/HintedHandoff
+hinted_handoff_enabled: true
+# this defines the maximum amount of time a dead host will have hints
+# generated.  After it has been dead this long, new hints for it will not be
+# created until it has been seen alive and gone down again.
+max_hint_window_in_ms: 10800000 # 3 hours
+# Maximum throttle in KBs per second, per delivery thread.  This will be
+# reduced proportionally to the number of nodes in the cluster.  (If there
+# are two nodes in the cluster, each delivery thread will use the maximum
+# rate; if there are three, each will throttle to half of the maximum,
+# since we expect two nodes to be delivering hints simultaneously.)
+hinted_handoff_throttle_in_kb: 1024
+# Number of threads with which to deliver hints;
+# Consider increasing this number when you have multi-dc deployments, since
+# cross-dc handoff tends to be slower
+max_hints_delivery_threads: 2
+
+hints_directory: target/embeddedCassandra/hints
+
+# The following setting populates the page cache on memtable flush and compaction
+# WARNING: Enable this setting only when the whole node's data fits in memory.
+# Defaults to: false
+# populate_io_cache_on_flush: false
+
+# Authentication backend, implementing IAuthenticator; used to identify users
+# Out of the box, Cassandra provides org.apache.cassandra.auth.{AllowAllAuthenticator,
+# PasswordAuthenticator}.
+#
+# - AllowAllAuthenticator performs no checks - set it to disable authentication.
+# - PasswordAuthenticator relies on username/password pairs to authenticate
+#   users. It keeps usernames and hashed passwords in system_auth.credentials table.
+#   Please increase system_auth keyspace replication factor if you use this authenticator.
+authenticator: AllowAllAuthenticator
+
+# Authorization backend, implementing IAuthorizer; used to limit access/provide permissions
+# Out of the box, Cassandra provides org.apache.cassandra.auth.{AllowAllAuthorizer,
+# CassandraAuthorizer}.
+#
+# - AllowAllAuthorizer allows any action to any user - set it to disable authorization.
+# - CassandraAuthorizer stores permissions in system_auth.permissions table. Please
+#   increase system_auth keyspace replication factor if you use this authorizer.
+authorizer: AllowAllAuthorizer
+
+# Validity period for permissions cache (fetching permissions can be an
+# expensive operation depending on the authorizer, CassandraAuthorizer is
+# one example). Defaults to 2000, set to 0 to disable.
+# Will be disabled automatically for AllowAllAuthorizer.
+permissions_validity_in_ms: 2000
+
+
+# The partitioner is responsible for distributing rows (by key) across
+# nodes in the cluster.  Any IPartitioner may be used, including your/m
+# own as long as it is on the classpath.  Out of the box, Cassandra
+# provides org.apache.cassandra.dht.{Murmur3Partitioner, RandomPartitioner
+# ByteOrderedPartitioner, OrderPreservingPartitioner (deprecated)}.
+#
+# - RandomPartitioner distributes rows across the cluster evenly by md5.
+#   This is the default prior to 1.2 and is retained for compatibility.
+# - Murmur3Partitioner is similar to RandomPartioner but uses Murmur3_128
+#   Hash Function instead of md5.  When in doubt, this is the best option.
+# - ByteOrderedPartitioner orders rows lexically by key bytes.  BOP allows
+#   scanning rows in key order, but the ordering can generate hot spots
+#   for sequential insertion workloads.
+# - OrderPreservingPartitioner is an obsolete form of BOP, that stores
+# - keys in a less-efficient format and only works with keys that are
+#   UTF8-encoded Strings.
+# - CollatingOPP collates according to EN,US rules rather than lexical byte
+#   ordering.  Use this as an example if you need custom collation.
+#
+# See http://wiki.apache.org/cassandra/Operations for more on
+# partitioners and token selection.
+partitioner: org.apache.cassandra.dht.Murmur3Partitioner
+
+# directories where Cassandra should store data on disk.
+data_file_directories:
+    - target/embeddedCassandra/data
+
+# commit log
+commitlog_directory: target/embeddedCassandra/commitlog
+
+cdc_raw_directory: target/embeddedCassandra/cdc
+
+# policy for data disk failures:
+# stop: shut down gossip and Thrift, leaving the node effectively dead, but
+#       can still be inspected via JMX.
+# best_effort: stop using the failed disk and respond to requests based on
+#              remaining available sstables.  This means you WILL see obsolete
+#              data at CL.ONE!
+# ignore: ignore fatal errors and let requests fail, as in pre-1.2 Cassandra
+disk_failure_policy: stop
+
+
+# Maximum size of the key cache in memory.
+#
+# Each key cache hit saves 1 seek and each row cache hit saves 2 seeks at the
+# minimum, sometimes more. The key cache is fairly tiny for the amount of
+# time it saves, so it's worthwhile to use it at large numbers.
+# The row cache saves even more time, but must store the whole values of
+# its rows, so it is extremely space-intensive. It's best to only use the
+# row cache if you have hot rows or static rows.
+#
+# NOTE: if you reduce the size, you may not get you hottest keys loaded on startup.
+#
+# Default value is empty to make it "auto" (min(5% of Heap (in MB), 100MB)). Set to 0 to disable key cache.
+key_cache_size_in_mb:
+
+# Duration in seconds after which Cassandra should
+# safe the keys cache. Caches are saved to saved_caches_directory as
+# specified in this configuration file.
+#
+# Saved caches greatly improve cold-start speeds, and is relatively cheap in
+# terms of I/O for the key cache. Row cache saving is much more expensive and
+# has limited use.
+#
+# Default is 14400 or 4 hours.
+key_cache_save_period: 14400
+
+# Number of keys from the key cache to save
+# Disabled by default, meaning all keys are going to be saved
+# key_cache_keys_to_save: 100
+
+# Maximum size of the row cache in memory.
+# NOTE: if you reduce the size, you may not get you hottest keys loaded on startup.
+#
+# Default value is 0, to disable row caching.
+row_cache_size_in_mb: 0
+
+# Duration in seconds after which Cassandra should
+# safe the row cache. Caches are saved to saved_caches_directory as specified
+# in this configuration file.
+#
+# Saved caches greatly improve cold-start speeds, and is relatively cheap in
+# terms of I/O for the key cache. Row cache saving is much more expensive and
+# has limited use.
+#
+# Default is 0 to disable saving the row cache.
+row_cache_save_period: 0
+
+# Number of keys from the row cache to save
+# Disabled by default, meaning all keys are going to be saved
+# row_cache_keys_to_save: 100
+
+# saved caches
+saved_caches_directory: target/embeddedCassandra/saved_caches
+
+# commitlog_sync may be either "periodic" or "batch."
+# When in batch mode, Cassandra won't ack writes until the commit log
+# has been fsynced to disk.  It will wait up to
+# commitlog_sync_batch_window_in_ms milliseconds for other writes, before
+# performing the sync.
+#
+# commitlog_sync: batch
+# commitlog_sync_batch_window_in_ms: 50
+#
+# the other option is "periodic" where writes may be acked immediately
+# and the CommitLog is simply synced every commitlog_sync_period_in_ms
+# milliseconds.
+commitlog_sync: periodic
+commitlog_sync_period_in_ms: 10000
+
+# The size of the individual commitlog file segments.  A commitlog
+# segment may be archived, deleted, or recycled once all the data
+# in it (potentially from each columnfamily in the system) has been
+# flushed to sstables.
+#
+# The default size is 32, which is almost always fine, but if you are
+# archiving commitlog segments (see commitlog_archiving.properties),
+# then you probably want a finer granularity of archiving; 8 or 16 MB
+# is reasonable.
+commitlog_segment_size_in_mb: 32
+
+# any class that implements the SeedProvider interface and has a
+# constructor that takes a Map<String, String> of parameters will do.
+seed_provider:
+    # Addresses of hosts that are deemed contact points.
+    # Cassandra nodes use this list of hosts to find each other and learn
+    # the topology of the ring.  You must change this if you are running
+    # multiple nodes!
+    - class_name: org.apache.cassandra.locator.SimpleSeedProvider
+      parameters:
+          # seeds is actually a comma-delimited list of addresses.
+          # Ex: "<ip1>,<ip2>,<ip3>"
+          - seeds: "127.0.0.1"
+
+
+# For workloads with more data than can fit in memory, Cassandra's
+# bottleneck will be reads that need to fetch data from
+# disk. "concurrent_reads" should be set to (16 * number_of_drives) in
+# order to allow the operations to enqueue low enough in the stack
+# that the OS and drives can reorder them.
+#
+# On the other hand, since writes are almost never IO bound, the ideal
+# number of "concurrent_writes" is dependent on the number of cores in
+# your system; (8 * number_of_cores) is a good rule of thumb.
+concurrent_reads: 32
+concurrent_writes: 32
+
+# Total memory to use for memtables.  Cassandra will flush the largest
+# memtable when this much memory is used.
+# If omitted, Cassandra will set it to 1/3 of the heap.
+# memtable_total_space_in_mb: 2048
+
+# Total space to use for commitlogs.
+# If space gets above this value (it will round up to the next nearest
+# segment multiple), Cassandra will flush every dirty CF in the oldest
+# segment and remove it.
+# commitlog_total_space_in_mb: 4096
+
+# This sets the amount of memtable flush writer threads.  These will
+# be blocked by disk io, and each one will hold a memtable in memory
+# while blocked. If you have a large heap and many data directories,
+# you can increase this value for better flush performance.
+# By default this will be set to the amount of data directories defined.
+#memtable_flush_writers: 1
+
+# the number of full memtables to allow pending flush, that is,
+# waiting for a writer thread.  At a minimum, this should be set to
+# the maximum number of secondary indexes created on a single CF.
+#memtable_flush_queue_size: 4
+
+# Whether to, when doing sequential writing, fsync() at intervals in
+# order to force the operating system to flush the dirty
+# buffers. Enable this to avoid sudden dirty buffer flushing from
+# impacting read latencies. Almost always a good idea on SSD:s; not
+# necessarily on platters.
+trickle_fsync: false
+trickle_fsync_interval_in_kb: 10240
+
+# TCP port, for commands and data
+storage_port: 7010
+
+# SSL port, for encrypted communication.  Unused unless enabled in
+# encryption_options
+ssl_storage_port: 7011
+
+# Address to bind to and tell other Cassandra nodes to connect to. You
+# _must_ change this if you want multiple nodes to be able to
+# communicate!
+#
+# Leaving it blank leaves it up to InetAddress.getLocalHost(). This
+# will always do the Right Thing *if* the node is properly configured
+# (hostname, name resolution, etc), and the Right Thing is to use the
+# address associated with the hostname (it might not be).
+#
+# Setting this to 0.0.0.0 is always wrong.
+listen_address: 127.0.0.1
+
+start_native_transport: true
+# port for the CQL native transport to listen for clients on
+native_transport_port: 9042
+
+# Whether to start the thrift rpc server.
+start_rpc: true
+
+# Address to broadcast to other Cassandra nodes
+# Leaving this blank will set it to the same value as listen_address
+# broadcast_address: 1.2.3.4
+
+# The address to bind the Thrift RPC service to -- clients connect
+# here. Unlike ListenAddress above, you *can* specify 0.0.0.0 here if
+# you want Thrift to listen on all interfaces.
+#
+# Leaving this blank has the same effect it does for ListenAddress,
+# (i.e. it will be based on the configured hostname of the node).
+rpc_address: localhost
+# port for Thrift to listen for clients on
+rpc_port: 9171
+
+# enable or disable keepalive on rpc connections
+rpc_keepalive: true
+
+# Cassandra provides three options for the RPC Server:
+#
+# sync  -> One connection per thread in the rpc pool (see below).
+#          For a very large number of clients, memory will be your limiting
+#          factor; on a 64 bit JVM, 128KB is the minimum stack size per thread.
+#          Connection pooling is very, very strongly recommended.
+#
+# async -> Nonblocking server implementation with one thread to serve
+#          rpc connections.  This is not recommended for high throughput use
+#          cases. Async has been tested to be about 50% slower than sync
+#          or hsha and is deprecated: it will be removed in the next major release.
+#
+# hsha  -> Stands for "half synchronous, half asynchronous." The rpc thread pool
+#          (see below) is used to manage requests, but the threads are multiplexed
+#          across the different clients.
+#
+# The default is sync because on Windows hsha is about 30% slower.  On Linux,
+# sync/hsha performance is about the same, with hsha of course using less memory.
+rpc_server_type: sync
+
+# Uncomment rpc_min|max|thread to set request pool size.
+# You would primarily set max for the sync server to safeguard against
+# misbehaved clients; if you do hit the max, Cassandra will block until one
+# disconnects before accepting more.  The defaults for sync are min of 16 and max
+# unlimited.
+#
+# For the Hsha server, the min and max both default to quadruple the number of
+# CPU cores.
+#
+# This configuration is ignored by the async server.
+#
+# rpc_min_threads: 16
+# rpc_max_threads: 2048
+
+# uncomment to set socket buffer sizes on rpc connections
+# rpc_send_buff_size_in_bytes:
+# rpc_recv_buff_size_in_bytes:
+
+# Frame size for thrift (maximum field length).
+# 0 disables TFramedTransport in favor of TSocket. This option
+# is deprecated; we strongly recommend using Framed mode.
+thrift_framed_transport_size_in_mb: 15
+
+# The max length of a thrift message, including all fields and
+# internal thrift overhead.
+thrift_max_message_length_in_mb: 16
+
+# Set to true to have Cassandra create a hard link to each sstable
+# flushed or streamed locally in a backups/ subdirectory of the
+# Keyspace data.  Removing these links is the operator's
+# responsibility.
+incremental_backups: false
+
+# Whether or not to take a snapshot before each compaction.  Be
+# careful using this option, since Cassandra won't clean up the
+# snapshots for you.  Mostly useful if you're paranoid when there
+# is a data format change.
+snapshot_before_compaction: false
+
+# Whether or not a snapshot is taken of the data before keyspace truncation
+# or dropping of column families. The STRONGLY advised default of true
+# should be used to provide data safety. If you set this flag to false, you will
+# lose data on truncation or drop.
+auto_snapshot: false
+
+# Add column indexes to a row after its contents reach this size.
+# Increase if your column values are large, or if you have a very large
+# number of columns.  The competing causes are, Cassandra has to
+# deserialize this much of the row to read a single column, so you want
+# it to be small - at least if you do many partial-row reads - but all
+# the index data is read for each access, so you don't want to generate
+# that wastefully either.
+column_index_size_in_kb: 64
+
+# Size limit for rows being compacted in memory.  Larger rows will spill
+# over to disk and use a slower two-pass compaction process.  A message
+# will be logged specifying the row key.
+#in_memory_compaction_limit_in_mb: 64
+
+# Number of simultaneous compactions to allow, NOT including
+# validation "compactions" for anti-entropy repair.  Simultaneous
+# compactions can help preserve read performance in a mixed read/write
+# workload, by mitigating the tendency of small sstables to accumulate
+# during a single long running compactions. The default is usually
+# fine and if you experience problems with compaction running too
+# slowly or too fast, you should look at
+# compaction_throughput_mb_per_sec first.
+#
+# This setting has no effect on LeveledCompactionStrategy.
+#
+# concurrent_compactors defaults to the number of cores.
+# Uncomment to make compaction mono-threaded, the pre-0.8 default.
+#concurrent_compactors: 1
+
+# Multi-threaded compaction. When enabled, each compaction will use
+# up to one thread per core, plus one thread per sstable being merged.
+# This is usually only useful for SSD-based hardware: otherwise,
+# your concern is usually to get compaction to do LESS i/o (see:
+# compaction_throughput_mb_per_sec), not more.
+#multithreaded_compaction: false
+
+# Throttles compaction to the given total throughput across the entire
+# system. The faster you insert data, the faster you need to compact in
+# order to keep the sstable count down, but in general, setting this to
+# 16 to 32 times the rate you are inserting data is more than sufficient.
+# Setting this to 0 disables throttling. Note that this account for all types
+# of compaction, including validation compaction.
+compaction_throughput_mb_per_sec: 16
+
+# Track cached row keys during compaction, and re-cache their new
+# positions in the compacted sstable.  Disable if you use really large
+# key caches.
+#compaction_preheat_key_cache: true
+
+# Throttles all outbound streaming file transfers on this node to the
+# given total throughput in Mbps. This is necessary because Cassandra does
+# mostly sequential IO when streaming data during bootstrap or repair, which
+# can lead to saturating the network connection and degrading rpc performance.
+# When unset, the default is 200 Mbps or 25 MB/s.
+# stream_throughput_outbound_megabits_per_sec: 200
+
+# How long the coordinator should wait for read operations to complete
+read_request_timeout_in_ms: 5000
+# How long the coordinator should wait for seq or index scans to complete
+range_request_timeout_in_ms: 10000
+# How long the coordinator should wait for writes to complete
+write_request_timeout_in_ms: 2000
+# How long a coordinator should continue to retry a CAS operation
+# that contends with other proposals for the same row
+cas_contention_timeout_in_ms: 1000
+# How long the coordinator should wait for truncates to complete
+# (This can be much longer, because unless auto_snapshot is disabled
+# we need to flush first so we can snapshot before removing the data.)
+truncate_request_timeout_in_ms: 60000
+# The default timeout for other, miscellaneous operations
+request_timeout_in_ms: 10000
+
+# Enable operation timeout information exchange between nodes to accurately
+# measure request timeouts.  If disabled, replicas will assume that requests
+# were forwarded to them instantly by the coordinator, which means that
+# under overload conditions we will waste that much extra time processing
+# already-timed-out requests.
+#
+# Warning: before enabling this property make sure to ntp is installed
+# and the times are synchronized between the nodes.
+cross_node_timeout: false
+
+# Enable socket timeout for streaming operation.
+# When a timeout occurs during streaming, streaming is retried from the start
+# of the current file. This _can_ involve re-streaming an important amount of
+# data, so you should avoid setting the value too low.
+# Default value is 0, which never timeout streams.
+# streaming_socket_timeout_in_ms: 0
+
+# phi value that must be reached for a host to be marked down.
+# most users should never need to adjust this.
+# phi_convict_threshold: 8
+
+# endpoint_snitch -- Set this to a class that implements
+# IEndpointSnitch.  The snitch has two functions:
+# - it teaches Cassandra enough about your network topology to route
+#   requests efficiently
+# - it allows Cassandra to spread replicas around your cluster to avoid
+#   correlated failures. It does this by grouping machines into
+#   "datacenters" and "racks."  Cassandra will do its best not to have
+#   more than one replica on the same "rack" (which may not actually
+#   be a physical location)
+#
+# IF YOU CHANGE THE SNITCH AFTER DATA IS INSERTED INTO THE CLUSTER,
+# YOU MUST RUN A FULL REPAIR, SINCE THE SNITCH AFFECTS WHERE REPLICAS
+# ARE PLACED.
+#
+# Out of the box, Cassandra provides
+#  - SimpleSnitch:
+#    Treats Strategy order as proximity. This improves cache locality
+#    when disabling read repair, which can further improve throughput.
+#    Only appropriate for single-datacenter deployments.
+#  - PropertyFileSnitch:
+#    Proximity is determined by rack and data center, which are
+#    explicitly configured in cassandra-topology.properties.
+#  - RackInferringSnitch:
+#    Proximity is determined by rack and data center, which are
+#    assumed to correspond to the 3rd and 2nd octet of each node's
+#    IP address, respectively.  Unless this happens to match your
+#    deployment conventions (as it did Facebook's), this is best used
+#    as an example of writing a custom Snitch class.
+#  - Ec2Snitch:
+#    Appropriate for EC2 deployments in a single Region.  Loads Region
+#    and Availability Zone information from the EC2 API. The Region is
+#    treated as the Datacenter, and the Availability Zone as the rack.
+#    Only private IPs are used, so this will not work across multiple
+#    Regions.
+#  - Ec2MultiRegionSnitch:
+#    Uses public IPs as broadcast_address to allow cross-region
+#    connectivity.  (Thus, you should set seed addresses to the public
+#    IP as well.) You will need to open the storage_port or
+#    ssl_storage_port on the public IP firewall.  (For intra-Region
+#    traffic, Cassandra will switch to the private IP after
+#    establishing a connection.)
+#
+# You can use a custom Snitch by setting this to the full class name
+# of the snitch, which will be assumed to be on your classpath.
+endpoint_snitch: SimpleSnitch
+
+# controls how often to perform the more expensive part of host score
+# calculation
+dynamic_snitch_update_interval_in_ms: 100
+# controls how often to reset all host scores, allowing a bad host to
+# possibly recover
+dynamic_snitch_reset_interval_in_ms: 600000
+# if set greater than zero and read_repair_chance is < 1.0, this will allow
+# 'pinning' of replicas to hosts in order to increase cache capacity.
+# The badness threshold will control how much worse the pinned host has to be
+# before the dynamic snitch will prefer other replicas over it.  This is
+# expressed as a double which represents a percentage.  Thus, a value of
+# 0.2 means Cassandra would continue to prefer the static snitch values
+# until the pinned host was 20% worse than the fastest.
+dynamic_snitch_badness_threshold: 0.1
+
+# request_scheduler -- Set this to a class that implements
+# RequestScheduler, which will schedule incoming client requests
+# according to the specific policy. This is useful for multi-tenancy
+# with a single Cassandra cluster.
+# NOTE: This is specifically for requests from the client and does
+# not affect inter node communication.
+# org.apache.cassandra.scheduler.NoScheduler - No scheduling takes place
+# org.apache.cassandra.scheduler.RoundRobinScheduler - Round robin of
+# client requests to a node with a separate queue for each
+# request_scheduler_id. The scheduler is further customized by
+# request_scheduler_options as described below.
+request_scheduler: org.apache.cassandra.scheduler.NoScheduler
+
+# Scheduler Options vary based on the type of scheduler
+# NoScheduler - Has no options
+# RoundRobin
+#  - throttle_limit -- The throttle_limit is the number of in-flight
+#                      requests per client.  Requests beyond
+#                      that limit are queued up until
+#                      running requests can complete.
+#                      The value of 80 here is twice the number of
+#                      concurrent_reads + concurrent_writes.
+#  - default_weight -- default_weight is optional and allows for
+#                      overriding the default which is 1.
+#  - weights -- Weights are optional and will default to 1 or the
+#               overridden default_weight. The weight translates into how
+#               many requests are handled during each turn of the
+#               RoundRobin, based on the scheduler id.
+#
+# request_scheduler_options:
+#    throttle_limit: 80
+#    default_weight: 5
+#    weights:
+#      Keyspace1: 1
+#      Keyspace2: 5
+
+# request_scheduler_id -- An identifer based on which to perform
+# the request scheduling. Currently the only valid option is keyspace.
+# request_scheduler_id: keyspace
+
+# index_interval controls the sampling of entries from the primrary
+# row index in terms of space versus time.  The larger the interval,
+# the smaller and less effective the sampling will be.  In technicial
+# terms, the interval coresponds to the number of index entries that
+# are skipped between taking each sample.  All the sampled entries
+# must fit in memory.  Generally, a value between 128 and 512 here
+# coupled with a large key cache size on CFs results in the best trade
+# offs.  This value is not often changed, however if you have many
+# very small rows (many to an OS page), then increasing this will
+# often lower memory usage without a impact on performance.
+index_interval: 128
+
+# Enable or disable inter-node encryption
+# Default settings are TLS v1, RSA 1024-bit keys (it is imperative that
+# users generate their own keys) TLS_RSA_WITH_AES_128_CBC_SHA as the cipher
+# suite for authentication, key exchange and encryption of the actual data transfers.
+# NOTE: No custom encryption options are enabled at the moment
+# The available internode options are : all, none, dc, rack
+#
+# If set to dc cassandra will encrypt the traffic between the DCs
+# If set to rack cassandra will encrypt the traffic between the racks
+#
+# The passwords used in these options must match the passwords used when generating
+# the keystore and truststore.  For instructions on generating these files, see:
+# http://download.oracle.com/javase/6/docs/technotes/guides/security/jsse/JSSERefGuide.html#CreateKeystore
+#
+encryption_options:
+    internode_encryption: none
+    keystore: conf/.keystore
+    keystore_password: cassandra
+    truststore: conf/.truststore
+    truststore_password: cassandra
+    # More advanced defaults below:
+    # protocol: TLS
+    # algorithm: SunX509
+    # store_type: JKS
+    # cipher_suites: [TLS_RSA_WITH_AES_128_CBC_SHA,TLS_RSA_WITH_AES_256_CBC_SHA]

spring-5-reactive/src/test/java/com/baeldung/reactive/errorhandling/ErrorHandlingIntegrationTest.java

@@ -1,10 +1,13 @@
 package com.baeldung.reactive.errorhandling;
 
-import java.io.IOException;
 import static org.junit.Assert.assertEquals;
+
+import java.io.IOException;
+
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.autoconfigure.web.reactive.AutoConfigureWebTestClient;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.boot.test.context.SpringBootTest.WebEnvironment;
 import org.springframework.http.MediaType;
@@ -15,6 +18,7 @@ import org.springframework.test.web.reactive.server.WebTestClient;
 @RunWith(SpringRunner.class)
 @SpringBootTest(webEnvironment = WebEnvironment.DEFINED_PORT)
 @WithMockUser
+@AutoConfigureWebTestClient(timeout = "10000")
 public class ErrorHandlingIntegrationTest {
 
     @Autowired

spring-5-reactive/src/test/java/com/baeldung/reactive/filters/PlayerHandlerIntegrationTest.java

@@ -3,6 +3,7 @@ package com.baeldung.reactive.filters;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.autoconfigure.web.reactive.AutoConfigureWebTestClient;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.security.test.context.support.WithMockUser;
 import org.springframework.test.context.junit4.SpringRunner;
@@ -14,6 +15,7 @@ import static org.junit.Assert.assertEquals;
 @RunWith(SpringRunner.class)
 @SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
 @WithMockUser
+@AutoConfigureWebTestClient(timeout = "10000")
 public class PlayerHandlerIntegrationTest {
 
     @Autowired

spring-5-reactive/src/test/java/com/baeldung/stepverifier/PostExecutionUnitTest.java

@@ -28,7 +28,7 @@ public class PostExecutionUnitTest {
           .expectComplete()
           .verifyThenAssertThat()
           .hasDropped(4)
-          .tookLessThan(Duration.ofMillis(1050));
+          .tookLessThan(Duration.ofMillis(1500));
     }
 
 }

spring-activiti/src/test/java/com/baeldung/SpringContextIntegrationTest.java

@@ -2,6 +2,7 @@ package com.baeldung;
 
 import org.junit.Test;
 import org.junit.runner.RunWith;
+import org.springframework.boot.test.autoconfigure.jdbc.AutoConfigureTestDatabase;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.test.context.junit4.SpringRunner;
 
@@ -9,6 +10,7 @@ import com.baeldung.activitiwithspring.ActivitiWithSpringApplication;
 
 @RunWith(SpringRunner.class)
 @SpringBootTest(classes = ActivitiWithSpringApplication.class)
+@AutoConfigureTestDatabase
 public class SpringContextIntegrationTest {
 
     @Test

spring-activiti/src/test/java/com/baeldung/activitiwithspring/ActivitiSpringSecurityIntegrationTest.java

@@ -4,6 +4,7 @@ import org.activiti.engine.IdentityService;
 import org.junit.Test;
 import org.junit.runner.RunWith;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.autoconfigure.jdbc.AutoConfigureTestDatabase;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.security.core.userdetails.UsernameNotFoundException;
 import org.springframework.test.context.junit4.SpringRunner;
@@ -14,6 +15,7 @@ import com.baeldung.activiti.security.withspring.ActivitiSpringSecurityApplicati
 @RunWith(SpringRunner.class)
 @SpringBootTest(classes = ActivitiSpringSecurityApplication.class)
 @WebAppConfiguration
+@AutoConfigureTestDatabase
 public class ActivitiSpringSecurityIntegrationTest {
     @Autowired
     private IdentityService identityService;

spring-activiti/src/test/java/com/baeldung/activitiwithspring/ActivitiWithSpringApplicationIntegrationTest.java

@@ -2,11 +2,13 @@ package com.baeldung.activitiwithspring;
 
 import org.junit.Test;
 import org.junit.runner.RunWith;
+import org.springframework.boot.test.autoconfigure.jdbc.AutoConfigureTestDatabase;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.test.context.junit4.SpringRunner;
 
 @RunWith(SpringRunner.class)
-@SpringBootTest
+@SpringBootTest(classes = ActivitiWithSpringApplication.class)
+@AutoConfigureTestDatabase
 public class ActivitiWithSpringApplicationIntegrationTest {
 
     @Test

spring-activiti/src/test/java/com/baeldung/activitiwithspring/ProcessEngineCreationIntegrationTest.java

@@ -4,7 +4,7 @@ import org.activiti.engine.ProcessEngine;
 import org.activiti.engine.ProcessEngineConfiguration;
 import org.activiti.engine.ProcessEngines;
 import org.junit.Test;
-
+import org.junit.After;
 import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertNotNull;
 
@@ -62,4 +62,9 @@ public class ProcessEngineCreationIntegrationTest {
         assertNotNull(processEngine);
         assertEquals("sa", processEngine.getProcessEngineConfiguration().getJdbcUsername());
     }
+    
+    @After
+    public void cleanup() {
+        ProcessEngines.destroy();
+    }
 }

spring-core/pom.xml

@@ -56,6 +56,12 @@
             <artifactId>spring-boot-test</artifactId>
             <version>${mockito.spring.boot.version}</version>
             <scope>test</scope>
+        </dependency>
+         <dependency>
+            <groupId>org.assertj</groupId>
+            <artifactId>assertj-core</artifactId>
+            <version>${assertj.version}</version>
+            <scope>test</scope>
         </dependency>
         <dependency>
             <groupId>commons-io</groupId>
@@ -85,6 +91,7 @@
         <commons.io.version>2.5</commons.io.version>
         <spring-boot.version>1.5.2.RELEASE</spring-boot.version>
         <mockito.version>1.10.19</mockito.version>
+        <assertj.version>3.12.2</assertj.version>
     </properties>
 
 </project>

spring-core/src/main/resources/constructordi.xml

@@ -1,19 +1,21 @@
 <beans xmlns="http://www.springframework.org/schema/beans"
     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
     xsi:schemaLocation="http://www.springframework.org/schema/beans
-    http://www.springframework.org/schema/beans/spring-beans-3.0.xsd">
+    https://www.springframework.org/schema/beans/spring-beans.xsd">
 
     <bean id="toyota" class="com.baeldung.constructordi.domain.Car">
         <constructor-arg index="0" ref="engine" />
         <constructor-arg index="1" ref="transmission" />
     </bean>
 
-    <bean id="engine" class="com.baeldung.constructordi.domain.Engine">
+    <bean id="engine"
+        class="com.baeldung.constructordi.domain.Engine">
         <constructor-arg index="0" value="v4" />
         <constructor-arg index="1" value="2" />
     </bean>
 
-    <bean id="transmission" class="com.baeldung.constructordi.domain.Transmission">
+    <bean id="transmission"
+        class="com.baeldung.constructordi.domain.Transmission">
         <constructor-arg value="sliding" />
     </bean>
 

spring-core/src/test/java/com/baeldung/constructordi/ConstructorDependencyInjectionIntegrationTest.java

@@ -0,0 +1,33 @@
+package com.baeldung.constructordi;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.annotation.AnnotationConfigApplicationContext;
+import org.springframework.context.support.ClassPathXmlApplicationContext;
+import org.springframework.test.context.ContextConfiguration;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+import org.springframework.test.context.support.AnnotationConfigContextLoader;
+
+import com.baeldung.constructordi.domain.Car;
+
+@RunWith(SpringJUnit4ClassRunner.class)
+@ContextConfiguration(loader = AnnotationConfigContextLoader.class, classes = Config.class)
+public class ConstructorDependencyInjectionIntegrationTest {
+
+    @Test
+    public void givenPrototypeInjection_WhenObjectFactory_ThenNewInstanceReturn() {
+        ApplicationContext context = new AnnotationConfigApplicationContext(Config.class);
+        Car firstContextCar = context.getBean(Car.class);
+
+        ApplicationContext xmlContext = new ClassPathXmlApplicationContext("constructordi.xml");
+        Car secondContextCar = xmlContext.getBean(Car.class);
+
+        assertThat(firstContextCar).isNotSameAs(secondContextCar);
+        assertThat(firstContextCar).hasToString("Engine: v8 5 Transmission: sliding");
+        assertThat(secondContextCar).hasToString("Engine: v4 2 Transmission: sliding");
+    }
+
+}

spring-security-rest-custom/src/main/java/org/baeldung/config/child/MethodSecurityConfig.java

@@ -0,0 +1,37 @@
+package org.baeldung.config.child;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.security.access.intercept.RunAsImplAuthenticationProvider;
+import org.springframework.security.access.intercept.RunAsManager;
+import org.springframework.security.access.intercept.RunAsManagerImpl;
+import org.springframework.security.authentication.AuthenticationProvider;
+import org.springframework.security.config.annotation.authentication.builders.AuthenticationManagerBuilder;
+import org.springframework.security.config.annotation.method.configuration.EnableGlobalMethodSecurity;
+import org.springframework.security.config.annotation.method.configuration.GlobalMethodSecurityConfiguration;
+
+
+@Configuration
+@EnableGlobalMethodSecurity(securedEnabled = true)
+public class MethodSecurityConfig extends GlobalMethodSecurityConfiguration {
+
+    @Override
+    protected RunAsManager runAsManager() {
+        RunAsManagerImpl runAsManager = new RunAsManagerImpl();
+        runAsManager.setKey("MyRunAsKey");
+        return runAsManager;
+    }
+
+    @Autowired
+    public void configureGlobal(AuthenticationManagerBuilder auth) throws Exception {
+        auth.authenticationProvider(runAsAuthenticationProvider());
+    }
+
+    @Bean
+    public AuthenticationProvider runAsAuthenticationProvider() {
+        RunAsImplAuthenticationProvider authProvider = new RunAsImplAuthenticationProvider();
+        authProvider.setKey("MyRunAsKey");
+        return authProvider;
+    }
+}

spring-security-rest-custom/src/main/java/org/baeldung/service/RunAsService.java

@@ -0,0 +1,17 @@
+package org.baeldung.service;
+
+import org.springframework.security.access.annotation.Secured;
+import org.springframework.security.core.Authentication;
+import org.springframework.security.core.context.SecurityContextHolder;
+import org.springframework.stereotype.Service;
+
+@Service
+public class RunAsService {
+
+    @Secured({ "ROLE_RUN_AS_REPORTER" })
+    public Authentication getCurrentUser() {
+        Authentication authentication = 
+                SecurityContextHolder.getContext().getAuthentication();
+        return authentication;
+    }
+}

spring-security-rest-custom/src/main/java/org/baeldung/web/controller/RunAsController.java

@@ -0,0 +1,23 @@
+package org.baeldung.web.controller;
+
+import org.springframework.security.access.annotation.Secured;
+import org.springframework.security.core.Authentication;
+import org.springframework.security.core.context.SecurityContextHolder;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.ResponseBody;
+
+
+@Controller
+@RequestMapping("/runas")
+public class RunAsController {
+
+    @Secured({ "ROLE_USER", "RUN_AS_REPORTER" })
+    @RequestMapping
+    @ResponseBody
+    public String tryRunAs() {
+        Authentication auth = SecurityContextHolder.getContext().getAuthentication();
+        return "Current User Authorities inside this RunAS method only " + 
+        auth.getAuthorities().toString();
+    }
+}

spring-security-rest-custom/src/main/java/org/baeldung/web/controller/ViewController.java

@@ -10,4 +10,9 @@ public class ViewController {
     public String index() {
         return "index";
     }
+    
+    @RequestMapping({ "/runashome" })
+    public String run() {
+        return "runas";
+    }
 }

spring-security-rest-custom/src/main/webapp/WEB-INF/templates/runas.html

@@ -0,0 +1,23 @@
+<!DOCTYPE html>
+<html xmlns:th="https://www.thymeleaf.org"
+	xmlns:sec="https://www.thymeleaf.org/thymeleaf-extras-springsecurity5">
+<body>
+	Current user authorities:
+	<span sec:authentication="principal.authorities">user</span>
+	<br />
+	<span id="temp"></span>
+	<a href="#" onclick="tryRunAs()">Generate Report As Super User</a>
+
+	<script
+		src="http://ajax.googleapis.com/ajax/libs/jquery/1.11.2/jquery.min.js"></script>
+	<script type="text/javascript">
+	
+		function tryRunAs(){
+			var context = window.location.pathname.substring(0, window.location.pathname.indexOf("/", 2));
+		    $.get( context + "/runas" , function( data ) {
+		         $("#temp").html(data);
+		    });
+		}
+	</script>
+</body>
+</html>

testing-modules/junit-5-advanced/pom.xml

@@ -0,0 +1,32 @@
+<?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>junit-5-advanced</artifactId>
+    <version>1.0-SNAPSHOT</version>
+    <name>junit-5-advanced</name>
+    <description>Advanced JUnit 5 Topics</description>
+
+    <parent>
+        <groupId>com.baeldung</groupId>
+        <artifactId>parent-modules</artifactId>
+        <version>1.0.0-SNAPSHOT</version>
+        <relativePath>../../</relativePath>
+    </parent>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter</artifactId>
+            <version>${junit-jupiter.version}</version>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+    
+    <properties>
+        <junit-jupiter.version>5.4.2</junit-jupiter.version>
+        <maven-surefire-plugin.version>2.21.0</maven-surefire-plugin.version>
+    </properties>
+
+</project>

testing-modules/junit-5-advanced/src/test/java/com/baeldung/displayname/DisplayNameGeneratorUnitTest.java

@@ -0,0 +1,87 @@
+package com.baeldung.displayname;
+
+import org.junit.jupiter.api.DisplayNameGeneration;
+import org.junit.jupiter.api.DisplayNameGenerator;
+import org.junit.jupiter.api.Nested;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.params.ParameterizedTest;
+import org.junit.jupiter.params.provider.ValueSource;
+
+import java.lang.reflect.Method;
+
+@DisplayNameGeneration(DisplayNameGeneratorUnitTest.ReplaceCamelCase.class)
+class DisplayNameGeneratorUnitTest {
+
+    @Test
+    void camelCaseName() {
+    }
+
+    @Nested
+    @DisplayNameGeneration(DisplayNameGeneratorUnitTest.IndicativeSentences.class)
+    class ANumberIsFizz {
+        @Test
+        void ifItIsDivisibleByThree() {
+        }
+
+        @ParameterizedTest(name = "Number {0} is fizz.")
+        @ValueSource(ints = { 3, 12, 18 })
+        void ifItIsOneOfTheFollowingNumbers(int number) {
+        }
+    }
+
+    @Nested
+    @DisplayNameGeneration(DisplayNameGeneratorUnitTest.IndicativeSentences.class)
+    class ANumberIsBuzz {
+        @Test
+        void ifItIsDivisibleByFive() {
+        }
+
+        @ParameterizedTest(name = "Number {0} is buzz.")
+        @ValueSource(ints = { 5, 10, 20 })
+        void ifItIsOneOfTheFollowingNumbers(int number) {
+        }
+    }
+
+    static class IndicativeSentences extends ReplaceCamelCase {
+        @Override
+        public String generateDisplayNameForNestedClass(Class<?> nestedClass) {
+            return super.generateDisplayNameForNestedClass(nestedClass) + "...";
+        }
+
+        @Override
+        public String generateDisplayNameForMethod(Class<?> testClass, Method testMethod) {
+            return replaceCamelCase(testClass.getSimpleName() + " " + testMethod.getName()) + ".";
+        }
+    }
+
+    static class ReplaceCamelCase extends DisplayNameGenerator.Standard {
+        @Override
+        public String generateDisplayNameForClass(Class<?> testClass) {
+            return replaceCamelCase(super.generateDisplayNameForClass(testClass));
+        }
+
+        @Override
+        public String generateDisplayNameForNestedClass(Class<?> nestedClass) {
+            return replaceCamelCase(super.generateDisplayNameForNestedClass(nestedClass));
+        }
+
+        @Override
+        public String generateDisplayNameForMethod(Class<?> testClass, Method testMethod) {
+            return this.replaceCamelCase(testMethod.getName()) + DisplayNameGenerator.parameterTypesAsString(testMethod);
+        }
+
+        String replaceCamelCase(String camelCase) {
+            StringBuilder result = new StringBuilder();
+            result.append(camelCase.charAt(0));
+            for (int i=1; i<camelCase.length(); i++) {
+                if (Character.isUpperCase(camelCase.charAt(i))) {
+                    result.append(' ');
+                    result.append(Character.toLowerCase(camelCase.charAt(i)));
+                } else {
+                    result.append(camelCase.charAt(i));
+                }
+            }
+            return result.toString();
+        }
+    }
+}

testing-modules/junit-5-basics/pom.xml

@@ -16,20 +16,10 @@
     </parent>
 
     <dependencies>
-        <dependency>
-            <groupId>org.junit.platform</groupId>
-            <artifactId>junit-platform-engine</artifactId>
-            <version>${junit.platform.version}</version>
-        </dependency>
-        <dependency>
-            <groupId>org.junit.jupiter</groupId>
-            <artifactId>junit-jupiter-params</artifactId>
-            <version>${junit.jupiter.version}</version>
-        </dependency>
         <dependency>
             <groupId>org.junit.platform</groupId>
             <artifactId>junit-platform-runner</artifactId>
-            <version>${junit.platform.version}</version>
+            <version>${junit-platform.version}</version>
             <scope>test</scope>
         </dependency>
         <dependency>
@@ -44,6 +34,24 @@
             <version>${junit.vintage.version}</version>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter-engine</artifactId>
+            <version>${junit-jupiter.version}</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter-params</artifactId>
+            <version>${junit-jupiter.version}</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter-api</artifactId>
+            <version>${junit-jupiter.version}</version>
+            <scope>test</scope>
+        </dependency>
         <dependency>
             <groupId>com.h2database</groupId>
             <artifactId>h2</artifactId>
@@ -92,13 +100,7 @@
                     <plugin>
                         <artifactId>maven-surefire-plugin</artifactId>
                         <version>${maven-surefire-plugin.version}</version>
-                        <dependencies>
+                        
-                            <dependency>
-                                <groupId>org.junit.platform</groupId>
-                                <artifactId>junit-platform-surefire-provider</artifactId>
-                                <version>${junit.platform.version}</version>
-                            </dependency>
-                        </dependencies>
                         <configuration>
                             <excludes>
                                 **/*IntegrationTest.java
@@ -148,9 +150,9 @@
     </profiles>
     
     <properties>
-        <junit.jupiter.version>5.4.2</junit.jupiter.version>
+        <junit.vintage.version>5.4.2</junit.vintage.version>
-        <junit.platform.version>1.2.0</junit.platform.version>
+        <junit-platform.version>1.2.0</junit-platform.version>
-        <junit.vintage.version>5.2.0</junit.vintage.version>
+        <junit-jupiter.version>5.4.2</junit-jupiter.version>
         <h2.version>1.4.196</h2.version>
         <spring.version>5.0.6.RELEASE</spring.version>
         <maven-surefire-plugin.version>2.21.0</maven-surefire-plugin.version>

testing-modules/junit-5-basics/src/test/java/com/baeldung/extensions/tempdir/SharedTemporaryDirectoryUnitTest.java

@@ -0,0 +1,49 @@
+package com.baeldung.extensions.tempdir;
+
+import static org.junit.Assert.assertTrue;
+import static org.junit.jupiter.api.Assertions.assertAll;
+import static org.junit.jupiter.api.Assertions.assertLinesMatch;
+
+import java.io.IOException;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.util.Arrays;
+import java.util.List;
+
+import org.junit.jupiter.api.Order;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.TestMethodOrder;
+import org.junit.jupiter.api.io.TempDir;
+
+import org.junit.jupiter.api.MethodOrderer.OrderAnnotation;
+
+@TestMethodOrder(OrderAnnotation.class)
+class SharedTemporaryDirectoryUnitTest {
+
+    @TempDir
+    static Path sharedTempDir;
+    
+    @Test
+    @Order(1)
+    void givenFieldWithSharedTempDirectoryPath_whenWriteToFile_thenContentIsCorrect() throws IOException {
+        Path numbers = sharedTempDir.resolve("numbers.txt");
+
+        List<String> lines = Arrays.asList("1", "2", "3");
+        Files.write(numbers, lines);
+
+        assertAll(
+            () -> assertTrue("File should exist", Files.exists(numbers)),
+            () -> assertLinesMatch(lines, Files.readAllLines(numbers)));
+        
+        Files.createTempDirectory("bpb");
+    }
+
+    @Test
+    @Order(2)
+    void givenAlreadyWrittenToSharedFile_whenCheckContents_thenContentIsCorrect() throws IOException {
+        Path numbers = sharedTempDir.resolve("numbers.txt");
+
+        assertLinesMatch(Arrays.asList("1", "2", "3"), Files.readAllLines(numbers));
+    }
+
+}

testing-modules/junit-5-basics/src/test/java/com/baeldung/extensions/tempdir/TemporaryDirectoryUnitTest.java

@@ -0,0 +1,48 @@
+package com.baeldung.extensions.tempdir;
+
+import static org.junit.Assert.assertTrue;
+import static org.junit.jupiter.api.Assertions.assertAll;
+import static org.junit.jupiter.api.Assertions.assertLinesMatch;
+
+import java.io.File;
+import java.io.IOException;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.util.Arrays;
+import java.util.List;
+
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.io.TempDir;
+
+class TemporaryDirectoryUnitTest {
+
+    @Test
+    void givenTestMethodWithTempDirectoryPath_whenWriteToFile_thenContentIsCorrect(@TempDir Path tempDir) throws IOException {
+        Path numbers = tempDir.resolve("numbers.txt");
+
+        List<String> lines = Arrays.asList("1", "2", "3");
+        Files.write(numbers, lines);
+
+        assertAll(
+            () -> assertTrue("File should exist", Files.exists(numbers)),
+            () -> assertLinesMatch(lines, Files.readAllLines(numbers)));
+    }
+
+    @TempDir
+    File anotherTempDir;
+
+    @Test
+    void givenFieldWithTempDirectoryFile_whenWriteToFile_thenContentIsCorrect() throws IOException {
+        assertTrue("Should be a directory ", this.anotherTempDir.isDirectory());
+
+        File letters = new File(anotherTempDir, "letters.txt");
+        List<String> lines = Arrays.asList("x", "y", "z");
+
+        Files.write(letters.toPath(), lines);
+        
+        assertAll(
+            () -> assertTrue("File should exist", Files.exists(letters.toPath())),
+            () -> assertLinesMatch(lines, Files.readAllLines(letters.toPath())));
+    }
+
+}

testing-modules/pom.xml

@@ -33,5 +33,6 @@
         <module>testing</module>
         <module>testng</module>
         <module>junit-5-basics</module>
+        <module>junit-5-advanced</module>
     </modules>
 </project>