Why do you need to convert it? Can't you send to a camel endpoint from a
akka.camel.Producer and then if you need do camel specific things in the
camel endpoint?
/Patrik
On Thu, Jun 12, 2014 at 4:23 AM, wrote:
> sorry , it's akka-camel.
>
>
> On Wednesday, June 11, 2014 6:45:27 PM UTC+8, Patri
Thanks a lot for sharing!
Cheers,
Patrik
On Thu, Jun 12, 2014 at 7:27 PM, Ian Hummel wrote:
> So it's been almost 1 year, but funny enough I had to go back and work on
> this code a little more and finally found an answer. Updating the thread
> in the hopes that this is useful for future Googl
On Thu, Jun 12, 2014 at 4:57 PM, Marco Shaw wrote:
> Anyone have any tip/tips for someone new to Scala/Akka on where to start?
>
> I'm decent at (object-oriented) scripting, so I'm not starting from
> scratch. I'm starting to learn Scala and find atomicscala.com to be a
> decent starting point.
On Thu, Jun 12, 2014 at 9:50 PM, Swathi Sri Kondagari <
swathisri.kondag...@gmail.com> wrote:
> Hi
>
> Thanks a lot for the reply. I got to start working on a custom made
> solution according to the line of thought you had provided. But according
> to the suggestion *I couldn't get a hold of the a
So it's been almost 1 year, but funny enough I had to go back and work on
this code a little more and finally found an answer. Updating the thread
in the hopes that this is useful for future Google searches...
Whenever you create an Actor that extends akka.camel.Consumer, it registers
itself (
Anyone have any tip/tips for someone new to Scala/Akka on where to start?
I'm decent at (object-oriented) scripting, so I'm not starting from
scratch. I'm starting to learn Scala and find atomicscala.com to be a
decent starting point. I'm thinking about "Scala Puzzlers", but haven't
decided
Hi Evan,
Am Freitag, 13. Juni 2014 07:39:15 UTC+2 schrieb Evan Chan:
>
> On Wednesday, June 11, 2014 2:35:27 AM UTC-7, Carsten Saathoff wrote:
>>
>> And there is another aspect. Especially for larger projects microservices
>> are great to "enforce" a share nothing philosophy. Using akka
>> seria
I think the only way is to not throw the exception / and not complete the
future with failure.
/Patrik
On Thu, Jun 12, 2014 at 3:19 PM, Swaroop Belur wrote:
> Hi all,
>
> I have an use case where i do not want certain errors to be counted while
> incrementing and checking against maxFailures
Then you have to do the input blocking in something else than an actor, and
send the input as messages to the actors.
/Patrik
On Thu, Jun 12, 2014 at 12:29 PM, Matthew Pocock <
turingatemyhams...@gmail.com> wrote:
> Hi,
>
> I've got an application that uses akka. One bit of it listens to stdin a
Hi Richard,
On Wed, Jun 11, 2014 at 9:00 PM, Richard Rodseth wrote:
> I realize this is well-trodden ground, but it's still a bit confusing for
> newcomers.
>
> Can we agree that the ask pattern is legitimate at the boundary between a
> service and repository/DAO?
>
> It seems to me that it is
Hi Scott,
On Thu, Jun 12, 2014 at 7:31 AM, Scott Clasen
wrote:
> A few questions on using persistent Views in a cluster.
>
> I would like to have a ClusterSingleton processor for which there is a
> View on each cluster node.
>
> Generally, will this work?
>
yes
> any thing to look out for?
Hi,
NAT setups are not supported as explained here:
http://doc.akka.io/docs/akka/2.3.3/general/remoting.html#Peer-to-Peer_vs__Client-Server
and the the hostname must be exactly the same as the configured
akka.remote.netty.tcp.hostname
Does that explain your issue?
/Patrik
On Wed, Jun 11, 2014
Hi Carsten,
On Wednesday, June 11, 2014 2:35:27 AM UTC-7, Carsten Saathoff wrote:
>
>
>
> And there is another aspect. Especially for larger projects microservices
> are great to "enforce" a share nothing philosophy. Using akka
> serialization, I either have to share the messages or use protobuf
Hi
Thanks a lot for the reply. I got to start working on a custom made
solution according to the line of thought you had provided. But according
to the suggestion *I couldn't get a hold of the actorref that was failing
in the decider function of the onetoonestrategy to include book keeping*.
On an interesting note, it seems that if I send my actor processor a
regular non-Persistant wrapped message and then I have the actor wrap the
message in a Persistent object and send it to itself, it works! The problem
then appears to be when another actor trie to send it a Persistent message.
Hi Michael,
Thanks for the feedback. After trying your suggestion of just wrapping the
payload in a Persistent object, It seems that the problem is still there.
Specifically, I'm getting an ActorInitializationException when I try to
start up. Are there any other special considerations that I ne
Hi all,
I have an use case where i do not want certain errors to be counted while
incrementing and checking against maxFailures to open the breaker.
For example, there might be user error and db can give out syntax error in
SQL, which is perfectly fine and I do not want this to be counted
like
Hi,
I've got an application that uses akka. One bit of it listens to stdin and
on a newline terminates an actor. This has a knock-on effect of closing
down the entire system. The line is the return value of a future, and is:
io.Source.*stdin*.getLines().take(1).foreach(_ => minion ! StopMinioning
Thanks Patrik
Since I am using spring jdbc, I dont have direct control of obtaining
connection as well. So i think point 3 would be difficult to do.
I think i will use futures for this.
So just to understand completely - when you say circuitbreaker is used w/
Futures, so in an actor only scena
we are doing the same - though in Scala - you only have to wrap the message
with Persistent that the processor finally receives, as
shown in your first example.
One nice thing when sharding processors is that the decision which message
has to be wrapped with Persistent can be done in the processo
Thanks, that is what I thought. In fact, my point was that the "same" bootable
should be booted with different parameters, hence using appliction.conf does
not help. Probably the only way out is to use different but except for the
parameter identical bootables.
Thanks for pointing to the sbt na
21 matches
Mail list logo
