1 package org.apache.commons.jcs.engine;
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22 import junit.framework.TestCase;
23 import org.apache.commons.jcs.auxiliary.remote.MockRemoteCacheListener;
24 import org.apache.commons.jcs.engine.behavior.ICacheEventQueue;
25 import org.apache.commons.jcs.engine.behavior.ICacheEventQueue.QueueType;
26 import org.apache.commons.jcs.engine.behavior.ICacheListener;
27
28
29 public class CacheEventQueueFactoryUnitTest
30 extends TestCase
31 {
32
33 public void testCreateCacheEventQueue_Single()
34 {
35
36 QueueType eventQueueType = QueueType.SINGLE;
37 ICacheListener<String, String> listener = new MockRemoteCacheListener<String, String>();
38 long listenerId = 1;
39
40 CacheEventQueueFactory<String, String> factory = new CacheEventQueueFactory<String, String>();
41
42
43 ICacheEventQueue<String, String> result = factory.createCacheEventQueue( listener, listenerId, "cacheName", "threadPoolName", eventQueueType );
44
45
46 assertNotNull( "Should have a result", result );
47 assertTrue( "Wrong type", result instanceof CacheEventQueue );
48 }
49
50
51 public void testCreateCacheEventQueue_Pooled()
52 {
53
54 QueueType eventQueueType = QueueType.POOLED;
55 ICacheListener<String, String> listener = new MockRemoteCacheListener<String, String>();
56 long listenerId = 1;
57
58 CacheEventQueueFactory<String, String> factory = new CacheEventQueueFactory<String, String>();
59
60
61 ICacheEventQueue<String, String> result = factory.createCacheEventQueue( listener, listenerId, "cacheName", "threadPoolName", eventQueueType );
62
63
64 assertNotNull( "Should have a result", result );
65 assertTrue( "Wrong type", result instanceof PooledCacheEventQueue );
66 }
67 }