diff --git a/.idea/libraries/jgroups.xml b/.idea/libraries/jgroups.xml
index 8467733db7a..5ac32951af5 100644
--- a/.idea/libraries/jgroups.xml
+++ b/.idea/libraries/jgroups.xml
@@ -1,11 +1,9 @@
-
+
-
-
-
+
\ No newline at end of file
diff --git a/modules/elasticsearch/build.gradle b/modules/elasticsearch/build.gradle
index 62c9c1e8705..7a2c0a9ad6f 100644
--- a/modules/elasticsearch/build.gradle
+++ b/modules/elasticsearch/build.gradle
@@ -50,7 +50,7 @@ dependencies {
compile 'org.apache.lucene:lucene-analyzers:3.0.0'
compile 'org.apache.lucene:lucene-queries:3.0.0'
- compile('jgroups:jgroups:2.8.0.GA') { transitive = false }
+ compile('jgroups:jgroups:2.9.0.GA') { transitive = false }
compile('org.jboss.netty:netty:3.1.5.GA') { transitive = false }
testCompile project(':test-testng')
diff --git a/modules/elasticsearch/src/main/java/config/jgroups/tcp-nio.xml b/modules/elasticsearch/src/main/java/config/jgroups/tcp-nio.xml
index c71406eb511..4e3d04c812b 100644
--- a/modules/elasticsearch/src/main/java/config/jgroups/tcp-nio.xml
+++ b/modules/elasticsearch/src/main/java/config/jgroups/tcp-nio.xml
@@ -7,6 +7,8 @@
multicasting cannot be used in a network, e.g. because it is disabled (routers discard multicast).
Note that TCP.bind_addr and TCPPING.initial_hosts should be set, possibly via system properties, e.g.
-Djgroups.bind_addr=192.168.5.2 and -Djgroups.tcpping.initial_hosts=192.168.5.2[7800]".
+ author: Bela Ban
+ version: $Id: tcp-nio.xml,v 1.19 2009/12/11 10:45:19 belaban Exp $
-->
+ max_bytes="400K"/>
-
-
+
-
\ No newline at end of file
+
diff --git a/modules/elasticsearch/src/main/java/config/jgroups/tcpgossip.xml b/modules/elasticsearch/src/main/java/config/jgroups/tcpgossip.xml
index ad87ae618bd..937e9306a16 100644
--- a/modules/elasticsearch/src/main/java/config/jgroups/tcpgossip.xml
+++ b/modules/elasticsearch/src/main/java/config/jgroups/tcpgossip.xml
@@ -1,3 +1,6 @@
+
+
+
@@ -6,7 +9,7 @@
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="urn:org:jgroups http://www.jgroups.org/schema/JGroups-2.8.xsd">
-
+
@@ -14,7 +17,7 @@
-
+
diff --git a/modules/elasticsearch/src/main/java/config/jgroups/udp.xml b/modules/elasticsearch/src/main/java/config/jgroups/udp.xml
index a8b232210d8..cc1bd717c3e 100644
--- a/modules/elasticsearch/src/main/java/config/jgroups/udp.xml
+++ b/modules/elasticsearch/src/main/java/config/jgroups/udp.xml
@@ -1,30 +1,33 @@
-
+
+
+ max_bytes="1M"/>
-
-
+
-
+
diff --git a/modules/elasticsearch/src/main/java/org/elasticsearch/discovery/jgroups/JgroupsDiscovery.java b/modules/elasticsearch/src/main/java/org/elasticsearch/discovery/jgroups/JgroupsDiscovery.java
index 4d1129a72c6..fadcb9eb57a 100644
--- a/modules/elasticsearch/src/main/java/org/elasticsearch/discovery/jgroups/JgroupsDiscovery.java
+++ b/modules/elasticsearch/src/main/java/org/elasticsearch/discovery/jgroups/JgroupsDiscovery.java
@@ -29,7 +29,6 @@ import org.elasticsearch.discovery.Discovery;
import org.elasticsearch.discovery.DiscoveryException;
import org.elasticsearch.discovery.InitialStateDiscoveryListener;
import org.elasticsearch.env.Environment;
-import org.elasticsearch.threadpool.ThreadPool;
import org.elasticsearch.transport.TransportService;
import org.elasticsearch.util.component.AbstractComponent;
import org.elasticsearch.util.component.Lifecycle;
@@ -66,8 +65,6 @@ public class JgroupsDiscovery extends AbstractComponent implements Discovery, Re
private final ClusterName clusterName;
- private final ThreadPool threadPool;
-
private final TransportService transportService;
private final ClusterService clusterService;
@@ -85,10 +82,9 @@ public class JgroupsDiscovery extends AbstractComponent implements Discovery, Re
private final CopyOnWriteArrayList initialStateListeners = new CopyOnWriteArrayList();
@Inject public JgroupsDiscovery(Settings settings, Environment environment, ClusterName clusterName,
- ThreadPool threadPool, TransportService transportService, ClusterService clusterService) {
+ TransportService transportService, ClusterService clusterService) {
super(settings);
this.clusterName = clusterName;
- this.threadPool = threadPool;
this.transportService = transportService;
this.clusterService = clusterService;