Received: by 10.68.220.230 with SMTP id pz6mr2353172pbc.3.1337257420472;
Thu, 17 May 2012 05:23:40 -0700 (PDT)
X-BeenThere: akka-user@googlegroups.com
Received: by 10.68.229.8 with SMTP id sm8ls5581588pbc.0.gmail; Thu, 17 May
2012 05:23:38 -0700 (PDT)
Received: by 10.68.223.40 with SMTP id qr8mr9856831pbc.0.1337257418611;
Thu, 17 May 2012 05:23:38 -0700 (PDT)
Received: by 10.68.223.40 with SMTP id qr8mr9856830pbc.0.1337257418586;
Thu, 17 May 2012 05:23:38 -0700 (PDT)
Return-Path: <akka.offic...@gmail.com>
Received: from mail-pz0-f54.google.com (mail-pz0-f54.google.com [209.85.210.54])
by gmr-mx.google.com with ESMTPS id ss7si3182743pbc.2.2012.05.17.05.23.38
(version=TLSv1/SSLv3 cipher=OTHER);
Thu, 17 May 2012 05:23:38 -0700 (PDT)
Received-SPF: pass (google.com: domain of akka.offic...@gmail.com designates 209.85.210.54 as permitted sender) client-ip=209.85.210.54;
Authentication-Results: gmr-mx.google.com; spf=pass (google.com: domain of akka.offic...@gmail.com designates 209.85.210.54 as permitted sender) smtp.mail=akka.offic...@gmail.com; dkim=pass header...@gmail.com
Received: by dadv36 with SMTP id v36so2455009dad.41
for <akka-user@googlegroups.com>; Thu, 17 May 2012 05:23:38 -0700 (PDT)
DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed;
d=gmail.com; s=20120113;
h=mime-version:sender:in-reply-to:references:date
:x-google-sender-auth:message-id:subject:from:to:content-type;
bh=lBSLTC5PiIrBtSDSqV/KmuV5cg+qaPLrzQu19yR6FIQ=;
b=Oq/x2gZLEDm6Ce24ANjbRrZIOasmIb8f2mZ0tMgQYfWOG7Fzkrwq1IgU9WOq/ybp4J
DYpnj75i5OxFYFsp1bkUE5rc7zFy5OUPXt1bLOU8hcAIzX8asA6w9khhefbJqufA03T5
J5/deghbW6zNmKeWkOexW82IEg38cGOEM7bVJwgIVzm9VMSfx3+O60Ojdnd+z/eV17ta
5N6Mr4nvCfEhl+g+PpIfuDptBKU5yIp0se+ibGhlFwC5OGqVj8pE2P2JCHV6NsO87PQA
oh45u9wFgHC7otbpmGO702wykPfbBQBiZAVqJ6HyBtH9JMfCm8HYyafjkEgbUm+8ypKw
2I2w==
MIME-Version: 1.0
Received: by 10.68.228.106 with SMTP id sh10mr17675236pbc.107.1337257418353;
Thu, 17 May 2012 05:23:38 -0700 (PDT)
Sender: akka.offic...@gmail.com
Received: by 10.68.13.166 with HTTP; Thu, 17 May 2012 05:23:38 -0700 (PDT)
Received: by 10.68.13.166 with HTTP; Thu, 17 May 2012 05:23:38 -0700 (PDT)
In-Reply-To: <CANPzfU_Uw14OMQu0tit28zvN4OrZL8CAOq9Su4-NPJLs0wm...@mail.gmail.com>
References: <30412695.1179.1337175544674.JavaMail.geo-discussion-forums@vbwa3>
<1829916.1952.1337190191592.JavaMail.geo-discussion-forums@ynja13>
<CANPzfU_-dPTTjBAKHDrxXoACpxx2WF=DwnD=uEOykYW16LL...@mail.gmail.com>
<CADu5xUYODXE5-ccG54GLft3-0vxVccSYY3n+Q6Lh1ddLxWY...@mail.gmail.com>
<CANPzfU9Eui8TK52cPjJO6v=N-Gca2sDQZ_WVzbOWsnnvYpa...@mail.gmail.com>
<CADu5xUYqv33pzs__c+EVhuJd9ds=gwGONEQ1SKdM3Jof2FV...@mail.gmail.com>
<CANPzfU8+FuTSdLaDkk49vA21xD=o=m7skCj1VUNGGhAQ-ny...@mail.gmail.com>
<CADu5xUbWGBkDBuRgdGAzV-pPP6gfweiNHMyaaX4PC=moR9k...@mail.gmail.com>
<CANPzfU-UGrHRjPC+3a8zzfFHfEJC70iqy51fv=hMMszuygc...@mail.gmail.com>
<CADu5xUaXMGXCqo72bZaYOkhKCWRo5QjwE4_nP7GZAwkqoRa...@mail.gmail.com>
<CANPzfU_Uw14OMQu0tit28zvN4OrZL8CAOq9Su4-NPJLs0wm...@mail.gmail.com>
Date: Thu, 17 May 2012 14:23:38 +0200
Message-ID: <CADu5xUYu5mZYmprezDhHWpC139Co3d7Egbznhk494eATF1Y...@mail.gmail.com>
Subject: Re: [akka-user] Re: java.lang.AssertionError: assertion failed in Router
From: Jonas Boner <jo...@jonasboner.com>
To: akka-user@googlegroups.com
Content-Type: multipart/alternative; boundary=e89a8ffba9f564ebb804c03a8175
--e89a8ffba9f564ebb804c03a8175
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: quoted-printable
That is the plan
On May 17, 2012 2:16 PM, "=E2=88=9Aiktor =D2=A0lang" <viktor.kl...@gmail.co=
m> wrote:
>
>
> On Thu, May 17, 2012 at 2:13 PM, Akka Team <akka.offic...@gmail.com>wrote=
:
>
>> LOL. I'll take a look.
>>
> We should probably just issue a check for using BalancingDispatcher with =
a
> router at all, since it doesn't make any sense really.
>
>
>> On May 17, 2012 1:54 PM, "=E2=88=9Aiktor =D2=A0lang" <viktor.klang@gmai=
l.com> wrote:
>>
>>>
>>>
>>> On Thu, May 17, 2012 at 1:51 PM, Jonas Boner <jo...@jonasboner.com>wrot=
e:
>>>
>>>> You'll figure it out ;-)
>>>>
>>> Nah, looking forward to your pull request since you claimed it was easy=
.
>>> ;-)
>>>
>>>
>>>
>>>> On May 16, 2012 9:18 PM, "=E2=88=9Aiktor =D2=A0lang" <viktor.klang@gm=
ail.com>
>>>> wrote:
>>>>
>>>>> That's the easy part, the hard part is where to put that check.
>>>>> On May 16, 2012 9:08 PM, "Jonas Boner" <jo...@jonasboner.com> wrote:
>>>>>
>>>>>> On Wed, May 16, 2012 at 9:02 PM, =E2=88=9Aiktor =D2=A0lang <viktor.k=
l...@gmail.com>
>>>>>> wrote:
>>>>>> > How should it fail?
>>>>>> >
>>>>>>
>>>>>> With an exception with a proper error message of course.
>>>>>>
>>>>>> > Cheers,
>>>>>> > V
>>>>>> >
>>>>>> > On May 16, 2012 8:52 PM, "Jonas Boner" <jo...@jonasboner.com>
>>>>>> wrote:
>>>>>> >>
>>>>>> >> On Wed, May 16, 2012 at 7:48 PM, =E2=88=9Aiktor =D2=A0lang <
>>>>>> viktor.kl...@gmail.com>
>>>>>> >> wrote:
>>>>>> >> >
>>>>>> >> >
>>>>>> >> > On Wed, May 16, 2012 at 7:43 PM, krishnen <krishn...@gmail.com>
>>>>>> wrote:
>>>>>> >> >>
>>>>>> >> >> Hello,
>>>>>> >> >>
>>>>>> >> >> I made a small demo project to illustrate the problem :
>>>>>> >> >>
>>>>>> >> >> https://github.com/krishnenc/routing-akka
>>>>>> >> >>
>>>>>> >> >> Viktor : Removing the balancing dispatcher does indeed prevent
>>>>>> the
>>>>>> >> >> exception
>>>>>> >> >
>>>>>> >> >
>>>>>> >> > As I expected then. A remote SmallestMailboxFirst Router, with =
a
>>>>>> >> > Resizer,
>>>>>> >> > with a BalancingDispatcher is just a bad idea on all levels.
>>>>>> >>
>>>>>> >> Indeed bad. But it should not fail like this. Add a ticket.
>>>>>> >>
>>>>>> >> >
>>>>>> >> > Great that the assertion was there!
>>>>>> >> >
>>>>>> >> > Cheers,
>>>>>> >> > =E2=88=9A
>>>>>> >> >
>>>>>> >> >>
>>>>>> >> >>
>>>>>> >> >> Thks,
>>>>>> >> >> Krishnen
>>>>>> >> >>
>>>>>> >> >>
>>>>>> >> >>
>>>>>> >> >>
>>>>>> >> >> On Wednesday, May 16, 2012 5:39:04 PM UTC+4, krishnen wrote:
>>>>>> >> >>>
>>>>>> >> >>> Hi All,
>>>>>> >> >>>
>>>>>> >> >>> I am using Akka 2.0.1 in my application. I make use of a
>>>>>> remote router
>>>>>> >> >>> which i initialize on startup of the application as follows:
>>>>>> >> >>>
>>>>>> >> >>> val frameworkAddress =3D Seq(Address("akka",
>>>>>> "FrameworkApplication",
>>>>>> >> >>> config.getString("framework.ip-address"),
>>>>>> >> >>> config.getInt("framework.akka.remote.netty.port")))
>>>>>> >> >>>
>>>>>> >> >>> system.actorOf(Props[FrameworkActor].withRouter(
>>>>>> >> >>> RemoteRouterConfig(SmallestMailboxRouter(resizer =3D
>>>>>> >> >>> Some(DefaultResizer(
>>>>>> >> >>> lowerBound =3D 1, upperBound =3D 10)), routerDispatch=
er =3D
>>>>>> >> >>> "framework-dispatcher"),
>>>>>> >> >>> frameworkAddress)),
>>>>>> >> >>> "framework_server")
>>>>>> >> >>>
>>>>>> >> >>>
>>>>>> >> >>> The framework-dispatcher is defined in the config is defined =
as
>>>>>> >> >>> follows
>>>>>> >> >>> :
>>>>>> >> >>>
>>>>>> >> >>> framework-dispatcher {
>>>>>> >> >>> type =3D BalancingDispatcher
>>>>>> >> >>> executor =3D "fork-join-executor"
>>>>>> >> >>> }
>>>>>> >> >>>
>>>>>> >> >>>
>>>>>> >> >>> I send a few messages remotely to the router, the first few g=
o
>>>>>> through
>>>>>> >> >>> correctly, but at some point the app falls over with this
>>>>>> exception:
>>>>>> >> >>>
>>>>>> >> >>> [ERROR] [05/16/2012 16:32:22.487]
>>>>>> >> >>> [FrameworkApplication-akka.actor.default-dispatcher-5]
>>>>>> >> >>> [akka://FrameworkApplication/user] assertion failed
>>>>>> >> >>> java.lang.AssertionError: assertion failed
>>>>>> >> >>> at scala.Predef$.assert(Predef.scala:89)
>>>>>> >> >>> at
>>>>>> akka.routing.Router$$anonfun$receive$1.apply(Routing.scala:309)
>>>>>> >> >>> at
>>>>>> akka.routing.Router$$anonfun$receive$1.apply(Routing.scala:305)
>>>>>> >> >>> at
>>>>>> scala.PartialFunction$$anon$1.apply(PartialFunction.scala:45)
>>>>>> >> >>> at akka.actor.Actor$class.apply(Actor.scala:311)
>>>>>> >> >>> at akka.routing.RouterConfig$$anon$1.apply(Routing.scala:176)
>>>>>> >> >>> at akka.actor.ActorCell.invoke(ActorCell.scala:619)
>>>>>> >> >>> at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:196)
>>>>>> >> >>> at akka.dispatch.Mailbox.run(Mailbox.scala:178)
>>>>>> >> >>> at
>>>>>> >> >>>
>>>>>> >> >>>
>>>>>> akka.dispatch.ForkJoinExecutorConfigurator$MailboxExecutionTask.exec=
(AbstractDispatcher.scala:505)
>>>>>> >> >>> at akka.jsr166y.ForkJoinTask.doExec(ForkJoinTask.java:259)
>>>>>> >> >>> at
>>>>>> akka.jsr166y.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:974)
>>>>>> >> >>> at akka.jsr166y.ForkJoinPool.runWorker(ForkJoinPool.java:1478=
)
>>>>>> >> >>> at
>>>>>> >> >>>
>>>>>> akka.jsr166y.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:104)
>>>>>> >> >>>
>>>>>> >> >>> I had a quick look at the code, it seems the problem is with
>>>>>> router
>>>>>> >> >>> resizing. Can someone point to me what i am doing wrong?
>>>>>> >> >>>
>>>>>> >> >>> I am running Akka on :
>>>>>> >> >>> Ubuntu 11.10
>>>>>> >> >>> Scala 2.9.1
>>>>>> >> >>> OpenJDK Runtime Environment (IcedTea7 2.0pre)
>>>>>> >> >>> (7~b147-2.0~pre6-1ubuntu1~ppa1)
>>>>>> >> >>> OpenJDK 64-Bit Server VM (build 21.0-b17, mixed mode)
>>>>>> >> >>>
>>>>>> >> >>> If more info needed let me know.
>>>>>> >> >>>
>>>>>> >> >>> Thanks!
>>>>>> >> >>>
>>>>>> >> >>>
>>>>>> >> >>>
>>>>>> >> >>>
>>>>>> >> >> --
>>>>>> >> >> You received this message because you are subscribed to the
>>>>>> Google
>>>>>> >> >> Groups
>>>>>> >> >> "Akka User List" group.
>>>>>> >> >> To view this discussion on the web visit
>>>>>> >> >> https://groups.google.com/d/msg/akka-user/-/jG-UjDAfmSsJ.
>>>>>> >> >>
>>>>>> >> >> To post to this group, send email to akka-u...@googlegroups.co=
m
>>>>>> .
>>>>>> >> >> To unsubscribe from this group, send email to
>>>>>> >> >> akka-user+unsubscribe@googlegroups.com.
>>>>>> >> >> For more options, visit this group at
>>>>>> >> >> http://groups.google.com/group/akka-user?hl=3Den.
>>>>>> >> >
>>>>>> >> >
>>>>>> >> >
>>>>>> >> >
>>>>>> >> > --
>>>>>> >> > Viktor Klang
>>>>>> >> >
>>>>>> >> > Akka Tech Lead
>>>>>> >> > Typesafe - The software stack for applications that scale
>>>>>> >> >
>>>>>> >> > Twitter: @viktorklang
>>>>>> >> >
>>>>>> >> > --
>>>>>> >> > You received this message because you are subscribed to the
>>>>>> Google
>>>>>> >> > Groups
>>>>>> >> > "Akka User List" group.
>>>>>> >> > To post to this group, send email to akka-user@googlegroups.com=
.
>>>>>> >> > To unsubscribe from this group, send email to
>>>>>> >> > akka-user+unsubscribe@googlegroups.com.
>>>>>> >> > For more options, visit this group at
>>>>>> >> > http://groups.google.com/group/akka-user?hl=3Den.
>>>>>> >>
>>>>>> >>
>>>>>> >>
>>>>>> >> --
>>>>>> >> Jonas Bon=C3=A9r
>>>>>> >> CTO
>>>>>> >> Typesafe - The software stack for applications that scale
>>>>>> >> Phone: +46 733 777 123
>>>>>> >> Twitter: @jboner
>>>>>> >>
>>>>>> >> --
>>>>>> >> You received this message because you are subscribed to the Googl=
e
>>>>>> Groups
>>>>>> >> "Akka User List" group.
>>>>>> >> To post to this group, send email to akka-user@googlegroups.com.
>>>>>> >> To unsubscribe from this group, send email to
>>>>>> >> akka-user+unsubscribe@googlegroups.com.
>>>>>> >> For more options, visit this group at
>>>>>> >> http://groups.google.com/group/akka-user?hl=3Den.
>>>>>> >>
>>>>>> > --
>>>>>> > You received this message because you are subscribed to the Google
>>>>>> Groups
>>>>>> > "Akka User List" group.
>>>>>> > To post to this group, send email to akka-user@googlegroups.com.
>>>>>> > To unsubscribe from this group, send email to
>>>>>> > akka-user+unsubscribe@googlegroups.com.
>>>>>> > For more options, visit this group at
>>>>>> > http://groups.google.com/group/akka-user?hl=3Den.
>>>>>>
>>>>>>
>>>>>>
>>>>>> --
>>>>>> Jonas Bon=C3=A9r
>>>>>> CTO
>>>>>> Typesafe - The software stack for applications that scale
>>>>>> Phone: +46 733 777 123
>>>>>> Twitter: @jboner
>>>>>>
>>>>>> --
>>>>>> You received this message because you are subscribed to the Google
>>>>>> Groups "Akka User List" group.
>>>>>> To post to this group, send email to akka-user@googlegroups.com.
>>>>>> To unsubscribe from this group, send email to
>>>>>> akka-user+unsubscribe@googlegroups.com.
>>>>>> For more options, visit this group at
>>>>>> http://groups.google.com/group/akka-user?hl=3Den.
>>>>>>
>>>>>> --
>>>>> You received this message because you are subscribed to the Google
>>>>> Groups "Akka User List" group.
>>>>> To post to this group, send email to akka-user@googlegroups.com.
>>>>> To unsubscribe from this group, send email to
>>>>> akka-user+unsubscribe@googlegroups.com.
>>>>> For more options, visit this group at
>>>>> http://groups.google.com/group/akka-user?hl=3Den.
>>>>>
>>>> --
>>>> You received this message because you are subscribed to the Google
>>>> Groups "Akka User List" group.
>>>> To post to this group, send email to akka-user@googlegroups.com.
>>>> To unsubscribe from this group, send email to
>>>> akka-user+unsubscribe@googlegroups.com.
>>>> For more options, visit this group at
>>>> http://groups.google.com/group/akka-user?hl=3Den.
>>>>
>>>
>>>
>>>
>>> --
>>> Viktor Klang
>>>
>>> Akka Tech Lead
>>> Typesafe <http://www.typesafe.com/> - The software stack for
>>> applications that scale
>>>
>>> Twitter: @viktorklang
>>>
>>> --
>>> You received this message because you are subscribed to the Google
>>> Groups "Akka User List" group.
>>> To post to this group, send email to akka-user@googlegroups.com.
>>> To unsubscribe from this group, send email to
>>> akka-user+unsubscribe@googlegroups.com.
>>> For more options, visit this group at
>>> http://groups.google.com/group/akka-user?hl=3Den.
>>>
>> --
>> You received this message because you are subscribed to the Google Group=
s
>> "Akka User List" group.
>> To post to this group, send email to akka-user@googlegroups.com.
>> To unsubscribe from this group, send email to
>> akka-user+unsubscribe@googlegroups.com.
>> For more options, visit this group at
>> http://groups.google.com/group/akka-user?hl=3Den.
>>
>
>
>
> --
> Viktor Klang
>
> Akka Tech Lead
> Typesafe <http://www.typesafe.com/> - The software stack for applications
> that scale
>
> Twitter: @viktorklang
>
> --
> You received this message because you are subscribed to the Google Groups
> "Akka User List" group.
> To post to this group, send email to akka-user@googlegroups.com.
> To unsubscribe from this group, send email to
> akka-user+unsubscribe@googlegroups.com.
> For more options, visit this group at
> http://groups.google.com/group/akka-user?hl=3Den.
>
--e89a8ffba9f564ebb804c03a8175
Content-Type: text/html; charset=UTF-8
Content-Transfer-Encoding: quoted-printable
<p>That is the plan</p>
<div class=3D"gmail_quote">On May 17, 2012 2:16 PM, "=E2=88=9Aiktor =
=D2=A0lang" <<a href=3D"mailto:viktor.kl...@gmail.com">viktor.klang=
@gmail.com</a>> wrote:<br type=3D"attribution"><blockquote class=3D"gmai=
l_quote" style=3D"margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left=
:1ex">
<br><br><div class=3D"gmail_quote">On Thu, May 17, 2012 at 2:13 PM, Akka Te=
am <span dir=3D"ltr"><<a href=3D"mailto:akka.offic...@gmail.com" target=
=3D"_blank">akka.offic...@gmail.com</a>></span> wrote:<br><blockquote cl=
ass=3D"gmail_quote" style=3D"margin:0 0 0 .8ex;border-left:1px #ccc solid;p=
adding-left:1ex">
<p>LOL. I'll take a look.</p></blockquote><div>We should probably just =
issue a check for using BalancingDispatcher with a router at all, since it =
doesn't make any sense really.</div><div>=C2=A0</div><blockquote class=
=3D"gmail_quote" style=3D"margin:0 0 0 .8ex;border-left:1px #ccc solid;padd=
ing-left:1ex">
<div><div>
<div class=3D"gmail_quote">On May 17, 2012 1:54 PM, "=E2=88=9Aiktor =
=D2=A0lang" <<a href=3D"mailto:viktor.kl...@gmail.com" target=3D"_b=
lank">viktor.kl...@gmail.com</a>> wrote:<br type=3D"attribution"><blockq=
uote class=3D"gmail_quote" style=3D"margin:0 0 0 .8ex;border-left:1px #ccc =
solid;padding-left:1ex">
<br><br><div class=3D"gmail_quote">On Thu, May 17, 2012 at 1:51 PM, Jonas B=
oner <span dir=3D"ltr"><<a href=3D"mailto:jo...@jonasboner.com" target=
=3D"_blank">jo...@jonasboner.com</a>></span> wrote:<br><blockquote class=
=3D"gmail_quote" style=3D"margin:0 0 0 .8ex;border-left:1px #ccc solid;padd=
ing-left:1ex">
<p>You'll figure it out ;-)</p></blockquote><div>Nah, looking forward t=
o your pull request since you claimed it was easy. ;-)</div><div><br></div>=
<div>=C2=A0</div><blockquote class=3D"gmail_quote" style=3D"margin:0 0 0 .8=
ex;border-left:1px #ccc solid;padding-left:1ex">
<p> </p><div><div>
<div class=3D"gmail_quote">On May 16, 2012 9:18 PM, "=E2=88=9Aiktor =
=D2=A0lang" <<a href=3D"mailto:viktor.kl...@gmail.com" target=3D"_b=
lank">viktor.kl...@gmail.com</a>> wrote:<br type=3D"attribution"><blockq=
uote class=3D"gmail_quote" style=3D"margin:0 0 0 .8ex;border-left:1px #ccc =
solid;padding-left:1ex">
<p>That's the easy part, the hard part is where to put that check.</p>
<div class=3D"gmail_quote">On May 16, 2012 9:08 PM, "Jonas Boner"=
<<a href=3D"mailto:jo...@jonasboner.com" target=3D"_blank">jonas@jonasb=
oner.com</a>> wrote:<br type=3D"attribution"><blockquote class=3D"gmail_=
quote" style=3D"margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1=
ex">
On Wed, May 16, 2012 at 9:02 PM, =E2=88=9Aiktor =D2=A0lang <<a href=3D"m=
ailto:viktor.kl...@gmail.com" target=3D"_blank">viktor.kl...@gmail.com</a>&=
gt; wrote:<br>
> How should it fail?<br>
><br>
<br>
With an exception with a proper error message of course.<br>
<br>
> Cheers,<br>
> V<br>
><br>
> On May 16, 2012 8:52 PM, "Jonas Boner" <<a href=3D"mailto=
:jo...@jonasboner.com" target=3D"_blank">jo...@jonasboner.com</a>> wrote=
:<br>
>><br>
>> On Wed, May 16, 2012 at 7:48 PM, =E2=88=9Aiktor =D2=A0lang <<a =
href=3D"mailto:viktor.kl...@gmail.com" target=3D"_blank">viktor.klang@gmail=
.com</a>><br>
>> wrote:<br>
>> ><br>
>> ><br>
>> > On Wed, May 16, 2012 at 7:43 PM, krishnen <<a href=3D"mail=
to:krishn...@gmail.com" target=3D"_blank">krishn...@gmail.com</a>> wrote=
:<br>
>> >><br>
>> >> Hello,<br>
>> >><br>
>> >> I made a small demo project to illustrate the problem :<b=
r>
>> >><br>
>> >> <a href=3D"https://github.com/krishnenc/routing-akka" tar=
get=3D"_blank">https://github.com/krishnenc/routing-akka</a><br>
>> >><br>
>> >> Viktor : Removing the balancing dispatcher does indeed pr=
event the<br>
>> >> exception<br>
>> ><br>
>> ><br>
>> > As I expected then. A remote SmallestMailboxFirst Router, wit=
h a<br>
>> > Resizer,<br>
>> > with a BalancingDispatcher is just a bad idea on all levels.<=
br>
>><br>
>> Indeed bad. But it should not fail like this. Add a ticket.<br>
>><br>
>> ><br>
>> > Great that the assertion was there!<br>
>> ><br>
>> > Cheers,<br>
>> > =E2=88=9A<br>
>> ><br>
>> >><br>
>> >><br>
>> >> Thks,<br>
>> >> Krishnen<br>
>> >><br>
>> >><br>
>> >><br>
>> >><br>
>> >> On Wednesday, May 16, 2012 5:39:04 PM UTC+4, krishnen wro=
te:<br>
>> >>><br>
>> >>> Hi All,<br>
>> >>><br>
>> >>> I am using Akka 2.0.1 in my application. I make use o=
f a remote router<br>
>> >>> which i initialize on startup of the application as f=
ollows:<br>
>> >>><br>
>> >>> val frameworkAddress =3D Seq(Address("akka"=
, "FrameworkApplication",<br>
>> >>> =C2=A0 =C2=A0 =C2=A0 config.getString("framework=
.ip-address"),<br>
>> >>> =C2=A0 =C2=A0 =C2=A0 config.getInt("framework.ak=
ka.remote.netty.port")))<br>
>> >>><br>
>> >>> system.actorOf(Props[FrameworkActor].withRouter(<br>
>> >>> =C2=A0 =C2=A0 =C2=A0 RemoteRouterConfig(SmallestMailb=
oxRouter(resizer =3D<br>
>> >>> Some(DefaultResizer(<br>
>> >>> =C2=A0 =C2=A0 =C2=A0 =C2=A0 lowerBound =3D 1, upperBo=
und =3D 10)), routerDispatcher =3D<br>
>> >>> "framework-dispatcher"),<br>
>> >>> =C2=A0 =C2=A0 =C2=A0 =C2=A0 frameworkAddress)),<br>
>> >>> =C2=A0 =C2=A0 =C2=A0 =C2=A0 "framework_server&qu=
ot;)<br>
>> >>><br>
>> >>><br>
>> >>> The framework-dispatcher is defined in the config is =
defined as<br>
>> >>> follows<br>
>> >>> :<br>
>> >>><br>
>> >>> framework-dispatcher {<br>
>> >>> =C2=A0 type =3D BalancingDispatcher<br>
>> >>> =C2=A0 executor =3D "fork-join-executor"<br=
>
>> >>> =C2=A0 }<br>
>> >>><br>
>> >>><br>
>> >>> I send a few messages remotely to the router, the fir=
st few go through<br>
>> >>> correctly, but at some point the app falls over with =
this exception:<br>
>> >>><br>
>> >>> [ERROR] [05/16/2012 16:32:22.487]<br>
>> >>> [FrameworkApplication-akka.actor.default-dispatcher-5=
]<br>
>> >>> [akka://FrameworkApplication/user] assertion failed<b=
r>
>> >>> java.lang.AssertionError: assertion failed<br>
>> >>> at scala.Predef$.assert(Predef.scala:89)<br>
>> >>> at akka.routing.Router$$anonfun$receive$1.apply(Routi=
ng.scala:309)<br>
>> >>> at akka.routing.Router$$anonfun$receive$1.apply(Routi=
ng.scala:305)<br>
>> >>> at scala.PartialFunction$$anon$1.apply(PartialFunctio=
n.scala:45)<br>
>> >>> at akka.actor.Actor$class.apply(Actor.scala:311)<br>
>> >>> at akka.routing.RouterConfig$$anon$1.apply(Routing.sc=
ala:176)<br>
>> >>> at akka.actor.ActorCell.invoke(ActorCell.scala:619)<b=
r>
>> >>> at akka.dispatch.Mailbox.processMailbox(Mailbox.scala=
:196)<br>
>> >>> at akka.dispatch.Mailbox.run(Mailbox.scala:178)<br>
>> >>> at<br>
>> >>><br>
>> >>> akka.dispatch.ForkJoinExecutorConfigurator$MailboxExe=
cutionTask.exec(AbstractDispatcher.scala:505)<br>
>> >>> at akka.jsr166y.ForkJoinTask.doExec(ForkJoinTask.java=
:259)<br>
>> >>> at akka.jsr166y.ForkJoinPool$WorkQueue.runTask(ForkJo=
inPool.java:974)<br>
>> >>> at akka.jsr166y.ForkJoinPool.runWorker(ForkJoinPool.j=
ava:1478)<br>
>> >>> at<br>
>> >>> akka.jsr166y.ForkJoinWorkerThread.run(ForkJoinWorkerT=
hread.java:104)<br>
>> >>><br>
>> >>> I had a quick look at the code, it seems the problem =
is with router<br>
>> >>> resizing. Can someone point to me what i am doing wro=
ng?<br>
>> >>><br>
>> >>> I am running Akka on :<br>
>> >>> Ubuntu 11.10<br>
>> >>> Scala 2.9.1<br>
>> >>> OpenJDK Runtime Environment (IcedTea7 2.0pre)<br>
>> >>> (7~b147-2.0~pre6-1ubuntu1~ppa1)<br>
>> >>> OpenJDK 64-Bit Server VM (build 21.0-b17, mixed mode)=
<br>
>> >>><br>
>> >>> If more info needed let me know.<br>
>> >>><br>
>> >>> Thanks!<br>
>> >>><br>
>> >>><br>
>> >>><br>
>> >>><br>
>> >> --<br>
>> >> You received this message because you are subscribed to t=
he Google<br>
>> >> Groups<br>
>> >> "Akka User List" group.<br>
>> >> To view this discussion on the web visit<br>
>> >> <a href=3D"https://groups.google.com/d/msg/akka-user/-/jG=
-UjDAfmSsJ" target=3D"_blank">https://groups.google.com/d/msg/akka-user/-/j=
G-UjDAfmSsJ</a>.<br>
>> >><br>
>> >> To post to this group, send email to <a href=3D"mailto:ak=
ka-user@googlegroups.com" target=3D"_blank">akka-user@googlegroups.com</a>.=
<br>
>> >> To unsubscribe from this group, send email to<br>
>> >> <a href=3D"mailto:akka-user%2Bunsubscr...@googlegroups.co=
m" target=3D"_blank">akka-user+unsubscribe@googlegroups.com</a>.<br>
>> >> For more options, visit this group at<br>
>> >> <a href=3D"http://groups.google.com/group/akka-user?hl=3D=
en" target=3D"_blank">http://groups.google.com/group/akka-user?hl=3Den</a>.=
<br>
>> ><br>
>> ><br>
>> ><br>
>> ><br>
>> > --<br>
>> > Viktor Klang<br>
>> ><br>
>> > Akka Tech Lead<br>
>> > Typesafe=C2=A0- The software stack for applications that scal=
e<br>
>> ><br>
>> > Twitter: @viktorklang<br>
>> ><br>
>> > --<br>
>> > You received this message because you are subscribed to the G=
oogle<br>
>> > Groups<br>
>> > "Akka User List" group.<br>
>> > To post to this group, send email to <a href=3D"mailto:akka-u=
ser@googlegroups.com" target=3D"_blank">akka-user@googlegroups.com</a>.<br>
>> > To unsubscribe from this group, send email to<br>
>> > <a href=3D"mailto:akka-user%2Bunsubscribe@googlegroups.com" t=
arget=3D"_blank">akka-user+unsubscribe@googlegroups.com</a>.<br>
>> > For more options, visit this group at<br>
>> > <a href=3D"http://groups.google.com/group/akka-user?hl=3Den" =
target=3D"_blank">http://groups.google.com/group/akka-user?hl=3Den</a>.<br>
>><br>
>><br>
>><br>
>> --<br>
>> Jonas Bon=C3=A9r<br>
>> CTO<br>
>> Typesafe - The software stack for applications that scale<br>
>> Phone: <a href=3D"tel:%2B46%20733%20777%20123" value=3D"+467337771=
23" target=3D"_blank">+46 733 777 123</a><br>
>> Twitter:=C2=A0@jboner<br>
>><br>
>> --<br>
>> You received this message because you are subscribed to the Google=
Groups<br>
>> "Akka User List" group.<br>
>> To post to this group, send email to <a href=3D"mailto:akka-user@g=
ooglegroups.com" target=3D"_blank">akka-user@googlegroups.com</a>.<br>
>> To unsubscribe from this group, send email to<br>
>> <a href=3D"mailto:akka-user%2Bunsubscribe@googlegroups.com" target=
=3D"_blank">akka-user+unsubscribe@googlegroups.com</a>.<br>
>> For more options, visit this group at<br>
>> <a href=3D"http://groups.google.com/group/akka-user?hl=3Den" targe=
t=3D"_blank">http://groups.google.com/group/akka-user?hl=3Den</a>.<br>
>><br>
> --<br>
> You received this message because you are subscribed to the Google Gro=
ups<br>
> "Akka User List" group.<br>
> To post to this group, send email to <a href=3D"mailto:akka-user@googl=
egroups.com" target=3D"_blank">akka-user@googlegroups.com</a>.<br>
> To unsubscribe from this group, send email to<br>
> <a href=3D"mailto:akka-user%2Bunsubscribe@googlegroups.com" target=3D"=
_blank">akka-user+unsubscribe@googlegroups.com</a>.<br>
> For more options, visit this group at<br>
> <a href=3D"http://groups.google.com/group/akka-user?hl=3Den" target=3D=
"_blank">http://groups.google.com/group/akka-user?hl=3Den</a>.<br>
<br>
<br>
<br>
--<br>
Jonas Bon=C3=A9r<br>
CTO<br>
Typesafe - The software stack for applications that scale<br>
Phone: <a href=3D"tel:%2B46%20733%20777%20123" value=3D"+46733777123" targe=
t=3D"_blank">+46 733 777 123</a><br>
Twitter:=C2=A0@jboner<br>
<br>
--<br>
You received this message because you are subscribed to the Google Groups &=
quot;Akka User List" group.<br>
To post to this group, send email to <a href=3D"mailto:akka-user@googlegrou=
ps.com" target=3D"_blank">akka-user@googlegroups.com</a>.<br>
To unsubscribe from this group, send email to <a href=3D"mailto:akka-user%2=
Bunsubscribe@googlegroups.com" target=3D"_blank">akka-user+unsubscribe@goog=
legroups.com</a>.<br>
For more options, visit this group at <a href=3D"http://groups.google.com/g=
roup/akka-user?hl=3Den" target=3D"_blank">http://groups.google.com/group/ak=
ka-user?hl=3Den</a>.<br>
<br>
</blockquote></div>
<p></p>
-- <br>
You received this message because you are subscribed to the Google Groups &=
quot;Akka User List" group.<br>
To post to this group, send email to <a href=3D"mailto:akka-user@googlegrou=
ps.com" target=3D"_blank">akka-user@googlegroups.com</a>.<br>
To unsubscribe from this group, send email to <a href=3D"mailto:akka-user%2=
Bunsubscribe@googlegroups.com" target=3D"_blank">akka-user+unsubscribe@goog=
legroups.com</a>.<br>
For more options, visit this group at <a href=3D"http://groups.google.com/g=
roup/akka-user?hl=3Den" target=3D"_blank">http://groups.google.com/group/ak=
ka-user?hl=3Den</a>.<br>
</blockquote></div>
<p></p>
-- <br>
You received this message because you are subscribed to the Google Groups &=
quot;Akka User List" group.<br>
To post to this group, send email to <a href=3D"mailto:akka-user@googlegrou=
ps.com" target=3D"_blank">akka-user@googlegroups.com</a>.<br>
To unsubscribe from this group, send email to <a href=3D"mailto:akka-user%2=
Bunsubscribe@googlegroups.com" target=3D"_blank">akka-user+unsubscribe@goog=
legroups.com</a>.<br>
For more options, visit this group at <a href=3D"http://groups.google.com/g=
roup/akka-user?hl=3Den" target=3D"_blank">http://groups.google.com/group/ak=
ka-user?hl=3Den</a>.<br>
</div></div></blockquote></div><br><br clear=3D"all"><div><br></div>-- <br>=
<span style=3D"text-indent:0px;letter-spacing:normal;font-variant:normal;te=
xt-align:-webkit-auto;font-style:normal;font-weight:normal;line-height:norm=
al;border-collapse:separate;text-transform:none;font-size:medium;white-spac=
e:normal;font-family:Times;word-spacing:0px"><span style=3D"font-family:ari=
al;font-size:small"><span style=3D"border-collapse:collapse;font-family:ari=
al,sans-serif;font-size:13px">Viktor Klang<br>
<br>Akka Tech Lead</span><div><font face=3D"arial, sans-serif"><span style=
=3D"border-collapse:collapse"><a href=3D"http://www.typesafe.com/" target=
=3D"_blank">Typesafe</a><span>=C2=A0</span>- </span></font><span>The softwa=
re stack for applications that scale</span><br>
<font face=3D"arial, sans-serif"><span style=3D"border-collapse:collapse"><=
br></span></font><font face=3D"arial, sans-serif"><span style=3D"border-col=
lapse:collapse">Twitter: @viktorklang</span></font></div></span></span><br>
<p></p>
-- <br>
You received this message because you are subscribed to the Google Groups &=
quot;Akka User List" group.<br>
To post to this group, send email to <a href=3D"mailto:akka-user@googlegrou=
ps.com" target=3D"_blank">akka-user@googlegroups.com</a>.<br>
To unsubscribe from this group, send email to <a href=3D"mailto:akka-user%2=
Bunsubscribe@googlegroups.com" target=3D"_blank">akka-user+unsubscribe@goog=
legroups.com</a>.<br>
For more options, visit this group at <a href=3D"http://groups.google.com/g=
roup/akka-user?hl=3Den" target=3D"_blank">http://groups.google.com/group/ak=
ka-user?hl=3Den</a>.<br>
</blockquote></div>
<p></p>
-- <br>
You received this message because you are subscribed to the Google Groups &=
quot;Akka User List" group.<br>
To post to this group, send email to <a href=3D"mailto:akka-user@googlegrou=
ps.com" target=3D"_blank">akka-user@googlegroups.com</a>.<br>
To unsubscribe from this group, send email to <a href=3D"mailto:akka-user%2=
Bunsubscribe@googlegroups.com" target=3D"_blank">akka-user+unsubscribe@goog=
legroups.com</a>.<br>
For more options, visit this group at <a href=3D"http://groups.google.com/g=
roup/akka-user?hl=3Den" target=3D"_blank">http://groups.google.com/group/ak=
ka-user?hl=3Den</a>.<br>
</div></div></blockquote></div><br><br clear=3D"all"><div><br></div>-- <br>=
<span style=3D"text-indent:0px;letter-spacing:normal;font-variant:normal;te=
xt-align:-webkit-auto;font-style:normal;font-weight:normal;line-height:norm=
al;border-collapse:separate;text-transform:none;font-size:medium;white-spac=
e:normal;font-family:Times;word-spacing:0px"><span style=3D"font-family:ari=
al;font-size:small"><span style=3D"border-collapse:collapse;font-family:ari=
al,sans-serif;font-size:13px">Viktor Klang<br>
<br>Akka Tech Lead</span><div><font face=3D"arial, sans-serif"><span style=
=3D"border-collapse:collapse"><a href=3D"http://www.typesafe.com/" target=
=3D"_blank">Typesafe</a><span>=C2=A0</span>- </span></font><span>The softwa=
re stack for applications that scale</span><br>
<font face=3D"arial, sans-serif"><span style=3D"border-collapse:collapse"><=
br></span></font><font face=3D"arial, sans-serif"><span style=3D"border-col=
lapse:collapse">Twitter: @viktorklang</span></font></div></span></span><br>
<p></p>
-- <br>
You received this message because you are subscribed to the Google Groups &=
quot;Akka User List" group.<br>
To post to this group, send email to <a href=3D"mailto:akka-user@googlegrou=
ps.com" target=3D"_blank">akka-user@googlegroups.com</a>.<br>
To unsubscribe from this group, send email to <a href=3D"mailto:akka-user%2=
Bunsubscribe@googlegroups.com" target=3D"_blank">akka-user+unsubscribe@goog=
legroups.com</a>.<br>
For more options, visit this group at <a href=3D"http://groups.google.com/g=
roup/akka-user?hl=3Den" target=3D"_blank">http://groups.google.com/group/ak=
ka-user?hl=3Den</a>.<br>
</blockquote></div>
--e89a8ffba9f564ebb804c03a8175--
Message from discussion java.lang.AssertionError: assertion failed in Router
| Create a group - Google Groups - Google Home - Terms of Service - Privacy Policy |
| ©2013 Google |