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