|
@@ -39,7 +39,6 @@ public class Encode extends MessageToMessageEncoder {
|
|
|
if(msg==null || StrUtil.isEmptyIfStr(msg)){
|
|
if(msg==null || StrUtil.isEmptyIfStr(msg)){
|
|
|
ByteBuf buf = Unpooled.copiedBuffer("".getBytes(CharsetUtil.UTF_8));
|
|
ByteBuf buf = Unpooled.copiedBuffer("".getBytes(CharsetUtil.UTF_8));
|
|
|
out.add(buf);
|
|
out.add(buf);
|
|
|
- ctx.flush();
|
|
|
|
|
return;
|
|
return;
|
|
|
}
|
|
}
|
|
|
if(msg instanceof DefaultAddressedEnvelope){
|
|
if(msg instanceof DefaultAddressedEnvelope){
|
|
@@ -54,9 +53,7 @@ public class Encode extends MessageToMessageEncoder {
|
|
|
ByteBuf buf = Unpooled.copiedBuffer("".getBytes(CharsetUtil.UTF_8));
|
|
ByteBuf buf = Unpooled.copiedBuffer("".getBytes(CharsetUtil.UTF_8));
|
|
|
out.add(buf);
|
|
out.add(buf);
|
|
|
}
|
|
}
|
|
|
- }catch (Exception e){}finally {
|
|
|
|
|
- ctx.flush();
|
|
|
|
|
- }
|
|
|
|
|
|
|
+ }catch (Exception e){}
|
|
|
|
|
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|