[hornetq-commits] JBoss hornetq SVN: r10097 - in trunk/tests/src/org/hornetq/tests: unit/core/postoffice/impl and 1 other directory.
Author: clebert.suconic(a)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