will give me
exceptions. The exceptions will also affect other rules which can run with
the current data. Is there any way to handle exception in rule condition
for specific rule and restrict it to disturb the independent rules.
Regards,
Bishnu Shankar Pandey
I saw the Example. I tried implementing it with queue but the issue that I
am facing is that if the queue becomes empty fr some time the stream is
getting completed. Is there any way to create a continuous stream source
and if there if the queue is empty wait till it got any element and then
ood examples (include some with queues) at
> https://doc.akka.io/docs/akka/current/stream/stream-customize.html#custom-processing-with-graphstage
>
>
> BR, Felix
>
> > Am 06.11.2019 um 16:14 schrieb Bishnu Shankar Pandey <
> bishnu...@flutura.com >:
> >
> >
Hi All,
My use case is I want to create an Akka stream in which the source is a
java Queue. The stream should keep on the pooling values from the queue and
if the queue is empty then wait for the values in the queue. Akka stream
queue is another option but if in case of any failure I want to
for routing and handling them in Akka.
>
> Best regards,
> Brian Maso
>
> On Tue, Mar 26, 2019 at 3:46 AM Bishnu Shankar Pandey <
> bishnu.pan...@flutura.com> wrote:
>
>> I want to solve two scenarios :
>>
>> 1. I have a sender Actor and a Receiver Actor h
I want to solve two scenarios :
1. I have a sender Actor and a Receiver Actor how will the sender actor
know that the receiver actor is not responding. Terminated case can be used
to get a notification but what is the latency or the response time of the
*Terminated
message*. I can't miss
I am trying to create an Akka Sharding Cluster. I want to use proxy only
mode on one of the nodes just to route the message to the shard regions. I
am getting the following Warning:
[WARN] [02/11/2019 17:04:17.819]
[ClusterSystem-akka.actor.default-dispatcher-21]
I want to persist events in Akka only when there is a failure in the actor.
I am trying the following code to achieve persistence.
package persistence
import akka.actor._import akka.persistence._
case class Cmd(data: String)case class Evt(data: String)
case class ExampleState(events:
