Re: [akka-user] Akka Streams Camel?

That would be a great contribution to the Akka Streams Intregration initiative, see blog post http://blog.akka.io/integrations/2016/08/23/intro-alpakka Please create a pull request in akka-stream-contrib. It should be a separate sub-project, similar to akka-stream-contib-amqp Cheers, Patrik

[akka-user] Akka Streams Camel?

Hi, I am working on a project where we are using akka-streams and we have coded our own CamelSource and CamelSink. Basically a Source that can be any Camel consumer and a Sink that can be any Camel producer. I was wondering if it could be a good idea to provide those as part of some separated

Re: [akka-user] How to "scatter-gather" with Akka Stream?

Thanks! > On Aug 24, 2016, at 12:00 PM, Viktor Klang wrote: > > http://doc.akka.io/api/akka/2.4/?_ga=1.252408265.1579561034.1353497989#akka.stream.scaladsl.Partition > >

Re: [akka-user] How to "scatter-gather" with Akka Stream?

http://doc.akka.io/api/akka/2.4/?_ga=1.252408265.1579561034.1353497989#akka.stream.scaladsl.Partition http://doc.akka.io/api/akka/2.4/?_ga=1.252408265.1579561034.1353497989#akka.stream.scaladsl.Merge On Wed, Aug 24, 2016 at 8:44 PM, Drew Kutcharian wrote: > Source class

Re: [akka-user] (AKKA V2.3.9) Akka configured seed nodes are leaving cluster and unreachable/reachable warning message is getting logged. ::: Spring Class (ClassPathXmlApplicationContext) serializatio

and remote deployment Props is also a suspect ons 24 aug. 2016 kl. 20:48 skrev Justin du coeur : > It's not so much "how to avoid" -- you are presumably trying to send > something that contains a reference to that Context, and you need to *not* > do so. It's unlikely to have

Re: [akka-user] (AKKA V2.3.9) Akka configured seed nodes are leaving cluster and unreachable/reachable warning message is getting logged. ::: Spring Class (ClassPathXmlApplicationContext) serializatio

It's not so much "how to avoid" -- you are presumably trying to send something that contains a reference to that Context, and you need to *not* do so. It's unlikely to have anything to do with your configuration -- you're probably doing something illegal in your code. I doubt there's any way to

Re: [akka-user] How to "scatter-gather" with Akka Stream?

Source class doesn’t have partition/merge functions. Am I missing something? - Drew > On Aug 24, 2016, at 1:08 AM, Viktor Klang wrote: > > Partition + merge? > > On Wed, Aug 24, 2016 at 8:58 AM, Drew Kutcharian > wrote: > Hi

Re: [akka-user] (AKKA V2.3.9) Akka configured seed nodes are leaving cluster and unreachable/reachable warning message is getting logged. ::: Spring Class (ClassPathXmlApplicationContext) serializatio

Hello, Thanks for your quick response. *How can i avoid sending ClassPathXmlApplicationContext ?* I didn't have any custom code for serialization. I'm using akka provided cluster message Serializer serializers { akka-cluster = "akka.cluster.protobuf.ClusterMessageSerializer" }

Re: [akka-user] (AKKA V2.3.9) Akka configured seed nodes are leaving cluster and unreachable/reachable warning message is getting logged. ::: Spring Class (ClassPathXmlApplicationContext) serializatio

Then you must avoid sending ClassPathXmlApplicationContext. It's not serializable, and should not be, so you can't send it. On Wed, Aug 24, 2016 at 10:08 AM, vipin mandloi wrote: > Hello, > > > Thanks a lot for the response. > > *Enabled remote debugging , Error -

Re: [akka-user] How to "scatter-gather" with Akka Stream?

Partition + merge? On Wed, Aug 24, 2016 at 8:58 AM, Drew Kutcharian wrote: > Hi Guys, > > How can I do scatter-gather with Akka streams. Basically: > > 1. I’m reading messages from Kafka using akka-stream-kafka > 2. Then I group the messages using “groupedWithin” > 3. Then I

Re: [akka-user] (AKKA V2.3.9) Akka configured seed nodes are leaving cluster and unreachable/reachable warning message is getting logged. ::: Spring Class (ClassPathXmlApplicationContext) serializat

Hello, Thanks a lot for the response. *Enabled remote debugging , Error - "Failed to write message to Transport " is occurring due to Spring Class (ClassPathXmlApplicationContext) serialization failure. * Please let me know whether *Akka Cluster Remote Routess usages support spring

Re: [akka-user] Strange actor behavior with Akka Spring Integration

Hi Mark, > 22 aug. 2016 kl. 14:52 skrev Mark Kaberman : > > Hi Roland, > > I did some experiments and the results are not very encouraging. First, some > info about my application. It is quite simple: an actor executes a REST > request. It analyzes the response and based

[akka-user] How to "scatter-gather" with Akka Stream?

Hi Guys, How can I do scatter-gather with Akka streams. Basically: 1. I’m reading messages from Kafka using akka-stream-kafka 2. Then I group the messages using “groupedWithin” 3. Then I need to split the resulting batch into multiple groups (1 per logical shard) 4. I want to be able to process