WIP: MP Reactive Messaging POC

bom/pom.xml

@@ -441,6 +441,11 @@
                 <artifactId>helidon-microprofile-access-log</artifactId>
                 <version>${helidon.version}</version>
             </dependency>
+            <dependency>
+                <groupId>io.helidon.microprofile</groupId>
+                <artifactId>helidon-microprofile-reactive-streams</artifactId>
+                <version>${helidon.version}</version>
+            </dependency>
             <!-- metrics -->
             <dependency>
                 <groupId>io.helidon.metrics</groupId>

common/reactive/pom.xml

@@ -1,7 +1,7 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!--
 
-    Copyright (c) 2018, 2019 Oracle and/or its affiliates. All rights reserved.
+    Copyright (c) 2018, 2020 Oracle and/or its affiliates. All rights reserved.
 
     Licensed under the Apache License, Version 2.0 (the "License");
     you may not use this file except in compliance with the License.
@@ -28,10 +28,6 @@
     <artifactId>helidon-common-reactive</artifactId>
     <name>Helidon Common Reactive</name>
 
-    <properties>
-        <spotbugs.exclude>etc/spotbugs/exclude.xml</spotbugs.exclude>
-    </properties>
-
     <build>
         <plugins>
             <plugin>

common/reactive/src/main/java/io/helidon/common/reactive/BackPressureOverflowException.java

@@ -0,0 +1,33 @@
+/*
+ * Copyright (c)  2020 Oracle and/or its affiliates. All rights reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+package io.helidon.common.reactive;
+
+/**
+ * Raised when back-pressure buffer overflows.
+ */
+public class BackPressureOverflowException extends Exception {
+
+    /**
+     * Create new {@link BackPressureOverflowException}.
+     *
+     * @param limit Overflown limit
+     */
+    public BackPressureOverflowException(int limit) {
+        super(String.format("Buffer limit %d exceeded.", limit));
+    }
+}