ders =
headers)).map(uploadResponse
=> {
context.system.scheduler.scheduleOnce(FiniteDuration(15,
"second"), self, PoisonPill)
//self ! PoisonPill
"Done"
})
}
case o => Promise.failed(new RuntimeException(s"FAILURE:
${o.toString}")).future
}
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 >
> wrote:
>
>> Hi all,
>>
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,
temporarily
es/namespace, rather
> 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
>
>
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()}
}
}
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"
ver
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 :
>
> https://github.
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:
>> http://doc.akka.io/docs/akka/current/a
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 {
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 code java
> ?
>
> public bo
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: https://groups.google.com/group/akka-user
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
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 c
13 matches
Mail list logo
