Make NoSuchBufferException message more useful
This commit is contained in:
parent
b291d85757
commit
b76c39318d
@ -117,6 +117,28 @@ final class CodecUtil {
|
|||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
static void addToNextOutboundBuffer(ChannelHandlerContext ctx, Object msg) {
|
||||||
|
try {
|
||||||
|
ctx.nextOutboundMessageBuffer().add(msg);
|
||||||
|
} catch (NoSuchBufferException e) {
|
||||||
|
NoSuchBufferException newE =
|
||||||
|
new NoSuchBufferException(e.getMessage() + " (msg: " + msg + ')');
|
||||||
|
newE.setStackTrace(e.getStackTrace());
|
||||||
|
throw newE;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
static void addToNextInboundBuffer(ChannelHandlerContext ctx, Object msg) {
|
||||||
|
try {
|
||||||
|
ctx.nextInboundMessageBuffer().add(msg);
|
||||||
|
} catch (NoSuchBufferException e) {
|
||||||
|
NoSuchBufferException newE =
|
||||||
|
new NoSuchBufferException(e.getMessage() + " (msg: " + msg + ')');
|
||||||
|
newE.setStackTrace(e.getStackTrace());
|
||||||
|
throw newE;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
private CodecUtil() {
|
private CodecUtil() {
|
||||||
// Unused
|
// Unused
|
||||||
}
|
}
|
||||||
|
@ -41,7 +41,7 @@ public abstract class MessageToByteEncoder<I> extends ChannelOutboundMessageHand
|
|||||||
}
|
}
|
||||||
|
|
||||||
if (!isEncodable(msg)) {
|
if (!isEncodable(msg)) {
|
||||||
ctx.nextOutboundMessageBuffer().add(msg);
|
CodecUtil.addToNextOutboundBuffer(ctx, msg);
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -47,7 +47,7 @@ public abstract class MessageToMessageDecoder<I, O>
|
|||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
if (!isDecodable(msg)) {
|
if (!isDecodable(msg)) {
|
||||||
ctx.nextInboundMessageBuffer().add(msg);
|
CodecUtil.addToNextInboundBuffer(ctx, msg);
|
||||||
notify = true;
|
notify = true;
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
@ -39,7 +39,7 @@ public abstract class MessageToMessageEncoder<I, O> extends ChannelOutboundMessa
|
|||||||
}
|
}
|
||||||
|
|
||||||
if (!isEncodable(msg)) {
|
if (!isEncodable(msg)) {
|
||||||
ctx.nextOutboundMessageBuffer().add(msg);
|
CodecUtil.addToNextOutboundBuffer(ctx, msg);
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user