- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
出于学习目的,我正在尝试实现一个从远程 Actor 获取数据的简单 Play 应用程序。 Actor 的代码如下:
import akka.actor.{Props, ActorSystem, Actor}
class NumbersServer extends Actor {
var number = 0
protected def receive = {
case 'next => {
number += 1
number
}
case 'reset => number = 0
case 'exit => context.stop(self)
case 'get => sender ! number
}
}
object Server {
def main(args: Array[String]) {
val system = ActorSystem("ServerSystem")
val server = system.actorOf(Props[NumbersServer], "server")
}
}
我把它打包成一个jar,然后从命令行启动它。如果我尝试从另一个窗口打开的 Scala 控制台向该参与者发送消息,一切正常。现在我想从 Play 框架中获取 Actor 。在Application
对象我定义了以下方法:
def numbers = Action {
Ok(views.html.numbers(Client.actor.path.name))
}
然后在models
包我定义了客户端对象:
object Client {
import play.api.Play.current
val actor = Akka.system.actorFor("akka://ServerSystem@127.0.0.1:2552/user/server")
}
numbers.html.scala
文件:
@(message: String)
@main("Header") {
<h1>@message</h1>
}
所以我希望当我转到 127.0.0.1:9000/numbers
时,我会得到一个页面,其中包含服务器参与者的路径。而不是这个,我得到 <h1>deadLetters</h1>
.我做错了什么以及应该如何正确完成?
最佳答案
请按照给出的配置
https://groups.google.com/forum/#!topic/akka-user/Vw-B8nQeagk
同时添加 akka-remote 依赖
val appDependencies = Seq(
"com.typesafe.akka" % "akka-remote" % "2.0.2"
)
关于scala - Play framework 2.0 - deadLetters 而不是 Actor,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/10040503/
在我的小微服务中,我创建了一个 Producer Kafka 以这种方式在 DeadLetter 中发送带有错误的消息(JSON 格式的错误消息): @Component public class K
我想从服务总线队列中删除死信消息。特别是,该值称为 DeadLetterMessageCount,您可以通过右键单击 SB 的“属性”来找到它项目的服务器资源管理器中的队列(如果使用 SB 队列)。
我不知道为什么我有错误“deadLetters” class MyActor extends Actor { private def getIdList = Future { blocking(g
如果主题订阅中的任何消息的处理失败,我希望该消息从队列中删除,而不是将其发送到死信订阅。有办法做到这一点吗? 是否有一个azure cli可用于清除DeadLetter订阅中的消息? 最佳答案 这需要
我已经实现了退避指数重试。所以基本上,如果有任何异常,我会克隆消息,然后通过添加一些延迟将其重新提交到队列。 现在我面临两个问题 - 1)我发现当我克隆并重新提交回队列时,交付计数没有增加2) 如果达
我已经实现了退避指数重试。所以基本上,如果有任何异常,我会克隆消息,然后通过添加一些延迟将其重新提交到队列。 现在我面临两个问题 - 1)我发现当我克隆并重新提交回队列时,交付计数没有增加2) 如果达
出于学习目的,我正在尝试实现一个从远程 Actor 获取数据的简单 Play 应用程序。 Actor 的代码如下: import akka.actor.{Props, ActorSystem, Act
我正在尝试使用无服务器框架创建 AWS SQS 死信队列 这个想法是有一个 SQS 来触发一个 Lambda 函数, 并有另一个 SQS 作为 DeadLetterQueue,即。在 Lambda 失
我可以使用下面的代码从 Deadletter 向 Main 发送消息,但问题无法完成该消息。 这一行出错 -等待 deadletterReceiver.CompleteAsync(newMessage
我正在使用服务总线队列触发功能。 当我们手动(并且至关重要地立即)DeadLetter BrokeredMessage 时,它确实进入了死信队列。 但是,运行时报告以下错误: The lock s
我是一名优秀的程序员,十分优秀!