[hornetq-commits] JBoss hornetq SVN: r9695 - in trunk: tests/src/org/hornetq/tests/soak/client and 1 other directory.

[do-not-reply at jboss.org]

Author: timfox
Date: 2010-09-16 08:55:50 -0400 (Thu, 16 Sep 2010)
New Revision: 9695

Modified:
   trunk/src/main/org/hornetq/utils/LinkedListImpl.java
   trunk/tests/src/org/hornetq/tests/soak/client/SimpleSendReceiveSoakTest.java
Log:
https://jira.jboss.org/browse/HORNETQ-469

Modified: trunk/src/main/org/hornetq/utils/LinkedListImpl.java
===================================================================
--- trunk/src/main/org/hornetq/utils/LinkedListImpl.java	2010-09-16 12:11:07 UTC (rev 9694)
+++ trunk/src/main/org/hornetq/utils/LinkedListImpl.java	2010-09-16 12:55:50 UTC (rev 9695)
@@ -176,6 +176,10 @@
       {
          LinkedListImpl.this.nudgeIterators(toRemove);
       }
+      
+      //Help GC - otherwise GC potentially has to traverse a very long list to see if elements are reachable, this can result in OOM
+      //https://jira.jboss.org/browse/HORNETQ-469
+      toRemove.next = toRemove.prev = null;
    }
 
    private void nudgeIterators(Node<E> node)

Modified: trunk/tests/src/org/hornetq/tests/soak/client/SimpleSendReceiveSoakTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/soak/client/SimpleSendReceiveSoakTest.java	2010-09-16 12:11:07 UTC (rev 9694)
+++ trunk/tests/src/org/hornetq/tests/soak/client/SimpleSendReceiveSoakTest.java	2010-09-16 12:55:50 UTC (rev 9695)
@@ -88,7 +88,7 @@
       server = null;
    }
 
-   public void testSoakClient() throws Exception
+   public void testSoakClientTransactions() throws Exception
    {
       final ClientSessionFactory sf = createFactory(IS_NETTY);
 
@@ -123,8 +123,6 @@
             producer.send(msg);
          }
          
-         session.commit();
-
          for (int i = 0; i < MIN_MESSAGES_ON_QUEUE; i++)
          {
             ClientMessage msg = consumer.receive(5000);
@@ -132,8 +130,6 @@
             msg.acknowledge();
             assertEquals(msgReceivedID++, msg.getLongProperty("count").longValue());
          }
-         
-         sessionConsumer.commit();
       }
 
       sessionConsumer.close();
@@ -141,6 +137,7 @@
       sf.close();
 
    }
+   
 
    // Package protected ---------------------------------------------