Package org.jboss.cache.interceptors.base

Examples of org.jboss.cache.interceptors.base.CommandInterceptor

45
46
47
48
49
50
51
52
53
54
55
56
57
58
   @BeforeMethod
   public void setUp() throws Exception
   {
      pojo = new SamplePojo(21, "test");
      cache = createCache();
      CommandInterceptor interceptor = new OptimisticCreateIfNotExistsInterceptor();
      dummy = new MockInterceptor();

      interceptor.setNext(dummy);

      TestingUtil.replaceInterceptorChain(cache, interceptor);

      setupTransactionsInInvocationCtx(cache);
   }
View Full Code Here
56
57
58
59
60
61
62
63
64
65
66
   {
      List<CommandInterceptor> interceptors = cache.getInterceptorChain();
      assertEquals("Expecting 6 interceptors", 6, interceptors.size());
      assertInterceptorLinkage(interceptors);

      CommandInterceptor x = new TestInterceptor();
      cache.addInterceptor(x, 0);

      interceptors = cache.getInterceptorChain();
      assertEquals("Expecting 7 interceptors", 7, interceptors.size());
      assertInterceptorLinkage(interceptors);
View Full Code Here
72
73
74
75
76
77
78
79
80
81
82
   {
      List<CommandInterceptor> interceptors = cache.getInterceptorChain();
      assertEquals("Expecting 6 interceptors", 6, interceptors.size());
      assertInterceptorLinkage(interceptors);

      CommandInterceptor x = new TestInterceptor();
      cache.addInterceptor(x, 6);

      interceptors = cache.getInterceptorChain();
      assertEquals("Expecting 7 interceptors", 7, interceptors.size());
      assertInterceptorLinkage(interceptors);
View Full Code Here
88
89
90
91
92
93
94
95
96
97
98
   {
      List<CommandInterceptor> interceptors = cache.getInterceptorChain();
      assertEquals("Expecting 6 interceptors", 6, interceptors.size());
      assertInterceptorLinkage(interceptors);

      CommandInterceptor x = new TestInterceptor();
      cache.addInterceptor(x, 3);

      interceptors = cache.getInterceptorChain();
      assertEquals("Expecting 7 interceptors", 7, interceptors.size());
      assertInterceptorLinkage(interceptors);
View Full Code Here
104
105
106
107
108
109
110
111
112
113
114
   {
      List<CommandInterceptor> interceptors = cache.getInterceptorChain();
      assertEquals("Expecting 6 interceptors", 6, interceptors.size());
      assertInterceptorLinkage(interceptors);

      CommandInterceptor x = new TestInterceptor();
      try
      {
         cache.addInterceptor(x, 9);
         fail("Should throw an exception");
      }
View Full Code Here
119
120
121
122
123
124
125
126
127
128
129
   }

   public void testRemoveAtHead()
   {
      List<CommandInterceptor> interceptors = cache.getInterceptorChain();
      CommandInterceptor afterHead = interceptors.get(1);
      assertEquals("Expecting 6 interceptors", 6, interceptors.size());
      assertInterceptorLinkage(interceptors);

      cache.removeInterceptor(0);
View Full Code Here
135
136
137
138
139
140
141
142
143
144
145
   }

   public void testRemoveAtTail()
   {
      List<CommandInterceptor> interceptors = cache.getInterceptorChain();
      CommandInterceptor beforeTail = interceptors.get(4);
      assertEquals("Expecting 6 interceptors", 6, interceptors.size());
      assertInterceptorLinkage(interceptors);

      cache.removeInterceptor(5);
View Full Code Here
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
*/
public abstract class InterceptorChainTestBase
{
   protected void assertInterceptorLinkage(List<CommandInterceptor> list)
   {
      CommandInterceptor previous = null;
      for (CommandInterceptor i : list)
      {
         if (previous == null)
         {
            previous = i;
            continue;
         }

         assertEquals("Expecting the next interceptor after " + previous + " to be " + i, i, previous.getNext());

         previous = i;
      }
   }
View Full Code Here
28
29
30
31
32
33
34
35
36
37
38
39
40
41
   @BeforeMethod
   public void setUp() throws Exception
   {
      cache = createCache();
      CommandInterceptor interceptor = new OptimisticCreateIfNotExistsInterceptor();
      CommandInterceptor nodeInterceptor = new OptimisticNodeInterceptor();
      dummy = new MockInterceptor();

      interceptor.setNext(nodeInterceptor);
      nodeInterceptor.setNext(dummy);

      TestingUtil.replaceInterceptorChain(cache, interceptor);
   }
View Full Code Here
251
252
253
254
255
256
257
258
259
260
261
   public void testConcurrentPut() throws Exception
   {
      final String slowThreadName = "SLOW";
      final String fastThreadName = "FAST";
      CommandInterceptor slowdownInterceptor = new CommandInterceptor()
      {
         public Object handleDefault(InvocationContext ctx, VisitableCommand command) throws Throwable
         {
            if (Thread.currentThread().getName().equals(slowThreadName))
            {
View Full Code Here
TOP

Related Classes of org.jboss.cache.interceptors.base.CommandInterceptor

  • org.jboss.cache.config.parsing.element.CustomInterceptorsElementParser
  • org.jboss.cache.factories.CustomInterceptorChainTest
  • org.jboss.cache.factories.InterceptorChainFactory
  • org.jboss.cache.factories.InterceptorChainTestBase
  • org.jboss.cache.interceptors.InterceptorChain
  • org.jboss.cache.loader.SharedCacheLoaderTest
  • org.jboss.cache.optimistic.ConcurrentTransactionTest
  • org.jboss.cache.optimistic.NodeInterceptorGetChildrenNamesTest
  • org.jboss.cache.optimistic.NodeInterceptorGetKeysTest
  • org.jboss.cache.optimistic.NodeInterceptorGetKeyValTest
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.