Thanks for the fast reply! I am aware of CoordinatedShutdown, and I love
it - it's exactly what I've been re-coding for every Akka system ;-)
For the special case of ShardedRegion however I did not find a way to do
the sequence I described in my original post, specifically giving time
to sharded
Well I am able to deploy the code to the Server and domain name is pointing
correctly to akka Http - so http://DomainName.COM is working fine now ...
but same isnt working with https URL i.e https://DomainName.COM ..
I am unable to figure out what am I missing as I have no error reported in
my
What you describe is exactly a feature we just rolled out in Akka 2.5.0 :-)
Docs here:
http://doc.akka.io/docs/akka/2.5/scala/actors.html#Coordinated_Shutdown
It also handles other parts of Akka, such as cluster singletons, Akka HTTP
and more.
Akka 2.5 is binary compatible with 2.4 (except if a
When shutting down an ActorSystem, I would like to shut down a
ShardRegion in three phases to ensure consistency:
1. Prevent sharded entities from receiving any new commands
2. Let the sharded entities finish their work
3. Actually shut down the ShardRegion, stopping all sharded entities and
I am sharing the code and process I am following:
def getOrCreateCartActor(cart_id: UUID): ActorRef = {
var cartActor: ActorRef = null
implicit val timeout = Timeout(50 seconds)
val name = "/user/" + cart_id.toString
val extractEntityId: ShardRegion.ExtractEntityId = {
That's *extremely* weird. I mean, the entire point of Cluster Sharding is
that you are always getting the same Actor for a given ID. Can you show
the code that you're using to start your sharding region, and to send the
messages? What do your messages look like, and how are you extracting the
Nice, thanks!
That works just fine ⇒ import JacksonSupport and you're basically done. I
recall how much time it took me to add correct marshallers/unmarshallers
for Jackson/Spray, 4 years ago.
The huge progress since that time!
--
>> Read the docs: http://akka.io/docs/
Hi,
I have configured my AKKA Code to import and use SSL in its HTTP via
SSLContext The SSL I have used is purchased from GeoTrust (Third Party)
and SSL certificate is configured to serve for specific hostname / domain
name like "tech.com" - How do I configure Akka to listen for this
I think what you are looking for is a Source that defines your queries, and
a `mapAsync (3){/* perform query */}` as that executes the queries in
parallel, and returns the results in order.
If the result of the mapAsync is collections, you can flatMap to unpack
them. If the result is Streams, you
