[akka-user] Akka Camel ,AutoAck issue - (Needs to make Akka Camel consumer Actor asynchronous and at the same time needs jms message redelivery )

2015-07-27 Thread vipin mandloi
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

[akka-user] Akka interoperability with Akka.net ?

2015-07-27 Thread Alexandre Vermeerbergen
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

[akka-user] Marshalling (nested) maps to http response in Akka Http combined with status code

2015-07-27 Thread Jeroen Rosenberg
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

[akka-user] Akka stream dynamic flow

2015-07-27 Thread Matheus Lima
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)

Re: [akka-user] Akka stream dynamic flow

2015-07-27 Thread Viktor Klang
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

Re: [akka-user] Akka stream dynamic flow

2015-07-27 Thread matheuslimaufc
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

Re: [akka-user] Akka stream dynamic flow

2015-07-27 Thread Viktor Klang
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

[akka-user] Is there any example/documentation for PersistentFSMActor?

2015-07-27 Thread Nader Aeinehchi
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

Re: [akka-user] Re: Akka-http websockets connection fails 95% of the time

2015-07-27 Thread 'Johannes Rudolph' via Akka User List
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

Re: [akka-user] Akka Streams - Issue with processing different length streams through drop/zip

2015-07-27 Thread Lance Arlaus
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

Re: [akka-user] Re: Akka-http websockets connection fails 95% of the time

2015-07-27 Thread Luc Klaassen
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

[akka-user] Dynamic Routing for multiple partial Flows

2015-07-27 Thread Markus Bossert
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

Re: [akka-user] Re: Akka-http websockets connection fails 95% of the time

2015-07-27 Thread 'Johannes Rudolph' via Akka User List
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

Re: [akka-user] Re: Akka-http websockets connection fails 95% of the time

2015-07-27 Thread Endre Varga
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]

Re: [akka-user] Re: Akka Persistence, Cassandra and compaction strategies (DTCS)

2015-07-27 Thread Anders Båtstrand
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

[akka-user] journal.max-message-batch-size and size of events passed to persist() method

2015-07-27 Thread Yaroslav Klymko
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

[akka-user] How do I create an Unmarshaller / Marshaller in java?

2015-07-27 Thread john . vieten
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/

[akka-user] Re: How do I create an Unmarshaller / Marshaller in java?

2015-07-27 Thread john . vieten
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

[akka-user] Re: How do I create an Unmarshaller / Marshaller in java?

2015-07-27 Thread john . vieten
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

Re: [akka-user] journal.max-message-batch-size and size of events passed to persist() method

2015-07-27 Thread Konrad Malawski
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

Re: [akka-user] journal.max-message-batch-size and size of events passed to persist() method

2015-07-27 Thread Yaroslav Klymko
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

Re: [akka-user] journal.max-message-batch-size and size of events passed to persist() method

2015-07-27 Thread Konrad Malawski
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: