Feature/reactor module

build.gradle

@@ -1,24 +1,10 @@
-buildscript {
-    repositories {
-        mavenCentral()
-    }
-    dependencies {
-        classpath 'biz.aQute.bnd:biz.aQute.bnd.gradle:4.2.0'
-    }
-}
-
 plugins {
-    id 'com.github.johnrengelman.shadow' version '4.0.4' apply false
-    id 'biz.aQute.bnd.builder' version '4.2.0' apply false
-    id 'com.github.hierynomus.license' version '0.14.0' apply false
-    id 'com.jfrog.bintray' version '1.8.4' apply false
-    id 'com.github.breadmoirai.github-release' version '2.2.9' apply false
-}
-
-allprojects {
-    repositories {
-        mavenCentral()
-    }
+    id 'java-library'
+    id 'com.github.johnrengelman.shadow'
+    id 'biz.aQute.bnd.builder' apply false
+    id 'com.github.hierynomus.license' apply false
+    id 'com.jfrog.bintray' apply false
+    id 'com.github.breadmoirai.github-release' apply false
 }
 
 
@@ -53,22 +39,25 @@ allprojects {
 /* ******************** java ******************** */
 
 allprojects {
-    apply plugin: 'java'
-
-    sourceCompatibility = JavaVersion.VERSION_1_8
-    targetCompatibility = JavaVersion.VERSION_1_8
+    plugins.withType(JavaPlugin) {
+        sourceCompatibility = JavaVersion.VERSION_1_8
+        targetCompatibility = JavaVersion.VERSION_1_8
 
-    tasks.withType(JavaCompile) {
-        options.encoding = 'UTF-8'
+        tasks.withType(JavaCompile) {
+            options.encoding = 'UTF-8'
+        }
     }
 }
 
-apply plugin: 'java-library'
-apply plugin: 'com.github.johnrengelman.shadow'
-
 
 /* ******************** dependencies ******************** */
 
+allprojects {
+    repositories {
+        mavenCentral()
+    }
+}
+
 ext {
     rxJavaVersion = '2.2.5'
     nettyVersion = '4.1.32.Final'
@@ -117,20 +106,22 @@ dependencies {
 /* ******************** test ******************** */
 
 allprojects {
-    dependencies {
-        def junit5Version = '5.5.1'
-        def junitPlatformVersion = '1.5.1'
-
-        testImplementation group: 'org.junit.jupiter', name: 'junit-jupiter-api', version: junit5Version
-        testImplementation group: 'org.junit.jupiter', name: 'junit-jupiter-params', version: junit5Version
-        testRuntimeOnly group: 'org.junit.jupiter', name: 'junit-jupiter-engine', version: junit5Version
-        testRuntimeOnly group: 'org.junit.platform', name: 'junit-platform-launcher', version: junitPlatformVersion
-    }
+    plugins.withType(JavaPlugin) {
+        dependencies {
+            def junit5Version = '5.5.1'
+            def junitPlatformVersion = '1.5.1'
+
+            testImplementation group: 'org.junit.jupiter', name: 'junit-jupiter-api', version: junit5Version
+            testImplementation group: 'org.junit.jupiter', name: 'junit-jupiter-params', version: junit5Version
+            testRuntimeOnly group: 'org.junit.jupiter', name: 'junit-jupiter-engine',  version: junit5Version
+            testRuntimeOnly group: 'org.junit.platform', name: 'junit-platform-launcher', version: junitPlatformVersion
+        }
 
-    test {
-        useJUnitPlatform()
-        maxHeapSize = '4096m'
-        jvmArgs '-XX:+UseParallelGC'
+        test {
+            useJUnitPlatform()
+            maxHeapSize = '4096m'
+            jvmArgs '-XX:+UseParallelGC'
+        }
     }
 }
 
@@ -176,7 +167,7 @@ allprojects {
             group 'documentation'
             description 'Assembles a jar archive containing the javadoc.'
 
-            from javadoc
+            from tasks.javadoc
             classifier 'javadoc'
         }
 
@@ -261,49 +252,49 @@ allprojects {
                     }
                 }
                 normal(MavenPublication) {
-                    from project.components.java
-                    artifact project.tasks.javadocJar
-                    artifact project.tasks.sourcesJar
+                    from components.java
+                    artifact tasks.javadocJar
+                    artifact tasks.sourcesJar
                     suppressAllPomMetadataWarnings()
                 }
             }
         }
 
         project.apply plugin: 'com.jfrog.bintray'
 
-        afterEvaluate {
-            bintray {
-                user = project.bintray_username
-                key = project.bintray_apiKey
-                publications = publishing.publications.withType(MavenPublication).stream().collect { it.name }
-                publish = true
-                pkg {
-                    userOrg = 'hivemq'
-                    repo = 'HiveMQ'
-                    name = 'hivemq-mqtt-client'
-                    desc = project.description
-                    websiteUrl = project.githubUrl
-                    issueTrackerUrl = project.issuesUrl
-                    vcsUrl = project.githubUrl + '.git'
-                    licenses = [project.licenseShortName]
-                    labels = ['mqtt', 'mqtt-client', 'iot', 'internet-of-things', 'rxjava2', 'reactive-streams', 'backpressure']
-                    version {
-                        released = new Date()
-                        gpg {
-                            sign = true
-                        }
-                        /*mavenCentralSync {
-                            user = ''
-                            password = ''
-                        }*/
+        bintray {
+            user = project.bintray_username
+            key = project.bintray_apiKey
+            publish = true
+            pkg {
+                userOrg = 'hivemq'
+                repo = 'HiveMQ'
+                name = 'hivemq-mqtt-client'
+                desc = project.description
+                websiteUrl = project.githubUrl
+                issueTrackerUrl = project.issuesUrl
+                vcsUrl = project.githubUrl + '.git'
+                licenses = [project.licenseShortName]
+                labels = ['mqtt', 'mqtt-client', 'iot', 'internet-of-things', 'rxjava2', 'reactive-streams', 'backpressure']
+                version {
+                    released = new Date()
+                    gpg {
+                        sign = true
                     }
+                    /*mavenCentralSync {
+                        user = ''
+                        password = ''
+                    }*/
                 }
             }
         }
+        afterEvaluate {
+            bintray.publications = publishing.publications.withType(MavenPublication).stream().collect { it.name }
+        }
 
         // workaround for publishing gradle metadata https://github.com/bintray/gradle-bintray-plugin/issues/229
         //noinspection UnnecessaryQualifiedReference
-        project.tasks.withType(com.jfrog.bintray.gradle.tasks.BintrayUploadTask) {
+        tasks.withType(com.jfrog.bintray.gradle.tasks.BintrayUploadTask) {
             doFirst {
                 publishing.publications.withType(MavenPublication).each { publication ->
                     def moduleFile = new File(new File(new File(project.buildDir, 'publications'), publication.name), 'module.json')
@@ -322,13 +313,13 @@ allprojects {
             publications {
                 shaded(MavenPublication) {
                     artifactId project.name + '-' + project.shadedAppendix
-                    artifact project.tasks.shadowJar
-                    artifact project.tasks.javadocJar
-                    artifact project.tasks.sourcesJar
+                    artifact tasks.shadowJar
+                    artifact tasks.javadocJar
+                    artifact tasks.sourcesJar
                     pom.withXml {
                         def dependenciesNode = asNode().appendNode('dependencies')
 
-                        project.configurations.api.allDependencies.each {
+                        configurations.api.allDependencies.each {
                             def dependencyNode = dependenciesNode.appendNode('dependency')
                             dependencyNode.appendNode('groupId', it.group)
                             dependencyNode.appendNode('artifactId', it.name)
@@ -356,7 +347,7 @@ features.each { feature ->
                     rootDependencyNode.appendNode('version', project.version)
                     rootDependencyNode.appendNode('scope', 'compile')
 
-                    project.configurations.getByName(feature + 'Implementation').allDependencies.each {
+                    configurations.getByName(feature + 'Implementation').allDependencies.each {
                         def dependencyNode = dependenciesNode.appendNode('dependency')
                         dependencyNode.appendNode('groupId', it.group)
                         dependencyNode.appendNode('artifactId', it.name)

examples/build.gradle

@@ -1,4 +1,8 @@
-description 'HiveMQ MQTT Client examples'
+plugins {
+    id 'java'
+}
+
+description 'Examples using the HiveMQ MQTT Client'
 
 ext {
     moduleName = 'com.hivemq.client.mqtt.examples'

examples/src/main/java/com/hivemq/client/mqtt/examples/ReconnectStrategy.java

@@ -73,7 +73,7 @@ private static void completelyCustom() {
                 .addDisconnectedListener(context -> {
                     context.getReconnector()
                             .reconnect(true) // always reconnect (includes calling disconnect)
-                            .delay(2 * context.getReconnector().getAttempts(), TimeUnit.SECONDS); // linear scaling delay
+                            .delay(2L * context.getReconnector().getAttempts(), TimeUnit.SECONDS); // linear scaling delay
                 })
                 // multiple DisconnectedListener can form a reconnect strategy
                 .addDisconnectedListener(context -> {