are set deeply nested
within the routes. Is there an better way?
On Friday, 20 October 2017 00:15:28 UTC+2, Jelmer Kuperus wrote:
>
> In akka http I am using the respondWithHeader directive to add a
> correlation id to the response like so
>
> final case class `X-Request-Id`(token:
In akka http I am using the respondWithHeader directive to add a
correlation id to the response like so
final case class `X-Request-Id`(token: String) extends
ModeledCustomHeader[`X-Request-Id`] {
override def renderInRequests = true
override def renderInResponses = true
override val
the Source and the Sink is to use runWith on the
Flow, and pass in the Source and the Sink.
Here is some pseudocode
val (actorRef, whatever) = flow.runWith(actorProducerSource, whateverSink)
actorRef ! Cancel
B/
On 3 March 2015 at 14:59:07, Jelmer Kuperus (jkup...@gmail.com
javascript:) wrote
on Flow that takes both a
Source and a Sink and give you a Tuple of the materialized values?
B/
On 1 March 2015 at 23:23:58, Jelmer Kuperus (jkup...@gmail.com
javascript:) wrote:
Suppose you have a akka stream backed by an ActorPublisher that listens to
a continuous stream of data from
Hi.
I am working on something that processes messages from a kafka topic using
akka-camel
When i receive a message i attempt to contact a third party system when
this system is unavailable i'd like to retry in 10 minutes, 20 minutes, etc
up to 5 times. I guess I could accomplish this easily
Hi I am trying to get a balancing pool working in conjunction with a
priority mailbox (eg using the PriorityGenerator)
I expected the following to work :
context.actorOf(BalancingPool(5).withDispatcher(prio-dispatcher).props(Props(new
Actor)))
but it seems that the PriorityGenerator never
Hi I am new to using akka and I am running into the following issue
I have an actor written in a funcrtional style that roughly looks like this
:
class MyActor extends Actor {
def awaitCompletion(writer: writer) = {
case Add(message) = {
writer.write(message)
