1 package org.apache.commons.jcs3.engine;
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22 import java.util.concurrent.ConcurrentHashMap;
23 import java.util.concurrent.ConcurrentMap;
24
25 import org.apache.commons.jcs3.engine.behavior.ICache;
26 import org.apache.commons.jcs3.engine.behavior.ICacheEventQueue;
27
28
29
30
31
32 public class CacheListeners<K, V>
33 {
34
35 public final ICache<K, V> cache;
36
37
38 public final ConcurrentMap<Long, ICacheEventQueue<K, V>> eventQMap =
39 new ConcurrentHashMap<>();
40
41
42
43
44
45
46 public CacheListeners( final ICache<K, V> cache )
47 {
48 if ( cache == null )
49 {
50 throw new IllegalArgumentException( "cache must not be null" );
51 }
52 this.cache = cache;
53 }
54
55
56 @Override
57 public String toString()
58 {
59 final StringBuilder buffer = new StringBuilder();
60 buffer.append( "\n CacheListeners" );
61 buffer.append( "\n Region = " + cache.getCacheName() );
62 buffer.append( "\n Event Queue Map " );
63 buffer.append( "\n size = " + eventQMap.size() );
64 eventQMap.forEach((key, value)
65 -> buffer.append( "\n Entry: key: ").append(key)
66 .append(", value: ").append(value));
67 return buffer.toString();
68 }
69 }