raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

!cto #17454 Introduce DistributedPubSubSettings

Browse source 
* rename DistributedPubSubExtension to DistributedPubSub
This commit is contained in:
Patrik Nordwall 2015-05-07 11:01:59 +02:00
parent 7ab5da21d3
commit b8594d475e
10 changed files with 154 additions and 90 deletions
Download patch file Download diff file Expand all files Collapse all files

12
akka-cluster-tools/src/test/java/akka/cluster/pubsub/DistributedPubSubMediatorTest.java
View file

@ -4,7 +4,10 @@
package akka.cluster.pubsub;
import com.typesafe.config.ConfigFactory;
import akka.testkit.AkkaJUnitActorSystemResource;
import org.junit.ClassRule;
import org.junit.Test;
@ -19,7 +22,10 @@ public class DistributedPubSubMediatorTest {
@ClassRule
public static AkkaJUnitActorSystemResource actorSystemResource =
new AkkaJUnitActorSystemResource("DistributedPubSubMediatorTest");
new AkkaJUnitActorSystemResource("DistributedPubSubMediatorTest",
ConfigFactory.parseString(
"akka.actor.provider = \"akka.cluster.ClusterActorRefProvider\"\n" +
"akka.remote.netty.tcp.port=0"));
private final ActorSystem system = actorSystemResource.getSystem();
@ -47,7 +53,7 @@ public class DistributedPubSubMediatorTest {
public Subscriber() {
ActorRef mediator =
DistributedPubSubExtension.get(getContext().system()).mediator();
DistributedPubSub.get(getContext().system()).mediator();
// subscribe to the topic named "content"
mediator.tell(new DistributedPubSubMediator.Subscribe("content", getSelf()),
getSelf());
@ -70,7 +76,7 @@ public class DistributedPubSubMediatorTest {
// activate the extension
ActorRef mediator =
DistributedPubSubExtension.get(getContext().system()).mediator();
DistributedPubSub.get(getContext().system()).mediator();
public void onReceive(Object msg) {
if (msg instanceof String) {