Docjar: org/apache/hivemind/util/TestShutdownCoordinator.java

Home >> All >> org >> apache >> hivemind >> [ util Javadoc ]
Source code: org/apache/hivemind/util/TestShutdownCoordinator.java

1   // Copyright 2004, 2005 The Apache Software Foundation
2   //
3   // Licensed under the Apache License, Version 2.0 (the "License");
4   // you may not use this file except in compliance with the License.
5   // You may obtain a copy of the License at
6   //
7   //     http://www.apache.org/licenses/LICENSE-2.0
8   //
9   // Unless required by applicable law or agreed to in writing, software
10  // distributed under the License is distributed on an "AS IS" BASIS,
11  // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12  // See the License for the specific language governing permissions and
13  // limitations under the License.
14  
15  package org.apache.hivemind.util;
16  
17  import org.apache.hivemind.ApplicationRuntimeException;
18  import org.apache.hivemind.Registry;
19  import org.apache.hivemind.ShutdownCoordinator;
20  import org.apache.hivemind.events.RegistryShutdownListener;
21  import org.apache.hivemind.impl.RegistryBuilder;
22  import org.apache.hivemind.impl.ShutdownCoordinatorImpl;
23  
24  import hivemind.test.FrameworkTestCase;
25  
26  /**
27   * Tests the {@link org.apache.hivemind.impl.ShutdownCoordinator}.
28   *
29   * @author Howard Lewis Ship
30   */
31  public class TestShutdownCoordinator extends FrameworkTestCase
32  {
33      private static class Fixture implements RegistryShutdownListener
34      {
35          private boolean _shutdown;
36  
37          public boolean isShutdown()
38          {
39              return _shutdown;
40          }
41  
42          public void registryDidShutdown()
43          {
44              _shutdown = true;
45          }
46  
47      }
48  
49      public void testShutdownCoordinator()
50      {
51          ShutdownCoordinator c = new ShutdownCoordinatorImpl();
52  
53          Fixture f = new Fixture();
54  
55          c.addRegistryShutdownListener(f);
56  
57          c.shutdown();
58  
59          assertEquals(true, f.isShutdown());
60  
61          // For good riddens; test no failure if already down.
62  
63          c.shutdown();
64      }
65  
66      public void testShutdownCoordinatorService()
67      {
68          Registry r = RegistryBuilder.constructDefaultRegistry();
69  
70          ShutdownCoordinator c =
71              (ShutdownCoordinator) r.getService(
72                  "hivemind.ShutdownCoordinator",
73                  ShutdownCoordinator.class);
74  
75          Fixture f = new Fixture();
76  
77          c.addRegistryShutdownListener(f);
78  
79          c.shutdown();
80  
81          assertEquals(true, f.isShutdown());
82      }
83  
84      public void testShutdownFailure() throws Exception
85      {
86          ShutdownCoordinator c = new ShutdownCoordinatorImpl();
87  
88          c.addRegistryShutdownListener(new RegistryShutdownListener()
89          {
90              public void registryDidShutdown()
91              {
92                  throw new ApplicationRuntimeException("I'm just not in the mood.");
93              }
94          });
95  
96          interceptLogging();
97  
98          c.shutdown();
99  
100         assertLoggedMessagePattern("Unable to shutdown .*: I'm just not in the mood\\.");
101     }
102 
103 }