adding IPC style interactions (#43)

* adding IPC style interactions

* fix typo

* typos

* graphql support using ipc code

* clean up conversion to mono, removed some duplicate code

* remove java 11 specific api

* add tracing and metrics support

* add the ability to replace marshaller / unmarshaller at function level

* adding graphql version

* updates to the latest gradle version and fix jdk-8 compilation issue

* fixes jdk path for windows build

Author: robertroeser

.travis.yml

@@ -23,7 +23,7 @@ jobs:
     - rm -r "/c/Program Files (x86)/Microsoft Visual Studio 14.0"
     - export PATH=$PATH:"/c/Program Files (x86)/Microsoft Visual Studio/2017/BuildTools/VC/Tools/MSVC/14.16.27023/bin/HostX86/x64"
     - choco install -y adoptopenjdk8
-    - export PATH=$PATH:"/c/Program Files/AdoptOpenJDK/jdk8u222-b10/bin"
+    - export PATH=$PATH:"/c/Program Files/AdoptOpenJDK/jdk-8.0.222.10-hotspot/bin"
     - wget https://github.com/google/protobuf/releases/download/v3.6.1/protobuf-cpp-3.6.1.tar.gz
     - tar -xzf protobuf-cpp-3.6.1.tar.gz
     - pushd protobuf-3.6.1/cmake

build.gradle

@@ -14,7 +14,7 @@ apply from: 'artifactory.gradle'
 apply from: 'bintray.gradle'
 apply from: 'publication.gradle'
 
-buildScan {     
+buildScan {
     termsOfServiceUrl = 'https://gradle.com/terms-of-service'
     termsOfServiceAgree = 'yes'
 }
@@ -36,7 +36,7 @@ subprojects {
 
     ext['reactor-bom.version'] = 'Dysprosium-RELEASE'
     ext['rsocket.version'] = '1.0.0-RC5'
-
+    ext['graphql.version'] = '11.0'
     ext['protobuf.version'] = '3.6.1'
     ext['log4j.version'] = '2.11.2'
     ext['slf4j.version'] = '1.8.0-beta2'

gradle/wrapper/gradle-wrapper.properties

@@ -1,5 +1,5 @@
 distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
-distributionUrl=https\://services.gradle.org/distributions/gradle-5.2.1-bin.zip
+distributionUrl=https\://services.gradle.org/distributions/gradle-5.6.2-bin.zip
 zipStoreBase=GRADLE_USER_HOME
 zipStorePath=wrapper/dists

rsocket-ipc-core/build.gradle

@@ -0,0 +1,95 @@
+plugins {
+    id 'io.spring.dependency-management' version '1.0.7.RELEASE'
+}
+
+description = 'RSocket IPC Library'
+
+dependencies {
+    compile project (':rsocket-rpc-core')
+    implementation 'org.slf4j:slf4j-api'
+
+    api 'io.opentracing:opentracing-api'
+    api 'javax.inject:javax.inject'
+    api 'javax.annotation:javax.annotation-api'
+    api 'io.rsocket:rsocket-core'
+    api 'io.micrometer:micrometer-core'
+
+    testImplementation 'io.opentracing.brave:brave-opentracing'
+    testImplementation 'junit:junit'
+
+    testImplementation 'javax.inject:javax.inject'
+    testImplementation 'io.projectreactor:reactor-test'
+    testImplementation 'com.google.protobuf:protobuf-java'
+    testImplementation 'org.hdrhistogram:HdrHistogram'
+    testImplementation 'org.apache.logging.log4j:log4j-api'
+    testImplementation 'org.apache.logging.log4j:log4j-core'
+    testImplementation 'org.apache.logging.log4j:log4j-slf4j-impl'
+    testImplementation 'io.rsocket:rsocket-transport-netty'
+    testImplementation 'io.rsocket:rsocket-transport-local'
+    testImplementation 'org.mockito:mockito-core'
+    testImplementation 'io.zipkin.reporter2:zipkin-sender-okhttp3'
+}
+
+dependencyManagement {
+    imports {
+        mavenBom "io.projectreactor:reactor-bom:${ext['reactor-bom.version']}"
+    }
+
+    dependencies {
+        dependencySet(group: 'com.google.protobuf', version: ext['protobuf.version']) {
+            entry 'protobuf-java'
+            entry 'protoc'
+        }
+        dependency "com.google.protobuf:protoc:${ext['protobuf.version']}"
+
+        dependency "javax.inject:javax.inject:1"
+        dependency "javax.annotation:javax.annotation-api:1.2"
+
+        dependencySet(group: 'org.apache.logging.log4j', version: ext['log4j.version']) {
+            entry "log4j-api"
+            entry "log4j-core"
+            entry "log4j-slf4j-impl"
+        }
+
+        dependency "org.slf4j:slf4j-api:${ext['slf4j.version']}"
+        dependency "org.slf4j:slf4j-simple:${ext['slf4j.version']}"
+
+        dependencySet(group: 'io.rsocket', version: ext['rsocket.version']) {
+            entry 'rsocket-core'
+            entry 'rsocket-transport-netty'
+            entry 'rsocket-transport-local'
+        }
+
+        dependency "io.micrometer:micrometer-core:${ext['micrometer.version']}"
+        dependency "io.opentracing:opentracing-api:${ext['opentracing.version']}"
+        dependency "io.opentracing.brave:brave-opentracing:${ext['opentracing.brave.version']}"
+        dependency "io.zipkin.reporter2:zipkin-sender-okhttp3:${ext['zipkin.sender.version']}"
+
+        // TODO: Remove after JUnit5 migration
+        // TEST DEPENDENCIES
+
+        dependency 'junit:junit:4.12'
+
+        dependencySet(group: 'org.junit.jupiter', version: ext['junit.version']) {
+            entry 'junit-jupiter-api'
+            entry 'junit-jupiter-engine'
+            entry 'junit-jupiter-params'
+        }
+
+
+        dependency "org.mockito:mockito-core:${ext['mockito.version']}"
+        dependency "org.hamcrest:hamcrest-library:${ext['hamcrest.version']}"
+        dependency "org.assertj:assertj-core:${ext['assertj.version']}"
+        dependency "org.hdrhistogram:HdrHistogram:${ext['hdrhistogram.version']}"
+
+
+        dependencySet(group: 'org.junit.vintage', version: ext['junit.version']) {
+            entry 'junit-vintage-engine'
+        }
+
+        dependencySet(group: 'org.openjdk.jmh', version: ext['jmh.version']) {
+            entry 'jmh-core'
+            entry 'jmh-generator-annprocess'
+        }
+    }
+}