Merge pull request #25389 from chbatey/nit-1

Remove use of deprecated methods in java docs
This commit is contained in:
Patrik Nordwall 2018-08-23 11:26:39 +02:00 committed by GitHub
commit 8309dc9b45
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
11 changed files with 18 additions and 22 deletions

View file

@ -167,7 +167,7 @@ public class InitializationDocTest extends AbstractJavaTest {
GenericMessage<String> nonEmptyGenericMessage = new GenericMessage<String>("a"); GenericMessage<String> nonEmptyGenericMessage = new GenericMessage<String>("a");
genericTestActor.tell(emptyGenericMessage, getRef()); genericTestActor.tell(emptyGenericMessage, getRef());
expectNoMsg(); expectNoMessage();
genericTestActor.tell(nonEmptyGenericMessage, getRef()); genericTestActor.tell(nonEmptyGenericMessage, getRef());
expectMsgEquals("A"); expectMsgEquals("A");

View file

@ -50,7 +50,7 @@ public class SampleActorTest extends AbstractJavaTest {
assertTrue(expectMsgClass(String.class).startsWith("startsWith(guard):")); assertTrue(expectMsgClass(String.class).startsWith("startsWith(guard):"));
assertTrue(expectMsgClass(String.class).startsWith("contains(guard):")); assertTrue(expectMsgClass(String.class).startsWith("contains(guard):"));
expectMsgEquals(47110); expectMsgEquals(47110);
expectNoMsg(); expectNoMessage();
}}; }};
} }
} }

View file

@ -70,7 +70,7 @@ public class BuncherTest extends AbstractJavaTest {
final ActorRef probe = getRef(); final ActorRef probe = getRef();
buncher.tell(new Queue(42), probe); buncher.tell(new Queue(42), probe);
expectNoMsg(); expectNoMessage();
system.stop(buncher); system.stop(buncher);
}}; }};
} }

View file

@ -23,11 +23,7 @@ public class TellPatternJavaActor extends AbstractActor {
this.breaker = new CircuitBreaker( this.breaker = new CircuitBreaker(
getContext().dispatcher(), getContext().system().scheduler(), getContext().dispatcher(), getContext().system().scheduler(),
5, Duration.ofSeconds(10), Duration.ofMinutes(1)) 5, Duration.ofSeconds(10), Duration.ofMinutes(1))
.onOpen(new Runnable() { .addOnOpenListener(this::notifyMeOnOpen);
public void run() {
notifyMeOnOpen();
}
});
} }
public void notifyMeOnOpen() { public void notifyMeOnOpen() {

View file

@ -179,7 +179,7 @@ public class RecipeHold extends RecipeTest {
FiniteDuration timeout = FiniteDuration.create(200, TimeUnit.MILLISECONDS); FiniteDuration timeout = FiniteDuration.create(200, TimeUnit.MILLISECONDS);
sub.request(1); sub.request(1);
sub.expectNoMsg(timeout); sub.expectNoMessage(timeout);
pub.sendNext(1); pub.sendNext(1);
sub.expectNext(1); sub.expectNext(1);

View file

@ -79,17 +79,17 @@ public class RecipeManualTrigger extends RecipeTest {
FiniteDuration timeout = FiniteDuration.create(100, TimeUnit.MILLISECONDS); FiniteDuration timeout = FiniteDuration.create(100, TimeUnit.MILLISECONDS);
sub.expectSubscription().request(1000); sub.expectSubscription().request(1000);
sub.expectNoMsg(timeout); sub.expectNoMessage(timeout);
pub.sendNext(TRIGGER); pub.sendNext(TRIGGER);
sub.expectNext(new Message("1")); sub.expectNext(new Message("1"));
sub.expectNoMsg(timeout); sub.expectNoMessage(timeout);
pub.sendNext(TRIGGER); pub.sendNext(TRIGGER);
pub.sendNext(TRIGGER); pub.sendNext(TRIGGER);
sub.expectNext(new Message("2")); sub.expectNext(new Message("2"));
sub.expectNext(new Message("3")); sub.expectNext(new Message("3"));
sub.expectNoMsg(timeout); sub.expectNoMessage(timeout);
pub.sendNext(TRIGGER); pub.sendNext(TRIGGER);
sub.expectNext(new Message("4")); sub.expectNext(new Message("4"));
@ -132,17 +132,17 @@ public class RecipeManualTrigger extends RecipeTest {
FiniteDuration timeout = FiniteDuration.create(100, TimeUnit.MILLISECONDS); FiniteDuration timeout = FiniteDuration.create(100, TimeUnit.MILLISECONDS);
sub.expectSubscription().request(1000); sub.expectSubscription().request(1000);
sub.expectNoMsg(timeout); sub.expectNoMessage(timeout);
pub.sendNext(TRIGGER); pub.sendNext(TRIGGER);
sub.expectNext(new Message("1")); sub.expectNext(new Message("1"));
sub.expectNoMsg(timeout); sub.expectNoMessage(timeout);
pub.sendNext(TRIGGER); pub.sendNext(TRIGGER);
pub.sendNext(TRIGGER); pub.sendNext(TRIGGER);
sub.expectNext(new Message("2")); sub.expectNext(new Message("2"));
sub.expectNext(new Message("3")); sub.expectNext(new Message("3"));
sub.expectNoMsg(timeout); sub.expectNoMessage(timeout);
pub.sendNext(TRIGGER); pub.sendNext(TRIGGER);
sub.expectNext(new Message("4")); sub.expectNext(new Message("4"));

View file

@ -82,7 +82,7 @@ public class RecipeMissedTicks extends RecipeTest {
sub.request(1); sub.request(1);
sub.expectNext(3); sub.expectNext(3);
sub.request(1); sub.request(1);
sub.expectNoMsg(timeout); sub.expectNoMessage(timeout);
pub.sendNext(Tick); pub.sendNext(Tick);
sub.expectNext(0); sub.expectNext(0);

View file

@ -63,7 +63,7 @@ public class DeviceGroupTest extends JUnitSuite {
ActorRef groupActor = system.actorOf(DeviceGroup.props("group")); ActorRef groupActor = system.actorOf(DeviceGroup.props("group"));
groupActor.tell(new DeviceManager.RequestTrackDevice("wrongGroup", "device1"), probe.getRef()); groupActor.tell(new DeviceManager.RequestTrackDevice("wrongGroup", "device1"), probe.getRef());
probe.expectNoMsg(); probe.expectNoMessage();
} }
//#device-group-test-registration //#device-group-test-registration

View file

@ -49,10 +49,10 @@ public class DeviceTest extends JUnitSuite {
ActorRef deviceActor = system.actorOf(Device.props("group", "device")); ActorRef deviceActor = system.actorOf(Device.props("group", "device"));
deviceActor.tell(new DeviceManager.RequestTrackDevice("wrongGroup", "device"), probe.getRef()); deviceActor.tell(new DeviceManager.RequestTrackDevice("wrongGroup", "device"), probe.getRef());
probe.expectNoMsg(); probe.expectNoMessage();
deviceActor.tell(new DeviceManager.RequestTrackDevice("group", "wrongDevice"), probe.getRef()); deviceActor.tell(new DeviceManager.RequestTrackDevice("group", "wrongDevice"), probe.getRef());
probe.expectNoMsg(); probe.expectNoMessage();
} }
//#device-registration-tests //#device-registration-tests

View file

@ -66,7 +66,7 @@ public class DeviceGroupTest extends JUnitSuite {
ActorRef groupActor = system.actorOf(DeviceGroup.props("group")); ActorRef groupActor = system.actorOf(DeviceGroup.props("group"));
groupActor.tell(new DeviceManager.RequestTrackDevice("wrongGroup", "device1"), probe.getRef()); groupActor.tell(new DeviceManager.RequestTrackDevice("wrongGroup", "device1"), probe.getRef());
probe.expectNoMsg(); probe.expectNoMessage();
} }
@Test @Test

View file

@ -48,10 +48,10 @@ public class DeviceTest extends JUnitSuite {
ActorRef deviceActor = system.actorOf(Device.props("group", "device")); ActorRef deviceActor = system.actorOf(Device.props("group", "device"));
deviceActor.tell(new DeviceManager.RequestTrackDevice("wrongGroup", "device"), probe.getRef()); deviceActor.tell(new DeviceManager.RequestTrackDevice("wrongGroup", "device"), probe.getRef());
probe.expectNoMsg(); probe.expectNoMessage();
deviceActor.tell(new DeviceManager.RequestTrackDevice("group", "wrongDevice"), probe.getRef()); deviceActor.tell(new DeviceManager.RequestTrackDevice("group", "wrongDevice"), probe.getRef());
probe.expectNoMsg(); probe.expectNoMessage();
} }
@Test @Test