Saya memiliki masalah dengan menulis ulang aplikasi saya ke Akka Cluster Sharding. Saya memiliki Sharded Entity sebut saja A, dan sekelompok aktor lokal di setiap node, sebut saja salah satunya B. Sekarang saya mengirim pesan B -> A yang berisi (String, ActorRef[B]) dan saya ingin membalas A -> B ....
9 Mei 2021, 14:33
Bagaimana cara menghentikan kluster SELURUH dengan sharding (mencakup beberapa mesin - node) dari satu aktor? Saya tahu saya dapat menghentikan sistem aktor pada simpul 'ini' context.system.terminate() Saya tahu saya bisa menghentikan Daerah Sharding lokal. Saya menemukan .prepareForFullClusterShutd....
29 April 2021, 23:56
Saya mencoba ask aktor yang akan membalas dengan Coba: val reply = actor.ask[Try[MyReply]](MyCommand) Namun ketika balasan datang dari aktor di node lain di cluster saya mendapatkan kesalahan berikut di log: Failed to serialize message [scala.util.Success]. Cukup menarik, jika saya menggunakan Opt....
8 Desember 2020, 18:42
Apa yang dimaksud dengan "mulai ulang sistem aktor" untuk kluster akka? Seharusnya saya memiliki seednode A dan node B lain, dan kode ini dieksekusi: let clusterObjOnNodeB = Cluster.Get actorSystemB clusterObjOnNodeB.JoinSeedNodes <| ImmutableList.Create<Address>(seq[ Address.Parse @"path to ....
24 September 2020, 11:28
Saya telah membaca blog, mendengarkan podcast, dan membaca dokumentasi Akka untuk sementara waktu sekarang, tetapi saya masih tidak bisa mengatakan bahwa saya benar-benar mengerti apakah model aktor tepat untuk apa yang saya coba selesaikan. Mari kita ambil contoh membangun aplikasi yang memberi tah....
17 September 2020, 17:02
Jadi saya membangun cluster akka dengan 2.6.6 dan saya menyiapkan master node yang akan menjadi seed node dan worker node yang dapat secara dinamis meninggalkan atau memasuki cluster. Saya juga memiliki node "klien" yang harus berbicara dengan node master, mungkin router tetapi tidak dengan pekerja....
19 Juni 2020, 03:27
Saya memiliki Sumber AMQP dan Wastafel AMQP dengan Deklarasi: List<Declaration> declarations = new ArrayList<Declaration>() {{ add(QueueDeclaration.create(sourceExchangeName)); add(BindingDeclaration.create(sourceExchangeName, sourceExchangeName).withRoutingKey(sourceRoutingKey)); }}....