Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
自定义 Supervision.Decider 未捕获 ActorPublisher 产生的异常
我正在构建一个将由第三方使用的库 在我的方法之一中 我返回Stream Item 它是根据分页 REST API 调用的结果异步生成的 我正在使用我的修改BulkPuller异步 我的代码是here 我希望我的流的接收者能够处理错误 根据文
scala
akka
akkastream
Spray.io:无法编译测试规范
我有以下服务 trait PingService extends MyHttpService val pingRoutes path ping get complete message gt pong MyHttpService是一个扩展的
scala
Testing
akka
spray
获取现有的或创建新的 akka actor
我正在尝试使用 ActorFor 获取现有的 ActorRef 或创建一个新的 ActorRef 如果它不存在 我有以下代码 但它似乎没有按预期工作 isTermminate 始终为 true ActorSystem system Acto
Java
akka
Actor
Akka:如何查找集群中的当前节点?
从 Akka actor 内部 如何找到集群的节点 即本节点认为当前可以访问的节点 谢谢 丹尼尔 您实际上不需要订阅ClusterDomainEvent or MemberEvent 您只需访问state集群扩展的成员 例如 val clu
Java
scala
clustercomputing
akka
distributedcomputing
一旦参与者被放入路由器,就会出现“遇到死信”
这就是我所发现的 但我一生都无法找到原因 我正在创建 打印机 参与者 它们基本上要么不执行任何操作 要么根据收到的消息类型打印消息 class Printer extends Actor def receive case m SomeMes
scala
akka
在能够处理其他消息之前初始化参与者
我有一个演员创造了另一个演员 class MyActor1 extends Actor val a2 system actorOf Props new MyActor 123 第二个参与者在创建后必须初始化 引导 自身 并且只有在此之后它才
scala
Asynchronous
akka
Future
如何指定 Spray Content-Type 响应标头?
我知道喷雾为我做到了这一点 但我仍然想用我的标头覆盖它 如何覆盖响应中的标头 我的回复如下 case HttpRequest GET Uri Path something gt sender HttpResponse entity key
scala
akka
spray
使用 Play 2.6 和 akka 流的 Websocket 代理
我正在尝试使用 Play 和 akka 流为 Websocket 连接创建一个简单的代理 交通流向是这样的 Client request gt gt request Server Proxy Client response lt lt re
scala
playframework
akka
akkahttp
akkastream
Akka cluster-sharding:入口 Actor 可以拥有动态道具吗
Akka Cluster Sharding 看起来与我必须跨 Akka 节点创建有状态持久 Actor 的单个实例的用例非常匹配 我不清楚是否有可能有一个需要参数来构造它的 Entry actor 类型 或者也许我需要重新考虑 Entry
scala
akka
akkacluster
Akka:参与者当前邮箱大小或等待处理的消息数
我试图找出等待演员处理的待处理队列项目的数量 我确信必须有一种方法可以从 actor 上下文或 context system mailboxes 等中引用 这是代码示例 class SomeActor extends Actor overr
scala
akka
为什么 akka 的 spring 集成文档仅存在于 1.3.1 而不适用于后续版本
有一个关于集成方式的链接AKKA and Spring 或者更好地说 如何使用Akka演员在spring环境 http doc akka io docs akka modules 1 3 1 modules spring html 其实有m
Java
Spring
Integration
akka
如何测试 Akka actor 是在 Scala 中创建的
我正在尝试编写一个测试来验证下面的演员是否正在创建一个 heartBeatExpireWorker 和一个 heartBeatAccepter 但我不知道该怎么做 首先 我想我可以使用 Mockhito 模拟或间谍来代替上下文 然后验证我是
scala
akka
scalatest
testkit
Akka 实践(二)- java开发demo1
下面就Akka的一个java demo来说明Akka 如何运作的 1 首先下载 Akka的官方包 下载地址为 http akka io downloads 我下载的是 Akka的2 3 15 解压这个压缩包 准备拷贝相关的jar包到自己的工
Java
akka
akka基础
基本概念消息传递API 通用API消息传递方式 Future机制Actor生命周期处理状态和错误 监督kill actor生命周期监控和DeathWatch安全重启状态 纵向扩展 Router调度方式使用策略 横向扩展 订阅集群事件启动 退
akka
AKKA入门
1 Guardian java package com example demo import akka actor typed javadsl ActorContext import akka actor typed ActorRef i
akka
akka基础
基本概念消息传递API 通用API消息传递方式 Future机制Actor生命周期处理状态和错误 监督kill actor生命周期监控和DeathWatch安全重启状态 纵向扩展 Router调度方式使用策略 横向扩展 订阅集群事件启动 退
akka
«
1 ...
4
5
6
7
8
9
10