alpakka

0熱

1答えて

alpakkaスリックコネクタを使ってmysqlにcaseオブジェクトを挿入するには

MySQLにデータを挿入するコードを書いています。私はAlpakka Slick Connectorを使うことに決めました。その例を使用します：https://developer.lightbend.com/docs/alpakka/latest/slick.html#using-a-slick-flow-or-sink私は正常にDBにデータを追加しましたが、SQLコマンドを含む文字列をシンクに渡

0熱

1答えて

Alpakka JMSトランザクション

私はAlpakkaとそのJMSコネクタで遊んで、Oracle AQからデータをデキューします。私は、以下の非常に基本的な実装を、thisガイドに従って実行することができます。私はそれをトランザクションにすることができますので、例外がスローされるとメッセージが失われないことを保証できます。 object ConsumerApp extends App { implicit val sys

1熱

1答えて

alpakka、JMSおよびcorrelationId in jms.Message in

私はクライアントとサーバーの間でメッセージの送受信にalpakka（Scala）とJMSコネクタを使用しました。すべての作業は完璧ですが、わかりません - どのようにjms.MessageでcorrelationIdを設定できるか何か考えてください。ありがとうございました。

0熱

1答えて

アクター/エージェントシステムはiPaaSを冗長化しますか？

私は、Akkaを（おそらくAlpakkaおよび/またはLagomと共に）使用するアプリケーションがあるとしましょう。 Red Hat JBoss FuseのようなiPaaSのメリットはありますか？「はい」の場合、その特典は何ですか？もしそうでなければ、それはiPaaSの代替手段であるアクターシステムの一部と呼ばれていますか？

1熱

1答えて

Akkaはalpakka jmsのKillSwitchをストリームします

私はalpakkaを使用して複数のjmsSource（異なるキュー用）を開始するシナリオを持っています。私はまた、キューをいつでも切り離す必要があります。そこで、以下のようにjms akkaストリームにKillSwitchを追加しました： - trait MessageListener { lazy val jmsPipeline = jmsSource .map { x =

1熱

1答えて

Play Framework 2.6 Alpakka S3ファイルアップロード

私はPlay Framework 2.6（Scala）とAlpakka AWS S3 Connectorを使用して、ファイルをS3バケットに非同期でアップロードします。私のコードは次のようになります： def richUpload(extension: String, checkFunction: (String, Option[String]) => Boolean, cannedAcl: Ca

0熱

1答えて

なぜAkka Streamsアプリケーションは正常に終了しないのですか？

は私がAlpakkaカサンドラライブラリに package com.abhi import akka.actor.ActorSystem import akka.stream.{ActorMaterializer, ClosedShape} import akka.stream.alpakka.cassandra.scaladsl.CassandraSource import akka.

0熱

1答えて

Alpakkaカサンドラ・フローの使用

は、私はそれはそれは非常に簡単で、ソースとシンクとしてカサンドラを使用できるようになりAlpakkaカサンドラhere のドキュメントを読んでいます。しかし、フローの使用はどうでしょうか。私が意味するのは、カッサンドラをソースまたはシンクとして使用していないことです。データを参照することになります。 Alpakkaを使用すると可能ですか？または自分自身でCassandra jdbcコードを記述す

1熱

1答えて

Alpakka - S3からKryoシリアル化されたオブジェクトを読み取る

私はKryoシリアル化されたバイナリデータをS3（数千のシリアル化オブジェクト）に保存しています。アルパッカは、data: Source[ByteString, NotUsed]と内容を読み取ることができます。しかし、Kryoフォーマットはデリミタを使用しないので、シリアル化された各オブジェクトをdata.via(Framing.delimiter(...))を使用して別のByteStringに