help
求助
only machine：
*tomcat akka -- akka*
qa:
use akka remote configure?
Akka 2.2.1 version
client error info ↓
org.jboss.netty.channel.ChannelException: Failed to bind to: /192.168.8.155:2552
.
Caused by: java.net.BindException: Address already in use: bind
.
when i use the java Serializer and default disptacher,but i use jvisualvm
look the cpu snapshot why akka.remote.netty.RemoteMessageEncoder.encode
use the protobuf package.
i see the client thread in akka.remote.netty.RemoteMessageEncoder.encode
method cost one request 28.8% time.this method
and the app thread in akka.remote.RemoteTransport.createControlEnvelope
method wast long time about 41%
在 2014年2月13日星期四UTC+8上午10时38分05秒，√写道：
Java Serializer is extremely slow compared to virtually anything else.
What if you switch from sending a String to sending an Array[Byte]?
On Thu,
On Wednesday, February 12, 2014 6:58:53 PM UTC+1, Thibaut Robert wrote:
On Wednesday, February 12, 2014 5:57:35 PM UTC+1, Raymond Roestenburg
wrote:
On Wed, Feb 12, 2014 at 5:08 PM, √iktor Ҡlang viktor...@gmail.comwrote:
On Wed, Feb 12, 2014 at 4:56 PM, Thibaut Robert
On Thu, Feb 13, 2014 at 4:01 AM, chen ke lingqi1...@gmail.com wrote:
so pity,when i use remotActor.tell(str.getByte()); the throughput is
slow than use remotActor.tell(str); why???
Because you're creating a new array for every message.
What version of Akka are you running?
在
顺便咨询下，你两台机器互发消息，吞吐量能达到多少？我只能到2万条消息/每秒
在 2014年2月13日星期四UTC+8下午1时47分16秒，闫冬写道：
help
求助
only machine：
*tomcat akka -- akka*
qa:
use akka remote configure?
Akka 2.2.1 version
client error info ↓
org.jboss.netty.channel.ChannelException: Failed to bind to:
/192.168.8.155:2552
Hi Guillaume,
this is most probably a Scala or JVM bug of some kind; could you tell us which
versions of each you are using? (and the Akka version as well).
Regards,
Roland
13 feb 2014 kl. 01:43 skrev Guillaume Simard gsim...@gmail.com:
Hello,
For some reason, the code below will make it
Hi partycoder,
in which way does your code cause an ordering problem? What do you observe and
why is that not as it should be?
Regards,
Roland
12 feb 2014 kl. 06:36 skrev partyco...@gmail.com:
Hello,
I have a question.
val f = some future
val a = Agent(some type)
// This may cause
Hi Zoran,
on the worker nodes you can configure
hostname=
port=0
since they just need to find the master.
Regards,
Roland
12 feb 2014 kl. 03:17 skrev Zoran Jeremic zoran.jere...@gmail.com:
Hi,
I've implemented Akka cluster where I have one master node that initialize
cluster in the
12 feb 2014 kl. 21:18 skrev Justin du coeur jduco...@gmail.com:
On Tue, Feb 11, 2014 at 5:59 AM, Akka Team akka.offic...@gmail.com wrote:
your proposal is a bit futuristic in the sense that passing in failures as
normal messages is something that I am only experimenting with for Akka 3 at
This is a weird one. I seemed to have 2 versions of Akka in my classpath. I
removed the older version and this stopped happening. I don't know what was
happening...
Brian
On Tuesday, February 11, 2014 2:01:47 PM UTC+1, Brian McGee wrote:
Hey,
For local testing with Akka 2.2.x I had
Hi Brian,
the rule is very simple: whatever you configure under netty.tcp.hostname
will become part of your ActorSystem's address and must be used by remote
actors *exactly* (i.e. literally that String which is provided). This means
that this String must resolve to the same system (IP) for all
Hi Tim,
what I meant was to query the AWS API for the current members of that ASG
and use the response to build the seed node list. Whether or not that list
contains the same nodes as some other node has seen previously is not
relevant (seed nodes are only used by the joining node, they are not
Hi,
This is more of a design-pattern question than a technical one:
I've been looking at the event-sourcing implementation in the Akka
persistence module as a possible replacement for our current
Akka/event-sourcing setup. In our existing framwork we're going with the
following pattern:
sorry,my company can't upload code,only use the words here.
first,my client and server in the same host node .
when i call the actor in local mode,the tps is 2m.but call the actor in
remote mode is only 20k...
when i deploy the client and server in two host ,the result is same ...
the
Hi Brian,
you can register multiple transports, but binding to multiple TCP sockets
is currently not supported.
Regards,
Roland
On Thu, Feb 13, 2014 at 1:34 PM, Brian McGee b.m.mc...@gmail.com wrote:
Ok thanks for the clarification. So what if you wish to bind to multiple
interfaces?
On Thu, Feb 13, 2014 at 1:51 PM, Akka Team akka.offic...@gmail.com wrote:
On Wed, Feb 12, 2014 at 8:31 AM, Jatin Puri purija...@gmail.com wrote:
Hi Roland,
Thanks for the response.
This is what I thought I would do:
class Act extends Actor with LoadBalancer{
override var
13 feb 2014 kl. 14:27 skrev √iktor Ҡlang viktor.kl...@gmail.com:
On Thu, Feb 13, 2014 at 1:51 PM, Akka Team akka.offic...@gmail.com wrote:
On Wed, Feb 12, 2014 at 8:31 AM, Jatin Puri purija...@gmail.com wrote:
Hi Roland,
Thanks for the response.
This is what I thought I
On Thu, Feb 13, 2014 at 2:06 PM, Raymond Roestenburg
raymond.roestenb...@gmail.com wrote:
Hi Roland,
On Thu, Feb 13, 2014 at 1:27 PM, Akka Team akka.offic...@gmail.comwrote:
Hi Ray,
good that you are looking into these things, and as far as I can see your
assessment of the current
On Thu, Feb 13, 2014 at 2:40 PM, Akka Team akka.offic...@gmail.com wrote:
On Thu, Feb 13, 2014 at 2:37 PM, √iktor Ҡlang viktor.kl...@gmail.comwrote:
On Thu, Feb 13, 2014 at 2:29 PM, Roland Kuhn goo...@rkuhn.info wrote:
13 feb 2014 kl. 14:27 skrev √iktor Ҡlang viktor.kl...@gmail.com:
Ticket created.
On Thu, Feb 13, 2014 at 4:08 PM, Raymond Roestenburg
raymond.roestenb...@gmail.com wrote:
On Thu, Feb 13, 2014 at 2:35 PM, √iktor Ҡlang viktor.kl...@gmail.comwrote:
On Thu, Feb 13, 2014 at 2:06 PM, Raymond Roestenburg
raymond.roestenb...@gmail.com wrote:
Hi Roland,
Thanks for your reply,
Point taken regarding ensuring there has been no change in the aggregate
state between command validation and appending derived events to the
journal - but as far as I can tell this only applies if the
EventSourcedProcessor is also the maintainer of the state which the
On Thu, Feb 13, 2014 at 4:08 PM, Raymond Roestenburg
raymond.roestenb...@gmail.com wrote:
On Thu, Feb 13, 2014 at 2:35 PM, √iktor Ҡlang viktor.kl...@gmail.comwrote:
On Thu, Feb 13, 2014 at 2:06 PM, Raymond Roestenburg
raymond.roestenb...@gmail.com wrote:
Hi Roland,
On Thu, Feb
Great, I'll be :)
--
Read the docs: http://akka.io/docs/
Check the FAQ: http://akka.io/faq/
Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups Akka
User List group.
To unsubscribe from
Hi Oleg,
your analysis is correct: since we added methods to the Actor trait Akka
2.3.0-RC2 and 2.2.3 are not binary compatible, you need to recompile your
projects when upgrading across major version numbers. In this respect it is
useful to know that Akka does not use major.minor.patch
Try to use this library:
https://github.com/romix/akka-kryo-serialization
On Thursday, February 13, 2014 11:45:17 AM UTC+1, chen ke wrote:
when i use 2.2.3 the problem is also
my requirement the message array must dynamic build.
when i use the protobuf serializer the problem also...
在
No worker listen at controller actual host address not at localhost
127.0.0.1.
On Thursday, February 13, 2014 3:40:43 AM UTC-8, rkuhn wrote:
Your worker does not listen at 127.0.0.1.
12 feb 2014 kl. 01:22 skrev HARSH PATEL patel@gmail.com javascript:
:
*Remote Controller System:*
Exactly, which is the problem.
13 feb 2014 kl. 19:49 skrev HARSH PATEL patel.hars...@gmail.com:
No worker listen at controller actual host address not at localhost 127.0.0.1.
On Thursday, February 13, 2014 3:40:43 AM UTC-8, rkuhn wrote:
Your worker does not listen at 127.0.0.1.
12 feb
Hello,
Are there any limitations on passing value classes in Akka?
I have this class:
case class ServerStats (
httpUrl : String,
instanceName : String,
envName : String,
version : String,
configHits : Long,
upSince : PosixDate,
// events :
Hi Christian:
Here are some ideas:
1. Write the data to a file in a filesystem accessible by both actor
systems, send the filename as a message. When the message is received,
read and delete the file.
2. Same as 1 but with a database.
3. Break up the message into multiple messages and
I forgot to add, for #3, since you have tried something similar already,
we are using the MessageSequence in combination with
a) ReliableProxy
b) A remoting config
akka.remote {
# Per the conversation at
https://groups.google.com/d/msg/akka-user/WdWJOAVXQMo/OvoDqeZ8PsUJ
# we
Right you are! My value class needed to be marked as Serializable, then it
worked fine.
Value classes are really weird things in Scala. Sometimes the compiler
simply replaces them with the types they wrap, Long in this case.
Other times an object is generated. Apparently the upSince field
code:
ActorSystem tcpServerSystem = ActorSystem.create(tcp-server-system);
final ActorRef tcpServer = Tcp.get(tcpServerSystem).manager();
throw exception:
Exception in thread main java.lang.NoSuchMethodError:
akka.util.Helpers$.Requiring(Ljava/lang/Object;)Ljava/lang/Object;
why???
--
试过了，将server的监听端口修改成了2553，但看log
[INFO] [02/14/2014 09:39:41.324] [main] [Remoting] Remoting started;
listening on addresses :[akka.tcp://ServerSys@192.168.8.155:2552]
server端监听的仍然是2552，不知道是不是我的配置有问题？
*ServerSys {*
* include common*
* akka {*
* actor {*
*provider =
I change host = , still its throwing same error. Thanks.
On Thursday, February 13, 2014 10:58:52 AM UTC-8, rkuhn wrote:
Exactly, which is the problem.
13 feb 2014 kl. 19:49 skrev HARSH PATEL patel@gmail.com javascript:
:
No worker listen at controller actual host address not at
我还没有开始做相关的测试...你用的是什么版本的？
在 2014年2月13日星期四UTC+8下午7时13分46秒，chen ke写道：
顺便咨询下，你两台机器互发消息，吞吐量能达到多少？我只能到2万条消息/每秒
在 2014年2月13日星期四UTC+8下午1时47分16秒，闫冬写道：
help
求助
only machine：
*tomcat akka -- akka*
qa:
use akka remote configure?
Akka 2.2.1 version
client error info ↓
试过了，将server的监听端口修改成了2553，但看log
[INFO] [02/14/2014 09:39:41.324] [main] [Remoting] Remoting started;
listening on addresses :[akka.tcp://ServerSys@192.168.8.155:2552]
server端监听的仍然是2552，不知道是不是我的配置有问题？
*ServerSys {*
* include common*
* akka {*
* actor {*
*provider =
You have multiple versions, or a different version than you compiled
against, on your classpath.
On Feb 14, 2014 7:19 AM, chen ke lingqi1...@gmail.com wrote:
code:
ActorSystem tcpServerSystem = ActorSystem.create(tcp-server-system);
final ActorRef tcpServer =
38 matches
Mail list logo
