I have written Akka Camel (extends Akka UntypedConsumerActor ) Actor which
is consuming messages from the JMS Queue. I want this Consumer to be
(Point#1) asynchronous, at the same time (Point#2)if a messages fails in
processing by child actor then JMS Queue can redeliver, So to achieve this
Hello,
I’m working on a project for which Akka seems to be a nice match, except
that I finally found a huge showstopper.
Indeed, in our project, most business logic is written in Java, but a few
portions are based on C#.
I heard about Akka.net, so I through it would be OK to mix an
I'm trying to create a marshaller using Akka Http for a nested map that I
want to return as Json from my Http API together with an appropriate status
code. In the real code the map is coming from a service call that might
fail. I would like to determine the status code based on this service
How can I create a dynamic flow? I'm developing a stream processing application
and I have a specific stage that I need perform a calculation over input
considering a parameter. And I need change this parameter dynamically. For
example:
case class CarStatus(position: Position, speed: Double)
Sounds like a stream of max speeds to me.
On Mon, Jul 27, 2015 at 3:15 PM, matheuslima...@gmail.com wrote:
I'm developing a system that process GPS and telemetry data and trigger
some events based on parameters. One example is speed violation. One stage
on my flow performs speed violation
I'm developing a system that process GPS and telemetry data and trigger
some events based on parameters. One example is speed violation. One stage
on my flow performs speed violation verification based on car speed and the
parameter maxSpeed. The problem is the user could change this parameter
what is a dynamic parameter, could you describe who can change it, when and
how many times?
--
Cheers,
√
On 27 Jul 2015 14:24, Matheus Lima matheuslima...@gmail.com wrote:
How can I create a dynamic flow? I'm developing a stream processing
application and I have a specific stage that I need
Hello everyone
I find PersistentFSMActor to be a very interesting concept.
I intend to use PersistentFSMActor as part of an automatic issue
management. I wonder if there is an example of its usage?
My hypothesis:
1. Each issue is represented as an PersistentFSMActor.
2. Each issue is born
Hi Luc,
in that case, can you provide a more information about the kind of
system you are running on? And it would be nice if we had a
tcpdump/wireshark dump that shows what's going on, so we can see at
least at which side things start to go wrong?
Johannes
On Mon, Jul 27, 2015 at 5:19 PM, Luc
Perhaps I've misunderstood, but it sounds like you need to process the
stream twice i.e. sequential, not parallel, processing.
That really isn't a use case for broadcast, AFIK.
A few questions:
1. Can the underlying stream be opened multiple times? For example, are
you reading elements
Hello,
If you check the git repository, i made some dumps with rawcap (to be able
to capture localhost tcp). The messages are simply not being sent for some
reason. When i tried sending messages with an interval from client side, it
shows that the connection eventually gets set up properly and
I have a Tcp-Server-Binding, realized as a class. Each instantiation
(binding to an IP:port) produces a stream of IncomingConnections. I also
have a Tcp-Client-Object which produces a stream of OutgoingConnections
as a result to given new addresses (targets). For either, the BidiFlow from
Hi Luc,
I can see the log messages you are seeing:
[DEBUG] [07/27/2015 12:01:01.059]
[api-akka.actor.default-dispatcher-9]
[akka://api/user/$a/flow-47-3-publisherSource-prefixAndTail]
Cancelling akka.stream.impl.MultiStreamOutputProcessor$SubstreamOutput@eda0238
(after: 5000 ms)
but I don't see
On Mon, Jul 27, 2015 at 12:22 PM, 'Johannes Rudolph' via Akka User List
akka-user@googlegroups.com wrote:
Hi Luc,
I can see the log messages you are seeing:
[DEBUG] [07/27/2015 12:01:01.059]
[api-akka.actor.default-dispatcher-9]
[akka://api/user/$a/flow-47-3-publisherSource-prefixAndTail]
Some events might not be allowed to be stored for over a certain time (they
contain personal information, positions etc).
For various other reasons as well (not related to Akka at all), I will have
to show my team I am able to control the disk usage, and delete messages.
At a later point, I
Hi folks,
I'm wondering whether *journal.max-message-batch-size* should be used to
batch events passed to *persist() *method ?
It is ignored now, is it expected?
--
Read the docs: http://akka.io/docs/
Check the FAQ:
http://doc.akka.io/docs/akka/current/additional/faq.html
How do I create an Unmarshaller / Marshaller which deserializes and
serializes java objects with java?
*(unfortuneatly my scala* is so bad so its not easy for me to translate
akka.http.javadsl.marshallers.jackson.Jackson.scala into java)
--
Read the docs: http://akka.io/docs/
or asked differently how do translate this class to java
https://github.com/akka/akka/blob/release-2.3-dev/akka-http-marshallers-java/akka-http-jackson/src/main/scala/akka/http/javadsl/marshallers/jackson/Jackson.scala
Am Montag, 27. Juli 2015 10:14:52 UTC+2 schrieb john@gmail.com:
How
or am I supposed to use Marshallers.toEntity() but this seems quite a lot
of work
Am Montag, 27. Juli 2015 10:14:52 UTC+2 schrieb john@gmail.com:
How do I create an Unmarshaller / Marshaller which deserializes and
serializes java objects with java?
*(unfortuneatly my scala* is so bad
Hi Yaroslav!
What do you mean?
It is applied - we flush a write when the accumulated events reach lenght of
that configured setting:
eventBatch.reverse.foreach { p ⇒
addToBatch(p)
if (!writeInProgress || maxBatchSizeReached) flushJournalBatch()
If you mean the persistAll(Seq()) than that's
I'm talking about `final def persist[A](events: immutable.Seq[A])(handler: A
⇒ Unit): Unit` in Akka 2.3
Looks like this has been fixed in Akka 2.4, thanks Konrad.
On Monday, July 27, 2015 at 11:48:04 AM UTC+3, Konrad Malawski wrote:
Hi Yaroslav!
What do you mean?
It is applied - we flush
persist(Seq) is == persistAll(Seq) in 2.4.x, with persist(Seq) being deprecated.
Thanks for the due diligence!
--
Cheers,
Konrad 'ktoso’ Malawski
Akka @ Typesafe
On 27 July 2015 at 10:59:56, Yaroslav Klymko (t3h...@gmail.com) wrote:
I'm talking about `final def persist[A](events:
22 matches
Mail list logo
