On Fri, Jun 3, 2016 at 9:38 AM, Isuru Ranawaka <[email protected]> wrote:
> while (true) {
> if (carbonMessage.isEmpty() &&
> carbonMessage.isEndOfMsgAdded()) {
> break;
> } else {
> ByteBuffer byteBuffer = carbonMessage.getMessageBody();
> System.out.println("Content Reading " + new
> String(byteBuffer.array()));
> }
> }
>
Your suggestion works but now I am seeing the following warning:
2016-06-03 10:01:56 ERROR ResourceLeakDetector:176 - LEAK:
ByteBuf.release() was not called before it's garbage-collected. Enable
advanced leak reporting to find out where the leak occurred. To enable
advanced leak reporting, specify the JVM option
'-Dio.netty.leakDetectionLevel=advanced' or call
ResourceLeakDetector.setLevel() See
http://netty.io/wiki/reference-counted-objects.html for more information.
--
*Afkham Azeez*
Director of Architecture; WSO2, Inc.; http://wso2.com
Member; Apache Software Foundation; http://www.apache.org/
* <http://www.apache.org/>*
*email: **[email protected]* <[email protected]>
* cell: +94 77 3320919blog: **http://blog.afkham.org*
<http://blog.afkham.org>
*twitter: **http://twitter.com/afkham_azeez*
<http://twitter.com/afkham_azeez>
*linked-in: **http://lk.linkedin.com/in/afkhamazeez
<http://lk.linkedin.com/in/afkhamazeez>*
*Lean . Enterprise . Middleware*
_______________________________________________
Dev mailing list
[email protected]
http://wso2.org/cgi-bin/mailman/listinfo/dev
