[akka-user] Error in request and response async in Tcp Akka on port 25 ?

Hi Every one i wrote this code for read Port 25 class Asker(connection: ActorRef) extends Actor { import Tcp._ connection ! Register(self); def receive = { case x => val parent = sender() connection ! x context become {case x => parent ! x;context.unbecome()} }

[akka-user] Re: how can write and read async with socket (councurent) ?

Someone who can help me ??? On Saturday, September 2, 2017 at 3:53:20 PM UTC+4:30, techlan...@gmail.com wrote: > > hi every one > I'm using akka 2.5.x how can call Socket async for read and write ?(what > is the best solution) > i need many connection concurrency for send email this is sample

[akka-user] Re: PersistentActor + akka streams

I have the same question ? On Wednesday, September 13, 2017 at 1:32:13 AM UTC+4:30, Yaroslav Klymko wrote: > > Hi guys, > > I'm wondering are there any plans to provide integration between akka > streams and PersistentActor ? > The feature I'm interested in particular is `FlowOps.batch`, so I

[akka-user] Re: how can write and read async with socket (councurent) ?

i can use TcpIO or Stream which better ? for above solution -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >> http://doc.akka.io/docs/akka/current/additional/faq.html >> Search the archives:

[akka-user] how can write and read async with socket (councurent) ?

hi every one I'm using akka 2.5.x how can call Socket async for read and write ?(what is the best solution) i need many connection concurrency for send email this is sample code java ? public boolean sendEmail(String data, String from, String to,String subject) throws IOException {

[akka-user] how integrated akka stream with actor persistence?

Hi, is anyone else trying to use the new Akka Streams with Akka Persistence? Has anyone created any code examples yet showing how to use them together? Thanks! -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >>

[akka-user] Re: Exception in thread "main" java.lang.IllegalArgumentException: Cannot instantiate router [adaptive-group], defined in [/frontend/backendRouter]

thanks Patrik Nordwall On Monday, May 29, 2017 at 6:35:54 PM UTC+4:30, techlan...@gmail.com wrote: > > hi all > this is my code : > > https://github.com/SalmaKhater/Learning-Akka/tree/master/akka-cluster/src/main/scala/load-balancing > and this is my config files in project : > >

[akka-user] Exception in thread "main" java.lang.IllegalArgumentException: Cannot instantiate router [adaptive-group], defined in [/frontend/backendRouter]

hi all this is my code : https://github.com/SalmaKhater/Learning-Akka/tree/master/akka-cluster/src/main/scala/load-balancing and this is my config files in project : https://github.com/SalmaKhater/Learning-Akka/tree/master/akka-cluster/src/main/resources and my sbt file this : name := "Akka"

Re: [akka-user] Akka-http server occasionally pausing

; show akka-stream classes.. > > This does not mean anything, since you might made your error when you > wired up your graph using only Akka Streams components. > > Can you give us a small reproducer that demonstrates this problem? > > -Endre > > On Fri, Aug 28, 2015 at

[akka-user] Akka-http server occasionally pausing

akka version: 2.3.12 akka-http version: 1.0 Hi all, I am running a service which is receiving small to medium payloads and uploading them to S3 type cloud storage. The load I am applying is about 200 requests/sec. Occasionally, I see the below stack trace and the service is pausing,

Re: [akka-user] Abrupt termination after a PUT completed

Thanks! On Monday, June 29, 2015 at 4:38:51 AM UTC-4, drewhk wrote: See this ticket: https://github.com/akka/akka/issues/17854 We will fix this very soon. On Fri, Jun 26, 2015 at 10:51 PM, IR ire...@gmail.com javascript: wrote: Hi all, Been trying to resolve an issue

[akka-user] Abrupt termination after a PUT completed

(FiniteDuration(15, second), self, PoisonPill) //self ! PoisonPill Done }) } case o = Promise.failed(new RuntimeException(sFAILURE: ${o.toString})).future } }) Thanks, IR -- Read the docs: http://akka.io/docs/ Check the FAQ