Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Repo info
Activity
  • 00:00
    akka-ci commented #29771
  • 00:00
    akka-ci unlabeled #29771
  • 00:00
    akka-ci labeled #29771
  • Oct 21 23:31
    akka-ci labeled #29771
  • Oct 21 23:30
    pvlugter opened #29771
  • Oct 21 21:59
    akka-ci commented #29770
  • Oct 21 21:58
    akka-ci commented #29770
  • Oct 21 21:58
    akka-ci unlabeled #29770
  • Oct 21 21:58
    akka-ci labeled #29770
  • Oct 21 21:50
    seglo synchronize #29770
  • Oct 21 21:49
    akka-ci labeled #29770
  • Oct 21 21:48
    seglo synchronize #29770
  • Oct 21 21:42
    seglo opened #29770
  • Oct 21 18:08
    akka-ci commented #29769
  • Oct 21 17:56
    akka-ci labeled #29769
  • Oct 21 17:51
    akka-ci commented #29769
  • Oct 21 17:49
    sebastian-alfers opened #29769
  • Oct 21 15:09

    raboof on master

    Fixes the wording of the Scalad… (compare)

  • Oct 21 15:09
    raboof closed #29766
  • Oct 21 13:30
    dr-jerry opened #29768
Johan Andrén
@johanandren
Ok, good, that’s the right place. Just wanted to check that you weren’t looking at some outdated docs.
Yan
@jarodzz
Routee is gone. I see RouteeProvider in 2.4.1 jar, but found no clue how to make it work.
i'm also looking into akka code in github, not found any sample yet.
Johan Andrén
@johanandren
Yan
@jarodzz
@johanandren thanks, i'll go through it
Johan Andrén
@johanandren
So, it’s a part of the akka sources and if it was outdated it would not compile
Good, I hope it helps!
Yan
@jarodzz
one more question.
i'm designing a system, where i get msg from a kafka queue, like 0.3 million per day. for each msg, i nee to invoke 3-4 web service to enrich some info, then write it to db
in my design, each web service call is an actor, inside onReceive, there is a http client async calls a web service.
do u think it make sense? i look into some article saying i should have a lot more actors than 3-4 in a system
Johan Andrén
@johanandren
There is no general best practice to have many actors, it depends on your use case and what you want to achieve.
Yan
@jarodzz
so i am working to add a round robin router for each web service and the write to db actor. just to have more actors
Johan Andrén
@johanandren
It is not a purpose in itself to have more actors. But it might be helpful if you have problems, such as, controling how many concurrent requests to the web services you are doing, handling errors calling the web services using supervision etc.
Yan
@jarodzz
got it. thanks. i am new to akka concept, so keep wandering whether i am using it right
thanks for your time.
Johan Andrén
@johanandren
No problem, asking questions and learning from each other is what the gitter channel is for!
(and the mailing list as well)
Being new to the concept it could be a good idea to read one of the books on Akka, there is a list with a few books here: http://doc.akka.io/docs/akka/2.4.1/additional/books.html
Not sure if there is a book that does Akka in Java though, but the concepts are the same even if the examples might be a bit hard to follow in a language you do not know.
Konrad `ktoso` Malawski
@ktoso

btw, GraphStage with BidiFlow has made implementing Play's WebSockets soooo much easier, no more AtomicReferences

that's great to hear @jroper :)

as for your problem... I believe @2m's upcoming PR will solve the problem you bumped into - we're adding eager pulling to fan-in stages
@briantopping why do yuo neeed to +compile for development?
just stick to one version for dev, unless debugging a specific problem I guess
Danila Matveev
@optician

Hi, guys!

I use akka-http (Http().superPool()) client and try to configure proxy (http://doc.akka.io/docs/akka-stream-and-http-experimental/2.0.1/scala/http/configuration.html) but application ignores settings and sends direct request.

It's local proxy for debugging (fiddler, win10) and it works properly with other applications.
akka.log-config-on-start = "on" shows expected configuration:

"akka" : {
        "http" : {
            "client" : {
                "proxy" : {
                    "http" : {
                        # application.conf: 31
                        "host" : "localhost",
                        # application.conf: 32
                        "port" : 8888
                    }
                }
            },
            "host-connection-pool" : {
                "client" : {
                    "proxy" : {
                        "http" : {
                            # application.conf: 123
                            "host" : "localhost",
                            # application.conf: 124
                            "port" : 8888
                        }                    
                    }
                }
            }
        }
    }
}

Tell me, please, where is my error?

Ashu Gupta
@ashugupt
Its actually because feature request akka/akka#16153 is still open. cc @ktoso
Konrad `ktoso` Malawski
@ktoso
that's different
"being a proxy" and "using a proxy" is different
AFAIR the ticket was on being... will check in a bit
nah, you're right
too many tickets to keep track of :<
well, almost that is for using proxies via TLS
Ashu Gupta
@ashugupt
But the proxy settings for HTTP client requests is also not there.
Konrad `ktoso` Malawski
@ktoso
hm that's akka/akka#16853 though
hm was dropped form http:next... I see
well, not much more i can say on that for now then
pinged there to include in planning
Ashu Gupta
@ashugupt
I also pulled my hair over that, then switched to java async-http-client and mapAsync’d that with streams :)
Konrad `ktoso` Malawski
@ktoso
hah I see
thanks for the feedback
Ashu Gupta
@ashugupt
yeah, project deadlines :(
Raam Rosh-Hai
@raam86
I am trying to use groupby in akka-streams
How should I determine the max number of streams?
I want to basically be unbounded. Is it dangerous to use MaxInt?
Konrad `ktoso` Malawski
@ktoso
well technically unbounded is by def dangerous
what are you grouping on
Raam Rosh-Hai
@raam86
Hours of the day.
I currently capped it at one month (24 * 31) but I am not sure it is the best way to go
Konrad `ktoso` Malawski
@ktoso
"hour of day"? thats 24 though
Raam Rosh-Hai
@raam86
24 per day and then times 31 for a full long month