Spring/spring-data-geode
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

enhanced StubAsyncEventQueueFactory for 7.0.1

Browse Source
This commit is contained in:
David Turanski
2013-03-08 08:23:39 -05:00
parent 39b05429bd
commit e3a6f47e76
5 changed files with 132 additions and 104 deletions
Download Patch File Download Diff File Expand all files Collapse all files

35
src/test/java/org/springframework/data/gemfire/test/StubAsyncEventQueueFactory.java
View File

@@ -39,6 +39,16 @@ public class StubAsyncEventQueueFactory implements AsyncEventQueueFactory {
private boolean parallel;
private boolean diskSynchronous;
private boolean batchConflationEnabled;
private int dispatcherThreads;
private OrderPolicy orderPolicy;
private int batchTimeInterval;
@Override
public AsyncEventQueue create(String name, AsyncEventListener listener) {
this.name = name;
@@ -51,6 +61,11 @@ public class StubAsyncEventQueueFactory implements AsyncEventQueueFactory {
when(asyncEventQueue.getId()).thenReturn(this.name);
when(asyncEventQueue.getMaximumQueueMemory()).thenReturn(this.maxQueueMemory);
when(asyncEventQueue.isParallel()).thenReturn(this.parallel);
when(asyncEventQueue.isBatchConflationEnabled()).thenReturn(this.batchConflationEnabled);
when(asyncEventQueue.isDiskSynchronous()).thenReturn(this.diskSynchronous);
when(asyncEventQueue.getBatchTimeInterval()).thenReturn(this.batchTimeInterval);
when(asyncEventQueue.getOrderPolicy()).thenReturn(this.orderPolicy);
when(asyncEventQueue.getDispatcherThreads()).thenReturn(this.dispatcherThreads);
return this.asyncEventQueue;
}
@@ -86,27 +101,27 @@ public class StubAsyncEventQueueFactory implements AsyncEventQueueFactory {
//The following added in 7.0.1
public AsyncEventQueueFactory setBatchConflationEnabled(boolean arg0) {
// TODO Auto-generated method stub
return null;
this.batchConflationEnabled = arg0;
return this;
}
public AsyncEventQueueFactory setBatchTimeInterval(int arg0) {
// TODO Auto-generated method stub
return null;
this.batchTimeInterval = arg0;
return this;
}
public AsyncEventQueueFactory setDiskSynchronous(boolean arg0) {
// TODO Auto-generated method stub
return null;
this.diskSynchronous = arg0;
return this;
}
public AsyncEventQueueFactory setDispatcherThreads(int arg0) {
// TODO Auto-generated method stub
return null;
this.dispatcherThreads = arg0;
return this;
}
public AsyncEventQueueFactory setOrderPolicy(OrderPolicy arg0) {
// TODO Auto-generated method stub
return null;
this.orderPolicy = arg0;
return this;
}
}