Hi Anindita,
It would be great for us to know what is lacking in the MDC sections of the
Akka Logging documentation,
please don't hesitate to contribute.
Thanks!
On Mon, Apr 27, 2015 at 8:09 AM, Anindita Ghatak anindita.g...@gmail.com
wrote:
Hi,
How can I use Akka with org.apache.log4j.MDC ?
Hi Soumya,
Why do you have the concurrent hash map in the Actor at all?
When using Actors you can easily have a *var* with an *immutable.Map*
which you can update/read from the Actor's receive. If you need to use
Futures,
apply the *pipeTo* pattern to forward the action to self.
Of course, if you
Dear group,
I am trying to send an empty datagram back to a client. This seems not to
be supported. The same code works just fine is the datagram payload is
non-empty:
// MyProxy is a 'bound UDP' server
MyProxy extends Actor {
def receive = {
case res: ProxyResponse =
val
On Sun, Apr 26, 2015 at 11:55 PM, Nweike Onwuyali nweikeonwuy...@gmail.com
wrote:
Hi Patrick,
Thanks for your response. Let me explain what i want to achieve.
1) When a user performs registration, i want to connect to couchDB and
persist the data
2)I want to send the user an email confirming
Hi Oliver,
Have you read the section of our docs about cyclic graphs and deadlocks?
http://doc.akka.io/docs/akka-stream-and-http-experimental/1.0-M2/scala/stream-graphs.html#Graph_cycles__liveness_and_deadlocks
Because akka streams (all reactive streams implementations) are purely
demand driven,
Excellent answer Adam.
An interesting point to add here is that when using Scala there is no need
to call unhandled() explicitly, because Scala’s PartialFunction allows us
to inspect if the function is able to handle a message or not. If not (no case
x = matches the message), we call unhandled()
Hello Roland,
we have both(Maven Central and Typesafe repo) configured on our Nexus.
Just found out that our Nexus has a (temporary) problem to update from
Maven Central - if this is fixed 2.3.10 jars will be taken from there..
I guess the Typesafe repo is still there cause it always was there
Ah, thanks for the pointer, I knew that there was something that we should fix.
I'll send out a public service announcement about the switched-off proxy when
these details are fixed.
Regards,
Roland
Sent from my iPhone
On 27 Apr 2015, at 11:19, delasoul michael.ham...@gmx.at wrote:
Hello akka,
we just tried to upgrade to 2.3.10.
Unfortunately:
akka-contrib is missing from the typesafe repo:
http://repo.typesafe.com/typesafe/releases/com/typesafe/akka/akka-contrib_2.11/
and I get an error for akka-slf4j:
[error] unresolved dependency:
Hi Michael,
May I ask why you are using that repository? Akka has been released to maven
central for quite a while now and the Typesafe repo must have erroneously
proxied that in the past.
Regards,
Roland
Sent from my iPhone
On 27 Apr 2015, at 10:22, delasoul michael.ham...@gmx.at wrote:
Hi,
How can I use Akka with org.apache.log4j.MDC ?
Thanks Regards,
Anindita
--
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
---
You received this
Hi Anton,
On Sun, Apr 26, 2015 at 9:31 PM, Anton Kulaga antonkul...@gmail.com wrote:
What about Websockets, as I understood they are supported in RC-1 but is
there anything in documentation that explains how to use them in akka-http?
Server-side websocket support is included in RC1 but not yet
Friendly reminder :-)
On Thursday, 23 April 2015 23:36:41 UTC+2, Leszek Gruchała wrote:
Hi,
I would like to better understand how a Receptionist actor is going to
work.
val receptionist: ActorRef[Command] = ctx.spawn(Props(Receptionist
.behavior), receptionist)
Dear hakkers,
during the past weeks many things have happened around Akka and the sheer
wealth of activity (confounded by “having to” visit a friend’s wedding on the
weekend :-) ) has left me without the time to properly appreciate all the
changes and landmarks we have passed.
Many of you may
Hi,
I've got a program using actors for parallel computations.
I'd like to know it's performance considering number of threads using
during computations(and maybe optimize it).
What tools would u suggest to check that?How to bite it?
--
Read the docs: http://akka.io/docs/
Check the
Hi,
I've got a program which uses actors(akka) for parallel computations.
I'd like to know it's performance considering thread using (to know need of
optimization).
What tools are proper for it?Which would you recommend?
--
Read the docs: http://akka.io/docs/
Check the FAQ:
Hi Magnus,
the answer to this question is very journal dependent.
It's up to the Journal to pick how to serialize your messages.
If a journal picks to serialize in human-readable formats you'd get that.
For example in a database like mongo you could just pick a JSON serializer
to put it into the
Hi,
Are there any examples that show how to implement response streaming using
akka-http?
Should I create an HttpEntity.CloseDelimited object providing Source
instance? What is the recommended way to create such source? In particular
I am interested in the following use cases:
- streaming
Thanks a lot. This is ver helpful.
I was curious to see if I can still see unhandled messages
On Mon, Apr 27, 2015 at 3:04 AM, Konrad Malawski kt...@typesafe.com wrote:
Excellent answer Adam.
An interesting point to add here is that when using Scala there is no need
to call unhandled()
Hi everyone,
we've discussed about serialization formats a few times on this list,
I think the discussion here: Best practices using Akka Persistence with
long-running projects?
Wow, that's awesome and s very deserved!!
--
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
---
You received this message because you are
Hi Anton,
I created a small standalone chat test application. See here:
https://github.com/jrudolph/akka-http-scala-js-websocket-chat
Johannes
On Sun, Apr 26, 2015 at 9:31 PM, Anton Kulaga antonkul...@gmail.com wrote:
What about Websockets, as I understood they are supported in RC-1 but is
Thanks Patrik! It works!
But now I have a new question: Is there any way to recover the object that
oversized the buffer? I get a message like max allowed size 31457280
bytes, actual size of encoded class QueryResult was 41402768 bytes but I
would like to access to that QueryResult in order
I'm deconstructing the argument on like 20 places in my application :
flow.mapAsync { case res :: errors :: result :: HNil = ... }
and now pattern matching will have to be used everywhere for the argument
to be deconstruced ... this interface is really unfortunate
On Tuesday, April 28, 2015
Hey,
shouldn't the :
Flow#mapAsync(parallelism: Int, f: Out ⇒ Future[T]): Repr[T, Mat]
method have this signature :
Flow#mapAsync(parallelism: Int)(f: Out ⇒ Future[T]): Repr[T, Mat]
as scala collection foldLeft, so it could be called like :
Flow[Resource].mapAsync(4) { res = asyncCode }
It
25 matches
Mail list logo
