回答情况：
提问时间：
问题标签：
Actor, ActorSystem, Props}import akka.cluster.pubsub.DistributedPubSubClusterExample]), "clusterExample") private val mediator = DistributedPubSubbind-hostname = "0.0.0.0"
浏览 2提问于2017-02-05得票数 0
回答已采纳
我正在对一个使用集群工具DistributedPubSub的参与者进行单元测试。对于测试，我使用的是Akka.net的TestKit。显然，在TestKit中，系统参与者Sys没有DistributedPubSub工具，并且它在访问该工具时抛出一个空指针异常。这是将执行元创建为Sys的子级时失败的代码：有没有一种方法可以模拟它或者创建一个参与者探测器来将它与
浏览 7提问于2016-12-21得票数 4
回答已采纳
{DistributedPubSub, DistributedPubSubMediator} import DistributedPubSubMediator.Publish
import akka.cluster.client.Clus
浏览 3修改于2017-02-02得票数 0
回答已采纳
Props.create(Publisher.class, () -> new Publisher()); this.mediator = DistributedPubSub.getSubscriber.class, () -> new Subscriber()); ActorRef mediator = DistributedPubSub.get
浏览 3修改于2017-12-11得票数 5
回答已采纳
val mediator = DistributedPubSub(context.system).mediator
mediator !
浏览 2提问于2020-08-24得票数 0
回答已采纳
{DistributedPubSub, DistributedPubSubMediator}
val mediator = DistributedPubSub(context.system{DistributedPubSub, DistributedPubSubMediator}
import com.typesaf
浏览 8修改于2017-08-24得票数 0
回答已采纳
}val mediator = DistributedPubSub(system).mediatorDistributedPubSubMediator.Put(seed)class SenderActor(senderLike:SenderLike) extends Actor {
val mediator = DistributedPubSub
浏览 3提问于2015-11-19得票数 1
回答已采纳
公共类订阅服务器扩展了UntypedActor { ActorRef mediator =
DistributedPubSub.get
浏览 0提问于2017-04-11得票数 0
从“现有”文档中，可以使用以下方法: DistributedPubSub.Get(Context.System).Mediator；
然而，一旦我启动一个中介，我就会得到一个“关联”异常。
浏览 1提问于2016-03-26得票数 3
作为参考，订阅服务器在中如下所示 val mediator = DistributedPubSub(context.system
浏览 6修改于2016-02-03得票数 4
回答已采纳
_mediator = DistributedPubSub.Get(Context.System).Mediator;
// ...
浏览 7提问于2021-08-10得票数 0
回答已采纳
ClusterSystem@127.0.0.1:2551"auto-down-unreachable-after = 10sakka.extensions = ["akka.cluster.pubsub.DistributedPubSubClusterSystem@127.0.0.1:2553"auto-down-unreachable-after = 10sakka.extensions = ["akka.cluster.pubsub.DistributedPubSub出版商：
public
浏览 4修改于2017-01-30得票数 1
回答已采纳
我使用的是Playplay.api.mvc.WebSocket和akka.contrib.pattern.DistributedPubSub事件，这已经很好了。
浏览 0提问于2015-06-01得票数 1
回答已采纳
}
"akka.cluster.metrics.ClusterMetricsExtension",
"akka.cluster.pubsub.DistributedPubSub
浏览 4修改于2016-12-30得票数 0
回答已采纳
设置很好，我已经连接了前端和集群，但是从ClusterReceptionist发送到DistributedPubSub mediator的Send消息被传递到了DeadLetters。
浏览 4提问于2017-05-04得票数 0
不知何故，我无法通过DistributedPubSub中介器询问/告知订阅者和生产者(两者都运行在不同的节点上)。
浏览 2修改于2015-07-21得票数 4
auto-down-unreachable-after = 10s}akka.extensions=["akka.cluster.pubsub.DistributedPubSub
浏览 29修改于2016-06-28得票数 1
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号