1回答
我有一个处理传入http请求的代码，如下所示 public Function < HttpRequest, HttpResponse > handleRequest() { public HttpResponse apply(HttpRequest request) throws Exception {
浏览 18提问于2019-02-08得票数 4
回答已采纳
我对该产品的一个非常大的烦恼是，几乎所有的类都出现在javadsl和scaladsl名称空间中。
不知何故，IntelliJ将首先从javadsl命名空间自动导入类。这会导致语法错误和大量浪费时间。如何永久阻止/隐藏javadsl命名空间？也许SBT中有一些设置，所以当我导入akka流依赖项时，我告诉SBT关闭javadsl命名空间的可见性。或者其他一些解决方案可以阻止IntelliJ从javadsl命名空间自动导入类。
浏览 1提问于2017-09-12得票数 1
回答已采纳
这是一堂课：import akka.NotUsed;import akka.http.javadsl.ConnectHttp;import akka.http.javadsl.model.ContentTypes;import akka.http.javadsl
浏览 5提问于2020-03-03得票数 0
回答已采纳
我尝试使用下面的导入，但'akka.http.javadsl.server‘似乎不可用(尽管当我下载jar文件并解压缩它时，我可以看到包)。其他包是可见的。我已尝试清除IntelliJ缓存。import akka.NotUsed; import akka.http.javadsl.ConnectHttp;import akka.http.javadsl.Http;
import akka.http.javadsl.ServerB
浏览 4提问于2017-06-14得票数 0
回答已采纳
code/flow-mobile/server/src/main/scala/in/flow/server/FlowServerStack.scala:108:型错配；
override def withStatus(statusCode: Int):
akka.http.javadsl</
浏览 3提问于2017-02-27得票数 0
1回答
我试图动态地添加传递到函数concatOrNotFound中的服务import akka.http.javadsl.model.HttpRequest;import akka.japi.function.Function;
Function<HttpRequest, java.util.concurrent.CompletionStage[akka.http.
浏览 1提问于2021-06-09得票数 0
回答已采纳
1回答
java.util.concurrent.TimeUnit;
import akka.actor.ActorSystem;import akka.http.javadsl.Http;import akka.http.javadsl.model.HttpRequest;
import akka.http.javads
浏览 3提问于2017-10-06得票数 1
akka.Done; import akka.actor.typed.ActorSystem; import akka.stream.javadsl.Sink; import akka.stream.javadsl.Tcp;
import akka.stream.j
浏览 3提问于2021-08-09得票数 0
回答已采纳
to compile - all classes are up to date at com.lightbend.lagom.internal.javadsl.registry.ServiceRegistryModule.configureForkJoinWorkerThre
浏览 10提问于2017-01-18得票数 0
回答已采纳
at com.lightbend.lagom.internal.javadsl.api.ServiceReader$$anonfun$4.apply(ServiceReader.scala:103)at com.lightbend.lagom.internal.javadsl.api.ServiceReader$$anonfun$4.apply(ServiceReader.scala:88)(JavadslServerBuilder.scala:66)
at com.lightbend.lagom.internal.javadsl.
浏览 16提问于2018-08-08得票数 1
2回答
was while locating for parameter<init>at bindServices<init> at
com.lightbend.lagom.<
浏览 0提问于2017-10-14得票数 1
我有一个HttpRequest的实例(来自akka.http.javadsl.model)，从它我可以得到RequestEntity，但是我不知道如何从实体中提取字符串。
浏览 2提问于2016-07-18得票数 4
import akka.NotUsed;import com.lightbend.lagom.javadsl.persistence.cassandra.CassandraSession;import javax.inject.Inject;
import akka.stream.javadsl.Source
浏览 3提问于2018-05-28得票数 1
回答已采纳
final Sink<Integer, CompletionStage<Integer>> sinkUnderTest = .map(i -> i * 2)Source.from(Arrays
浏览 9提问于2019-11-21得票数 2
回答已采纳
当服务在库贝开始时，我有错误： at com.lightbend.lagom.internal.javadsl.persistence.jpa.JpaSessionImpl.lambda$cre
浏览 2提问于2020-09-16得票数 0
回答已采纳
could not find implicit value for parameter um: akka.http.scaladsl.unmarshalling.Unmarshaller[akka.http.javadsl.model.ResponseEntity
浏览 0提问于2018-05-04得票数 0
回答已采纳
我正在将应用程序从XML转换为JavaDSL。我正在苦苦挣扎的部分是向RabbitMQ发布消息的部分。在XML版本中，动态地从报头中提取路由密钥。但是，在JavaDSL版本中，这是行不通的。invoice") .get();如何在使用JavaDSL
浏览 8提问于2022-10-07得票数 2
回答已采纳
1回答
我正在使用： akka.persistence.testkit.javadsl.EventSourcedBehaviorTestKit`akka.persistence.testkit.javadsl.PersistenceTestKit 我创建我的测试工具包： static final ActorTestKit testKit =
浏览 15提问于2020-08-19得票数 0
回答已采纳
我有一个简单的TCP服务器，它回显从客户端连接接收的数据。当发生客户端连接时，，我想立即用一些数据进行响应。为了简单起见，ByteBuffer。我想允许n个连接。目前，我是通过一个连接计数变量，只是不调用句柄。我认为这不是正确的方法。我希望能够在任何时候通过特定的连接从服务器发送消息。因此，如果我有3个连接，我想选择一个连接，我想要发送一条消息给.功能，关闭连接后关闭服务器。任何指针/代码片段都将不胜感激。// handles individual connections
final Sink<IncomingConnection, Comple
浏览 2提问于2021-07-13得票数 0
云服务器
ICP备案
对象存储
腾讯会议
实时音视频
腾讯云开发者
