Skip to content

Commit 6bbb344

Browse files
authored
Merge pull request #530 from lutovich/1.7-composite_cumulator
Use composite cumulator for message decoding
2 parents 9b49898 + 3d56c39 commit 6bbb344

File tree

1 file changed

+17
-0
lines changed

1 file changed

+17
-0
lines changed

driver/src/main/java/org/neo4j/driver/internal/async/inbound/MessageDecoder.java

Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -26,8 +26,15 @@
2626

2727
public class MessageDecoder extends ByteToMessageDecoder
2828
{
29+
private static final Cumulator DEFAULT_CUMULATOR = determineDefaultCumulator();
30+
2931
private boolean readMessageBoundary;
3032

33+
public MessageDecoder()
34+
{
35+
setCumulator( DEFAULT_CUMULATOR );
36+
}
37+
3138
@Override
3239
public void channelRead( ChannelHandlerContext ctx, Object msg ) throws Exception
3340
{
@@ -60,4 +67,14 @@ protected void decode( ChannelHandlerContext ctx, ByteBuf in, List<Object> out )
6067
readMessageBoundary = false;
6168
}
6269
}
70+
71+
private static Cumulator determineDefaultCumulator()
72+
{
73+
String value = System.getProperty( "messageDecoderCumulator", "" );
74+
if ( "merge".equals( value ) )
75+
{
76+
return MERGE_CUMULATOR;
77+
}
78+
return COMPOSITE_CUMULATOR;
79+
}
6380
}

0 commit comments

Comments
 (0)