我是新来的拉各姆斯卡拉。因为我使用ElasticSearch将数据存储为文档。我也有外部Cassandra运行。当我调用一个操作将数据存储在cassandra和ElasticSearch中时。由于我的数据成功地存储在cassandra中,但没有存储在ElasticSearch中。我已经在loader和lagomunmanagedservices中包含了所有的依赖项,用于ElasticSearch。我的ElasticSearch加载程序类
lazy val elasticSearch= serviceClient.implement[ElasticSearch]
lazy val indexStore:IndexStore[SearchResult]=wire[ElasticSearchIndexStore]
我的ElasticSearch的build.sbt文件是
lagomUnmanagedServices in ThisBuild := Map("elastic-search" -> "http://127.0.0.1:9200")
lagomCassandraEnabled in ThisBuild := false
lagomUnmanagedServices in ThisBuild := Map("cas_native" -> "http://localhost:9042")
ElasticSearch服务呼叫
override def descriptor: Descriptor ={
named("elastic-search")
.withCalls(
restCall(Method.POST,"/:index/category/:id/_update",updateIndexCategory _)
.withAutoAcl(true)
我的服务方式
trait ElasticSearch extends Service
{
def updateIndexCategory(index:String,id:UUID):ServiceCall[UpdateIndexCategoryData,Done]
}
我在外部运行ElasticSearch也。但我不知道为什么这个消息显示
com.lightbend.lagom.internal.scaladsl.registry.ScalaServiceRegistryClient [] - serviceName=[elastic-search] was not found. Hint: Maybe it was not started?
提前谢谢。
1条答案
按热度按时间ee7vknir1#
我发现错误出现在cassandra的ManagedServices中。我把它改成下面的样子