diff --git a/jgroups-spring-boot-autoconfigure/src/main/java/org/axonframework/extensions/jgroups/autoconfig/JGroupsAutoConfiguration.java b/jgroups-spring-boot-autoconfigure/src/main/java/org/axonframework/extensions/jgroups/autoconfig/JGroupsAutoConfiguration.java
index 563d097..b4f40af 100644
--- a/jgroups-spring-boot-autoconfigure/src/main/java/org/axonframework/extensions/jgroups/autoconfig/JGroupsAutoConfiguration.java
+++ b/jgroups-spring-boot-autoconfigure/src/main/java/org/axonframework/extensions/jgroups/autoconfig/JGroupsAutoConfiguration.java
@@ -64,7 +64,7 @@ public class JGroupsAutoConfiguration {
@ConditionalOnProperty("axon.distributed.jgroups.gossip.autoStart")
@Bean(destroyMethod = "stop")
- public GossipRouter gossipRouter() {
+ public GossipRouter gossipRouter() throws Exception {
Matcher matcher =
Pattern.compile("([^[\\[]]*)\\[(\\d*)\\]").matcher(properties.getJgroups().getGossip().getHosts());
if (matcher.find()) {
diff --git a/jgroups-spring-boot-autoconfigure/src/main/resources/default_tcp_gossip.xml b/jgroups-spring-boot-autoconfigure/src/main/resources/default_tcp_gossip.xml
index 146f773..65fddac 100644
--- a/jgroups-spring-boot-autoconfigure/src/main/resources/default_tcp_gossip.xml
+++ b/jgroups-spring-boot-autoconfigure/src/main/resources/default_tcp_gossip.xml
@@ -20,7 +20,8 @@
sock_conn_timeout="300"/>
-
+
+
diff --git a/jgroups/src/main/java/org/axonframework/extensions/jgroups/commandhandling/JGroupsConnector.java b/jgroups/src/main/java/org/axonframework/extensions/jgroups/commandhandling/JGroupsConnector.java
index e4237ed..959bcc4 100644
--- a/jgroups/src/main/java/org/axonframework/extensions/jgroups/commandhandling/JGroupsConnector.java
+++ b/jgroups/src/main/java/org/axonframework/extensions/jgroups/commandhandling/JGroupsConnector.java
@@ -46,11 +46,7 @@
import org.axonframework.tracing.Span;
import org.axonframework.tracing.SpanFactory;
import org.axonframework.tracing.SpanScope;
-import org.jgroups.Address;
-import org.jgroups.JChannel;
-import org.jgroups.Message;
-import org.jgroups.Receiver;
-import org.jgroups.View;
+import org.jgroups.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -292,21 +288,6 @@ public synchronized void viewAccepted(final View view) {
currentView = view;
}
- @Override
- public void suspect(Address suspectedMember) {
- logger.warn("Member is suspect: {}", suspectedMember);
- }
-
- @Override
- public void block() {
- //We are not going to block
- }
-
- @Override
- public void unblock() {
- //We are not going to block
- }
-
@Override
public void receive(Message msg) {
executorService.execute(() -> {
@@ -444,7 +425,7 @@ private void sendMyConfigurationTo(Address endpoint, boolean expectReply, int or
try {
logger.info("Sending my configuration to {}.", getOrDefault(endpoint, "all nodes"));
Message returnJoinMessage =
- new Message(endpoint, new JoinMessage(this.loadFactor, this.commandFilter, order, expectReply));
+ new ObjectMessage(endpoint, new JoinMessage(this.loadFactor, this.commandFilter, order, expectReply));
returnJoinMessage.setFlag(Message.Flag.OOB);
channel.send(returnJoinMessage);
} catch (Exception e) {
diff --git a/jgroups/src/test/java/org/axonframework/extensions/jgroups/commandhandling/JGroupsConnectorTest.java b/jgroups/src/test/java/org/axonframework/extensions/jgroups/commandhandling/JGroupsConnectorTest.java
index d8e5681..808aa88 100644
--- a/jgroups/src/test/java/org/axonframework/extensions/jgroups/commandhandling/JGroupsConnectorTest.java
+++ b/jgroups/src/test/java/org/axonframework/extensions/jgroups/commandhandling/JGroupsConnectorTest.java
@@ -41,6 +41,7 @@
import org.jgroups.Address;
import org.jgroups.JChannel;
import org.jgroups.Message;
+import org.jgroups.ObjectMessage;
import org.jgroups.stack.IpAddress;
import org.junit.jupiter.api.*;
@@ -228,7 +229,7 @@ void messagesReceivedPromptlyAfterConnectingDoesntCauseException() throws Except
.build();
doAnswer(i -> {
- connector1.receive(new Message(
+ connector1.receive(new ObjectMessage(
null,
new JoinMessage(100, new CommandNameFilter("test"), 0, false)).setSrc(channel2.address())
);
@@ -296,7 +297,7 @@ void joinMessageReceivedForDisconnectedHost() throws Exception {
waitForConnectorSync();
// secretly insert an illegal message
- Message message = new Message(channel1.getAddress(),
+ Message message = new ObjectMessage(channel1.getAddress(),
new JoinMessage(10, DenyAll.INSTANCE, 0, true));
message.setSrc(new IpAddress(12345));
channel1.getReceiver().receive(message);
diff --git a/jgroups/src/test/resources/org/axonframework/extensions/jgroups/commandhandling/tcp_gossip.xml b/jgroups/src/test/resources/org/axonframework/extensions/jgroups/commandhandling/tcp_gossip.xml
index 65a6c5e..345b795 100644
--- a/jgroups/src/test/resources/org/axonframework/extensions/jgroups/commandhandling/tcp_gossip.xml
+++ b/jgroups/src/test/resources/org/axonframework/extensions/jgroups/commandhandling/tcp_gossip.xml
@@ -31,7 +31,8 @@
sock_conn_timeout="300"/>
-
+
+
diff --git a/jgroups/src/test/resources/org/axonframework/extensions/jgroups/commandhandling/tcp_mcast.xml b/jgroups/src/test/resources/org/axonframework/extensions/jgroups/commandhandling/tcp_mcast.xml
index 8c5fa00..a6ab3f2 100644
--- a/jgroups/src/test/resources/org/axonframework/extensions/jgroups/commandhandling/tcp_mcast.xml
+++ b/jgroups/src/test/resources/org/axonframework/extensions/jgroups/commandhandling/tcp_mcast.xml
@@ -32,7 +32,6 @@
ucast_send_buf_size="5M"
mcast_recv_buf_size="5M"
mcast_send_buf_size="5M"
- max_bundle_size="64K"
max_bundle_timeout="30"
enable_diagnostics="true"
thread_naming_pattern="cl"
@@ -82,7 +81,7 @@
+ />
-
+
-
+ />
diff --git a/pom.xml b/pom.xml
index 4ed6d89..9c3feb6 100644
--- a/pom.xml
+++ b/pom.xml
@@ -53,7 +53,7 @@
4.12.0
- 4.2.30.Final
+ 5.5.2.Final
5.3.39
2.7.18