Skip to content

Commit

Permalink
Debug print message type mismatch value
Browse files Browse the repository at this point in the history
  • Loading branch information
martinfurmanski committed Sep 19, 2017
1 parent 2e73f63 commit cf494c2
Showing 1 changed file with 3 additions and 2 deletions.
Expand Up @@ -45,7 +45,8 @@ public void channelRead( ChannelHandlerContext ctx, Object msg ) throws Exceptio
{
if ( protocol.isExpecting( CatchupClientProtocol.State.MESSAGE_TYPE ) )
{
ResponseMessageType responseMessageType = from( ((ByteBuf) msg).readByte() );
byte byteValue = ((ByteBuf) msg).readByte();
ResponseMessageType responseMessageType = from( byteValue );

switch ( responseMessageType )
{
Expand All @@ -68,7 +69,7 @@ public void channelRead( ChannelHandlerContext ctx, Object msg ) throws Exceptio
protocol.expect( CatchupClientProtocol.State.TX_STREAM_FINISHED );
break;
default:
log.warn( "No handler found for message type %s", responseMessageType );
log.warn( "No handler found for message type %s (%d)", responseMessageType.name(), byteValue );
}

ReferenceCountUtil.release( msg );
Expand Down

0 comments on commit cf494c2

Please sign in to comment.