Upgrade Netty version to latest stable.

neo4j · Nov 11, 2016 · 558a9d3 · 558a9d3
1 parent b3758ac
commit 558a9d3
Show file tree

Hide file tree

Showing 6 changed files with 13 additions and 13 deletions.
diff --git a/...g/neo4j/causalclustering/catchup/storecopy/StoreCopyFinishedResponseEncodeDecodeTest.java b/...g/neo4j/causalclustering/catchup/storecopy/StoreCopyFinishedResponseEncodeDecodeTest.java
@@ -40,7 +40,7 @@ public void shouldEncodeAndDecodePullRequestMessage()
 
         // when
         channel.writeOutbound( sent );
-        channel.writeInbound( channel.readOutbound() );
+        channel.writeInbound( new Object[]{channel.readOutbound()} );
 
         // then
         StoreCopyFinishedResponse received = (StoreCopyFinishedResponse) channel.readInbound();

diff --git a/...ng/src/test/java/org/neo4j/causalclustering/catchup/tx/TxPullRequestEncodeDecodeTest.java b/...ng/src/test/java/org/neo4j/causalclustering/catchup/tx/TxPullRequestEncodeDecodeTest.java
@@ -39,7 +39,7 @@ public void shouldEncodeAndDecodePullRequestMessage()
 
         // when
         channel.writeOutbound( sent );
-        channel.writeInbound( channel.readOutbound() );
+        channel.writeInbound( new Object[]{channel.readOutbound()} );
 
         // then
         TxPullRequest received = (TxPullRequest) channel.readInbound();

diff --git a/...g/src/test/java/org/neo4j/causalclustering/catchup/tx/TxPullResponseEncodeDecodeTest.java b/...g/src/test/java/org/neo4j/causalclustering/catchup/tx/TxPullResponseEncodeDecodeTest.java
@@ -47,7 +47,7 @@ public void shouldEncodeAndDecodePullResponseMessage()
 
         // when
         channel.writeOutbound( sent );
-        channel.writeInbound( channel.readOutbound() );
+        channel.writeInbound( new Object[]{channel.readOutbound()} );
 
         // then
         TxPullResponse received = (TxPullResponse) channel.readInbound();

diff --git a/.../java/org/neo4j/causalclustering/catchup/tx/TxStreamFinishedResponseEncodeDecodeTest.java b/.../java/org/neo4j/causalclustering/catchup/tx/TxStreamFinishedResponseEncodeDecodeTest.java
@@ -38,7 +38,7 @@ public void shouldEncodeAndDecodePullRequestMessage()
 
         // when
         channel.writeOutbound( sent );
-        channel.writeInbound( channel.readOutbound() );
+        channel.writeInbound( new Object[]{channel.readOutbound()} );
 
         // then
         TxStreamFinishedResponse received = (TxStreamFinishedResponse) channel.readInbound();

diff --git a/...stering/src/test/java/org/neo4j/causalclustering/messaging/RaftMessageProcessingTest.java b/...stering/src/test/java/org/neo4j/causalclustering/messaging/RaftMessageProcessingTest.java
@@ -31,12 +31,12 @@
 import org.neo4j.causalclustering.core.consensus.RaftMessages;
 import org.neo4j.causalclustering.core.consensus.ReplicatedInteger;
 import org.neo4j.causalclustering.core.consensus.log.RaftLogEntry;
-import org.neo4j.causalclustering.messaging.marshalling.RaftMessageDecoder;
-import org.neo4j.causalclustering.messaging.marshalling.RaftMessageEncoder;
 import org.neo4j.causalclustering.core.replication.ReplicatedContent;
-import org.neo4j.causalclustering.messaging.marshalling.ChannelMarshal;
 import org.neo4j.causalclustering.core.state.storage.SafeChannelMarshal;
 import org.neo4j.causalclustering.identity.MemberId;
+import org.neo4j.causalclustering.messaging.marshalling.ChannelMarshal;
+import org.neo4j.causalclustering.messaging.marshalling.RaftMessageDecoder;
+import org.neo4j.causalclustering.messaging.marshalling.RaftMessageEncoder;
 import org.neo4j.storageengine.api.ReadPastEndException;
 import org.neo4j.storageengine.api.ReadableChannel;
 import org.neo4j.storageengine.api.WritableChannel;
@@ -106,7 +106,7 @@ public void shouldEncodeAndDecodeVoteRequest()
 
         // when
         channel.writeOutbound( request );
-        channel.writeInbound( channel.readOutbound() );
+        channel.writeInbound( new Object[]{channel.readOutbound()} );
 
         // then
         assertEquals( request, channel.readInbound() );
@@ -121,7 +121,7 @@ public void shouldEncodeAndDecodeVoteResponse()
 
         // when
         channel.writeOutbound( response );
-        channel.writeInbound( channel.readOutbound() );
+        channel.writeInbound( new Object[]{channel.readOutbound()} );
 
         // then
         assertEquals( response, channel.readInbound() );
@@ -138,7 +138,7 @@ public void shouldEncodeAndDecodeAppendEntriesRequest()
 
         // when
         channel.writeOutbound( request );
-        channel.writeInbound( channel.readOutbound() );
+        channel.writeInbound( new Object[]{channel.readOutbound()} );
 
         // then
         assertEquals( request, channel.readInbound() );
@@ -154,7 +154,7 @@ public void shouldEncodeAndDecodeAppendEntriesResponse()
 
         // when
         channel.writeOutbound( response );
-        channel.writeInbound( channel.readOutbound() );
+        channel.writeInbound( new Object[]{channel.readOutbound()} );
 
         // then
         assertEquals( response, channel.readInbound() );
@@ -170,7 +170,7 @@ public void shouldEncodeAndDecodeNewEntryRequest()
 
         // when
         channel.writeOutbound( request );
-        channel.writeInbound( channel.readOutbound() );
+        channel.writeInbound( new Object[]{channel.readOutbound()} );
 
         // then
         assertEquals( request, channel.readInbound() );

diff --git a/pom.xml b/pom.xml
@@ -499,7 +499,7 @@
       <dependency>
         <groupId>io.netty</groupId>
         <artifactId>netty-all</artifactId>
-        <version>4.0.40.Final</version>
+        <version>4.1.6.Final</version>
       </dependency>
 
       <dependency>