Fixed find bugs warnings
This commit is contained in:
parent
7044f9a586
commit
6ce3eebc55
@ -135,7 +135,8 @@ public abstract class AbstractCodecEmbedder<T> implements CodecEmbedder<T> {
|
|||||||
|
|
||||||
private void handleEvent(ChannelEvent e) {
|
private void handleEvent(ChannelEvent e) {
|
||||||
if (e instanceof MessageEvent) {
|
if (e instanceof MessageEvent) {
|
||||||
productQueue.offer(((MessageEvent) e).getMessage());
|
boolean offered = productQueue.offer(((MessageEvent) e).getMessage());
|
||||||
|
assert offered;
|
||||||
} else if (e instanceof ExceptionEvent) {
|
} else if (e instanceof ExceptionEvent) {
|
||||||
throw new CodecEmbedderException(((ExceptionEvent) e).getCause());
|
throw new CodecEmbedderException(((ExceptionEvent) e).getCause());
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user