ClusterRequest should always return the same connection.

codingchili · Apr 29, 2018 · 992930e · 992930e
1 parent e9eca90
commit 992930e
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 4 deletions.
diff --git a/build.gradle b/build.gradle
@@ -2,7 +2,7 @@ apply plugin: 'java'
 apply plugin: 'idea'
 apply plugin: 'maven'
 
-project.version = "1.0.32-SNAPSHOT"
+project.version = "1.0.33-SNAPSHOT"
 project.group = 'com.github.codingchili.chili-core'
 
 subprojects {

diff --git a/core/main/java/com/codingchili/core/listener/transport/ClusterRequest.java b/core/main/java/com/codingchili/core/listener/transport/ClusterRequest.java
@@ -54,9 +54,12 @@ public void write(Object msg) {
 
     @Override
     public Connection connection() {
-        return new Connection((message) -> {
-            throw new UnsupportedOperationException("Cannot write to the connection of Cluster requests, use #write instead.");
-        }, "");
+        if (connection == null) {
+            connection = new Connection((message) -> {
+                throw new UnsupportedOperationException("Cannot write to the connection of Cluster requests, use #write instead.");
+            }, "");
+        }
+        return connection;
     }
 
     @Override