Examples of addExpected()

Examples of org.apache.sling.discovery.impl.cluster.helpers.AssertingTopologyEventListener.addExpected()

321
322
323
324
325
326
327
328
329
330
331
                .getInstances().size());
        assertEquals(2, instance2.getClusterViewService().getClusterView()
                .getInstances().size());

        AssertingTopologyEventListener assertingTopologyEventListener = new AssertingTopologyEventListener();
        assertingTopologyEventListener.addExpected(Type.TOPOLOGY_INIT);
        assertEquals(1, assertingTopologyEventListener.getRemainingExpectedCount());
        instance1.bindTopologyEventListener(assertingTopologyEventListener);
        assertEquals(0, assertingTopologyEventListener.getRemainingExpectedCount());

        // startup instance 3
View Full Code Here

Examples of org.apache.sling.discovery.impl.cluster.helpers.AssertingTopologyEventListener.addExpected()

329
330
331
332
333
334
335
336
337
338
339
        assertEquals(0, assertingTopologyEventListener.getRemainingExpectedCount());

        // startup instance 3
        AcceptsMultiple acceptsMultiple = new AcceptsMultiple(
                Type.TOPOLOGY_CHANGING, Type.TOPOLOGY_CHANGED);
        assertingTopologyEventListener.addExpected(acceptsMultiple);
        assertingTopologyEventListener.addExpected(acceptsMultiple);
        instance3 = Instance.newClusterInstance("thirdInstance", instance1,
                false);
        instance1.runHeartbeatOnce();
        instance2.runHeartbeatOnce();
View Full Code Here

Examples of org.apache.sling.discovery.impl.cluster.helpers.AssertingTopologyEventListener.addExpected()

330
331
332
333
334
335
336
337
338
339
340
        // startup instance 3
        AcceptsMultiple acceptsMultiple = new AcceptsMultiple(
                Type.TOPOLOGY_CHANGING, Type.TOPOLOGY_CHANGED);
        assertingTopologyEventListener.addExpected(acceptsMultiple);
        assertingTopologyEventListener.addExpected(acceptsMultiple);
        instance3 = Instance.newClusterInstance("thirdInstance", instance1,
                false);
        instance1.runHeartbeatOnce();
        instance2.runHeartbeatOnce();
        instance3.runHeartbeatOnce();
View Full Code Here

Examples of org.apache.sling.discovery.impl.cluster.helpers.AssertingTopologyEventListener.addExpected()

169
170
171
172
173
174
175
176
177
178
179
        instance.runHeartbeatOnce();
        logger.info("testTopologyEventListeners: 2nd sleep 2s");
        Thread.sleep(2000);

        AssertingTopologyEventListener assertingTopologyEventListener = new AssertingTopologyEventListener();
        assertingTopologyEventListener.addExpected(Type.TOPOLOGY_INIT);
        instance.bindTopologyEventListener(assertingTopologyEventListener);
        assertEquals(0, assertingTopologyEventListener.getRemainingExpectedCount());

        final String propertyName = UUID.randomUUID().toString();
        propertyValue = UUID.randomUUID().toString();
View Full Code Here

Examples of org.apache.sling.discovery.impl.cluster.helpers.AssertingTopologyEventListener.addExpected()

178
179
180
181
182
183
184
185
186
187
188
        final String propertyName = UUID.randomUUID().toString();
        propertyValue = UUID.randomUUID().toString();
        PropertyProviderImpl pp = new PropertyProviderImpl();
        pp.setProperty(propertyName, propertyValue);

        assertingTopologyEventListener.addExpected(Type.PROPERTIES_CHANGED);

        assertEquals(1, assertingTopologyEventListener.getRemainingExpectedCount());
        assertEquals(0, pp.getGetCnt());
        instance.bindPropertyProvider(pp, propertyName);
        logger.info("testTopologyEventListeners: 3rd sleep 1.5s");
View Full Code Here

Examples of org.apache.sling.discovery.impl.cluster.helpers.AssertingTopologyEventListener.addExpected()

190
191
192
193
194
195
196
197
198
199
200
        assertEquals(0, assertingTopologyEventListener.getRemainingExpectedCount());
        // we can only assume that the getProperty was called at least once - it
        // could be called multiple times though..
        assertTrue(pp.getGetCnt() > 0);

        assertingTopologyEventListener.addExpected(Type.PROPERTIES_CHANGED);

        assertEquals(1, assertingTopologyEventListener.getRemainingExpectedCount());
        pp.setGetCnt(0);
        propertyValue = UUID.randomUUID().toString();
        pp.setProperty(propertyName, propertyValue);
View Full Code Here

Examples of org.apache.sling.discovery.impl.cluster.helpers.AssertingTopologyEventListener.addExpected()

220
221
222
223
224
225
226
227
228
229
230
        ClusterView initialClusterView = instance.getClusterViewService()
                .getClusterView();
        assertNotNull(initialClusterView);

        AssertingTopologyEventListener ada = new AssertingTopologyEventListener();
        ada.addExpected(Type.TOPOLOGY_INIT);
        instance.bindTopologyEventListener(ada);
        assertEquals(1, ada.getEvents().size());
        TopologyEvent initEvent = ada.getEvents().remove(0);
        assertNotNull(initEvent);
View Full Code Here

Examples of org.jboss.arquillian.persistence.data.dbunit.dataset.DataSetRegister.addExpected()

147
148
149
150
151
152
153
154
155
156
157
   {
      DataSetRegister dataSetRegister = getOrCreateDataSetRegister();
      for (DataSetResourceDescriptor dataSetDescriptor : dataSetDescriptors)
      {
         IDataSet expectedDataSet = createExpectedDataSet(dataSetDescriptor);
         dataSetRegister.addExpected(expectedDataSet);
      }
      dataSetRegisterProducer.set(dataSetRegister);
   }

   private IDataSet createExpectedDataSet(DataSetResourceDescriptor dataSetDescriptor)
View Full Code Here

Examples of org.jboss.arquillian.persistence.dbunit.dataset.DataSetRegister.addExpected()

195
196
197
198
199
200
201
202
203
204
205
   private void createExpectedDataSets(Collection<DataSetResourceDescriptor> dataSetDescriptors)
   {
      DataSetRegister dataSetRegister = getOrCreateDataSetRegister();
      for (DataSetResourceDescriptor dataSetDescriptor : dataSetDescriptors)
      {
         dataSetRegister.addExpected(dataSetDescriptor.getContent());
      }
      dataSetRegisterProducer.set(dataSetRegister);
   }

   private DataSetRegister getOrCreateDataSetRegister()
View Full Code Here

Examples of org.jboss.arquillian.persistence.dbunit.dataset.DataSetRegister.addExpected()

191
192
193
194
195
196
197
198
199
200
201
   private void createExpectedDataSets(Collection<DataSetResourceDescriptor> dataSetDescriptors)
   {
      DataSetRegister dataSetRegister = getOrCreateDataSetRegister();
      for (DataSetResourceDescriptor dataSetDescriptor : dataSetDescriptors)
      {
         dataSetRegister.addExpected(dataSetDescriptor.getContent());
      }
      dataSetRegisterProducer.set(dataSetRegister);
   }

   private DataSetRegister getOrCreateDataSetRegister()
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.