@Test public void test_attach_stripe_validation_fail_src_activated() { when(topologyServiceMock("localhost", 9411).isActivated()).thenReturn(true); AttachCommand command = newCommand(); command.setSourceAddress(createUnresolved("localhost", 9411)); command.setOperationType(STRIPE); command.setDestinationAddress(createUnresolved("localhost", 9410)); assertThat( command::run, is(throwing(instanceOf(IllegalArgumentException.class)).andMessage(is(containsString("cannot be attached since it is part of an existing cluster"))))); }
public void setSourceAddress(InetSocketAddress sourceAddress) { this.sourceAddress = sourceAddress; }
AttachCommand extends TopologyCommand { public void setSourceAddress(InetSocketAddress sourceAddress) { this.sourceAddress = sourceAddress; } }
AttachCommand extends TopologyCommand { public void setSourceAddress(InetSocketAddress sourceAddress) { this.sourceAddress = sourceAddress; }  }
AttachCommand extends TopologyCommand { public void setSourceAddress(InetSocketAddress sourceAddress) { this.sourceAddress = sourceAddress; }  void setSourceAddress(InetSocketAddress sourceAddress); void setRestartWaitTime(Measure<TimeUnit> restartWaitTime); void setRestartDelay(Measure<TimeUnit> restartDelay); @Override void validate(); }
AttachCommand extends TopologyCommand { public void setSourceAddress(InetSocketAddress sourceAddress) { this.sourceAddress = sourceAddress; }  void setSourceAddress(InetSocketAddress sourceAddress); void setRestartWaitTime(Measure<TimeUnit> restartWaitTime); void setRestartDelay(Measure<TimeUnit> restartDelay); @Override void validate();  }