Examples of addListenerConfig()

Examples of com.hazelcast.config.Config.addListenerConfig()

75
76
77
78
79
80
81
82
83
84
85
     */
    @Test
    public void testDeadTaker() throws Exception {
        Config config = new Config();
        final CountDownLatch shutdownLatch = new CountDownLatch(1);
        config.addListenerConfig(new ListenerConfig().setImplementation(new MembershipListener() {
            public void memberAdded(MembershipEvent membershipEvent) {
            }

            public void memberRemoved(MembershipEvent membershipEvent) {
                shutdownLatch.countDown();
View Full Code Here

Examples of com.hazelcast.config.Config.addListenerConfig()

101
102
103
104
105
106
107
108
109
110
111
    c4.getNetworkConfig().getJoin().getTcpIpConfig().setMembers(clusterTwoMembers);

    c4.setProperty(GroupProperties.PROP_WAIT_SECONDS_BEFORE_JOIN, "0");

    final CountDownLatch latch = new CountDownLatch(1);
    c4.addListenerConfig(new ListenerConfig(new LifecycleListener() {
      public void stateChanged(final LifecycleEvent event) {
        if(event.getState() == LifecycleState.MERGED) {
          System.out.println("h4 restarted");
          latch.countDown();
        }
View Full Code Here

Examples of com.hazelcast.config.Config.addListenerConfig()

194
195
196
197
198
199
200
201
202
203
204
                      latch.countDown();
                  }
              }
          }));
 
          c4.addListenerConfig(new ListenerConfig(new LifecycleListener() {
              public void stateChanged(final LifecycleEvent event) {
                  if (event.getState() == LifecycleState.MERGED) {
                      System.out.println("h4 restarted");
                      latch.countDown();
                  }
View Full Code Here

Examples of com.hazelcast.config.Config.addListenerConfig()

259
260
261
262
263
264
265
266
267
268
269
 
          final HazelcastInstance h1 = Hazelcast.newHazelcastInstance(c1);
          final HazelcastInstance h2 = Hazelcast.newHazelcastInstance(c2);
 
          final CountDownLatch latch = new CountDownLatch(1);
          c3.addListenerConfig(new ListenerConfig(new LifecycleListener() {
              public void stateChanged(final LifecycleEvent event) {
                  if (event.getState() == LifecycleState.MERGED) {
                      h1.getLifecycleService().shutdown();
                  } else if (event.getState() == LifecycleState.MERGED) {
                      System.out.println("h3 restarted");
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.