@Test public void testUnregister() { final Set<Instance> instances = Instances.newInstances(2); repository.register(instances); Assert.assertTrue(_instances.get().containsAll(instances)); repository.unregister(instances); for (final Instance instance : instances) { Assert.assertFalse(_instances.get().contains(instance)); } }
public void unregister(final Set<Instance> instances) { if (CollectionUtils.isEmpty(instances)) { return; } _client.unregister(instances); updateInstances(instances, RegisterType.unregister); }
InstanceRepository { public void unregister(final Set<Instance> instances) { if (CollectionUtils.isEmpty(instances)) { return; } _client.unregister(instances); updateInstances(instances, RegisterType.unregister); } }
InstanceRepository { public void unregister(final Set<Instance> instances) { if (CollectionUtils.isEmpty(instances)) { return; } _client.unregister(instances); updateInstances(instances, RegisterType.unregister); } InstanceRepository(final ArtemisClientConfig config); }
InstanceRepository { public void unregister(final Set<Instance> instances) { if (CollectionUtils.isEmpty(instances)) { return; } _client.unregister(instances); updateInstances(instances, RegisterType.unregister); } InstanceRepository(final ArtemisClientConfig config); Set<Instance> getAvailableInstances(); TextMessage getHeartbeatMessage(); void registerToRemote(final Set<Instance> instances); void register(final Set<Instance> instances); void unregister(final Set<Instance> instances); }
InstanceRepository { public void unregister(final Set<Instance> instances) { if (CollectionUtils.isEmpty(instances)) { return; } _client.unregister(instances); updateInstances(instances, RegisterType.unregister); } InstanceRepository(final ArtemisClientConfig config); Set<Instance> getAvailableInstances(); TextMessage getHeartbeatMessage(); void registerToRemote(final Set<Instance> instances); void register(final Set<Instance> instances); void unregister(final Set<Instance> instances);  }