Author: clebert.suconic(a)jboss.com
Date: 2010-08-02 22:42:47 -0400 (Mon, 02 Aug 2010)
New Revision: 9494
Modified:
trunk/src/main/org/hornetq/core/paging/impl/PageImpl.java
Log:
https://jira.jboss.org/browse/HORNETQ-467 - fixing leakage caused by the JDK on NIO
Modified: trunk/src/main/org/hornetq/core/paging/impl/PageImpl.java
===================================================================
--- trunk/src/main/org/hornetq/core/paging/impl/PageImpl.java 2010-07-30 18:36:17 UTC (rev
9493)
+++ trunk/src/main/org/hornetq/core/paging/impl/PageImpl.java 2010-08-03 02:42:47 UTC (rev
9494)
@@ -13,6 +13,7 @@
package org.hornetq.core.paging.impl;
+import java.nio.Buffer;
import java.nio.ByteBuffer;
import java.util.ArrayList;
import java.util.List;
@@ -94,7 +95,9 @@
{
ArrayList<PagedMessage> messages = new ArrayList<PagedMessage>();
- ByteBuffer buffer2 = fileFactory.newBuffer((int)file.size());
+ // Using direct buffer, as described on
https://jira.jboss.org/browse/HORNETQ-467
+ ByteBuffer buffer2 = ByteBuffer.allocateDirect((int)file.size());
+
file.position(0);
file.read(buffer2);