I was confused. I thought you were looking for something like:
path(v2.0 / tokens) {
post {
complete(it works)
}
} ~
path(v2.0 / somethingelse) {
post {
complete(it works)
}
}
Otherwise with
path(v2.0) {
path(tokens) {
You're matching
Hi,
by using
complete(HttpResponse(status = NoContent))
or
complete(NoContent)
the HTTP response contains the header:
Content-Type: text/plain; charset=UTF-8
If I understand the code correctly, HttpEntity.Empty should not send this
content type:
val Empty: Strict =
Found the solution, just in case anyone gets in the same spot as I was
earlier, the problem is with the incompatibility between zmq 2.2 and zmq
4.0.4, although zmq website advertises zmq latest version stating it is
backwards compatible it is NOT. when I stepped down my zmq version to 3.2.5
my
Hi Jim, thanks for the help ...
Have you followed all of the instructions for interacting with remote
actors here: http://doc.akka.io/docs/akka/2.3.9/scala/remoting.html ?
I follow this because I'm using the Java version of the API:
http://doc.akka.io/docs/akka/2.2.5/java/remoting.html
and them
oh! That was it! thanks ;)
I'll remember to check if they add it to the documentation once it's
released.
Cheers
G
On Thursday, 12 March 2015 10:00:46 UTC, Mark Hatton wrote:
Completing a route with a Tuple3[StatusCode, Seq[HttpHeader], T] doesn't
seem to work for me.
Ensure your
Completing a route with a Tuple3[StatusCode, Seq[HttpHeader], T] doesn't
seem to work for me.
Ensure your headers collection is an instance of immutable.Seq. E.g.:
import collection.immutable._
complete( (OK, Seq(`Cache-Control`(`no-cache`)), responseEntity) )
Works for me.
Mark
Hi Ronald and Patrik,
Are the release cycles of Akka Streams and Akka HTTP roughly the same.
I'm starting a new REST-only service and I'm not sure if I should use Spray
again, or start this project on Akka-Http. The product I'm developing will
be in production in about 2 months, so timing is a
Hello,
how is it possible to stop a shard region and all the shards located on the
same node gracefully?
Thanks a lot
Hannes
--
Read the docs: http://akka.io/docs/
Check the FAQ:
http://doc.akka.io/docs/akka/current/additional/faq.html
Search the archives:
Hello,
I am trying to stop my current Cluster Sharding application gracefully.
So far I couldn't find a way to stop a shard region and all the shards
located on the same node gracefully.
What would be a good way to achieve that?
Thanks a lot
Hannes
--
Read the docs:
Hi,
I'm trying to setup a client using TLS over TCP to connect to a server. The
client is using Akka Streams 1.0-M4.
At the moment I'm stymied:
1. After a series of debug messages about handshake, wrap and unwrap, the
SslTlsCipherActor writes a debug log of
### HS NEED_TASK
Running delegated
I am interested in that too.
So far, I've seen that leaving cluster gracefully with cluster.leave(...),
won't cause shard manager to automatically rebalance actors. Instead, it
relies on rebalance-interval settings.
On Thu, Mar 12, 2015 at 9:41 AM, Hannes Stockner hannes.stock...@gmail.com
I think you are looking for #16050
https://github.com/akka/akka/issues/16050.
I have actually a prototype of that ready so it will be available in Akka
2.4 (or some earlier snapshot/milestone).
Cheers,
Patrik
On Thu, Mar 12, 2015 at 11:28 AM, Dragisa Krsmanovic dragis...@gmail.com
wrote:
I am
Hi, *rrodseth*
thank you for link, I read it and try to re-write my code from Futures to
actor 'Tell', but at now example DAO are not async (but I think at now it's
not a problem):
import akka.actor._
import scala.concurrent.duration._
object ExampleActorBoot extends App {
val system =
A quick update,
a notable difference in my sources is that I call the actorSelection(...)
but from my client actor system, and not from another actor (in the usual
way contect.actorSelection(...) find in many documents):
ActorSelection selection = systemClient.actorSelection(remoteBasePath +
On Tuesday, March 10, 2015 at 4:17:10 PM UTC+1, Patrik Nordwall wrote:
What was puzzling me was:
Cluster Node [akka.tcp://...Node4...] - Marking node(s) as REACHABLE
[Member(address = akka.tcp://Node1..., status = Up)]
but looking at the code revealed that this is only an notification
On Tue, Mar 10, 2015 at 4:38 PM, michaels michael.schr...@atos.net wrote:
On Tuesday, March 10, 2015 at 4:17:10 PM UTC+1, Patrik Nordwall wrote:
What was puzzling me was:
Cluster Node [akka.tcp://...Node4...] - Marking node(s) as REACHABLE
[Member(address = akka.tcp://Node1..., status
16 matches
Mail list logo
