[hornetq-commits] JBoss hornetq SVN: r10097 - in trunk/tests/src/org/hornetq/tests: unit/core/postoffice/impl and 1 other directory.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2011-01-01 17:07:31 -0500 (Sat, 01 Jan 2011)
New Revision: 10097

Modified:
   trunk/tests/src/org/hornetq/tests/stress/paging/PageCursorStressTest.java
   trunk/tests/src/org/hornetq/tests/unit/core/postoffice/impl/FakeQueue.java
Log:
fixing a stress test

Modified: trunk/tests/src/org/hornetq/tests/stress/paging/PageCursorStressTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/stress/paging/PageCursorStressTest.java	2011-01-01 20:59:31 UTC (rev 10096)
+++ trunk/tests/src/org/hornetq/tests/stress/paging/PageCursorStressTest.java	2011-01-01 22:07:31 UTC (rev 10097)
@@ -1281,8 +1281,14 @@
    private PageSubscription createNonPersistentCursor(Filter filter) throws Exception
    {
       long id = server.getStorageManager().generateUniqueID();
-      queueList.add(new FakeQueue(new SimpleString(filter.toString()), id));
-      return lookupCursorProvider().createSubscription(id, filter, false);
+      FakeQueue queue = new FakeQueue(new SimpleString(filter.toString()), id);
+      queueList.add(queue);
+      
+      PageSubscription subs = lookupCursorProvider().createSubscription(id, filter, false);
+      
+      queue.setPageSubscription(subs);
+      
+      return subs;
    }
 
    /**

Modified: trunk/tests/src/org/hornetq/tests/unit/core/postoffice/impl/FakeQueue.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/unit/core/postoffice/impl/FakeQueue.java	2011-01-01 20:59:31 UTC (rev 10096)
+++ trunk/tests/src/org/hornetq/tests/unit/core/postoffice/impl/FakeQueue.java	2011-01-01 22:07:31 UTC (rev 10097)
@@ -37,6 +37,9 @@
  */
 public class FakeQueue implements Queue
 {
+   
+   PageSubscription subs;
+   
    public boolean isDirectDeliver()
    {
       // TODO Auto-generated method stub
@@ -610,8 +613,12 @@
     */
    public PageSubscription getPageSubscription()
    {
-      // TODO Auto-generated method stub
-      return null;
+      return subs;
    }
+   
+   public void setPageSubscription(PageSubscription sub)
+   {
+      this.subs = sub;
+   }
 
 }
\ No newline at end of file