Re: [Aglets-developer] Even after getting loacl proxy properly why local messaging between aglets
Status: Beta
Brought to you by:
cat4hire
Menu
▾
▴
Re: [Aglets-developer] Even after getting loacl proxy properly why local messaging between aglets throws com.ibm.aglet.NotHandledException ..?
|
From: Anil K. <akr...@ya...> - 2005-10-11 19:12:12
|
Hi Luca and ALL ,
Is aglet messaging not working earlier also ( i mean
in earlier versions ) ..? Since aglet messaging is
the main thing ,if it does not work i will be into lot
of problems. Can you guys ( other developers /users )
are communicating with aglets ..?
I tried printing the print stack trace in both cases(
local messaging and remote messaging ) . Please let me
know what is wrong.
Stack trace with local proxy .... Local messaging .
------STARTS
$$$$$$$$$$ The new agent has ID =e308f78be33d8ad4
localProxy is :AgletProxyImpl : Aglet [active]
ClassName [baglets.agletB]
Identifier[e308f78be33d8ad4]
Owner[CN=anilkumar, OU=erl, O=umr, L=rolla,
ST=mo, C=us]
CodeBase[atp://r24intelsys:4434/]
CN=anilkumar, OU=erl, O=umr, L=rolla, ST=mo, C=us
myID is :e308f78be33d8ad4
Message is not sent .Exception is
:com.ibm.aglet.NotHandledException: [Message : kind =
HELLO: arg = {}: priority = 5]
com.ibm.aglet.NotHandledException: [Message : kind =
HELLO: arg = {}: priority = 5]
at
com.ibm.aglets.FutureReplyImpl.cancel(Unknown Source)
at com.ibm.aglets.MessageImpl.handle(Unknown
Source)
at com.ibm.aglets.AgletThread.run(Unknown
Source)
Stack trace with local proxy .... Local messaging .
------ENDS
Stack trace with Remote proxy .... remote messaging
.-STARTS
$$$$$$$$$$ The new agent has ID =dbd9468f8f969b9e
myID is :dbd9468f8f969b9e
***** Addr: atp://131.151.8.211 place:
No integrity check because no security domain is
authenticated.
remoteProxy is :AgletProxyImpl : RemoteAgletRef :
null .. WeakRef[count=1]
Message is not sent .Exception is
:com.ibm.aglet.NotHandledException:
com.ibm.maf.NotHandled:null
com.ibm.aglet.NotHandledException:
com.ibm.maf.NotHandled:null
at
com.ibm.aglets.MessageBroker.sendMessage(Unknown
Source)
at
com.ibm.aglets.RemoteAgletRef.sendMessage(Unknown
Source)
at
com.ibm.aglets.AgletProxyImpl.sendMessage(Unknown
Source)
at old.agletA.run(agletA.java:33)
at com.ibm.aglets.SystemMessage.handle(Unknown
Source)
at com.ibm.aglets.AgletThread.run(Unknown
Source)
Stack trace with Remote proxy .... remote messaging
.-ENDS
For your easy reference i am copying the files that
i used to produce the stack trace.
/////////////////////// files used for remote
messaging/////////////////////////////////////////
package old;
import com.ibm.aglet.*;
import java.net.*;
public class agletA extends Aglet {
public void run()
{
try
{
//Get the aglet context
AgletContext context =
this.getAgletContext();
//Create the agletB instance.
AgletProxy toMove =
context.createAglet(null, "old.agletB", null);
//Save the new aglet ID
AgletID remoteID = toMove.getAgletID();
System.out.println(" $$$$$$$$$$ The
new agent has ID ="+remoteID);
//Migrate the new agent
String remoteContext =
"atp://131.151.8.211:4434";
URL url = new URL(remoteContext);
toMove.dispatch(url);
//Get the remote Proxy
AgletProxy remoteProxy =
context.getAgletProxy(url,remoteID);
try
{
System.out.println(" remoteProxy is
:"+remoteProxy);
//Send message to the remote agent
remoteProxy.sendMessage(new
Message("HELLO"));
}
catch(Exception e)
{
System.out.println("Message is not
sent .Exception is :"+e);
}
}
catch(Exception e )
{
System.out.println("Exception is :"+e);
}
}
}
package old;
import com.ibm.aglet.*;
import java.net.*;
public class agletB extends Aglet {
public void run()
{
try
{
AgletID myID = this.getAgletID();
System.out.println(" myID is :"+myID);
}
catch (Exception e)
{
System.out.println("Exception is :"+e);
}
}
//handle the message.
public boolean handleMessgae(Message msg)
{
if( msg.sameKind("HELLO"))
{
System.out.println("I am aglet . HELLO
message received from agletA. ");
return true;
}
return false;
}
}
Error with Remote messaging .
$$$$$$$$$$ The new agent has ID =dbd9468f8f969b9e
myID is :dbd9468f8f969b9e
***** Addr: atp://131.151.8.211 place:
No integrity check because no security domain is
authenticated.
remoteProxy is :AgletProxyImpl : RemoteAgletRef :
null .. WeakRef[count=1]
Message is not sent .Exception is
:com.ibm.aglet.NotHandledException:
com.ibm.maf.NotHandled:null
com.ibm.aglet.NotHandledException:
com.ibm.maf.NotHandled:null
at
com.ibm.aglets.MessageBroker.sendMessage(Unknown
Source)
at
com.ibm.aglets.RemoteAgletRef.sendMessage(Unknown
Source)
at
com.ibm.aglets.AgletProxyImpl.sendMessage(Unknown
Source)
at old.agletA.run(agletA.java:33)
at com.ibm.aglets.SystemMessage.handle(Unknown
Source)
at com.ibm.aglets.AgletThread.run(Unknown
Source)
/////////////////////// files used for LOCAL
messaging /////////////////////////////////////////
NOte : "agletB.java" file is the same as above.
package old;
import com.ibm.aglet.*;
import java.net.*;
public class agletA extends Aglet {
public void run()
{
try
{
//Get the aglet context
AgletContext context =
this.getAgletContext();
//Create the agletB instance.
AgletProxy toMove =
context.createAglet(null, "old.agletB", null);
//Save the new aglet ID
AgletID loacalID = toMove.getAgletID();
System.out.println(" $$$$$$$$$$ The
new agent has ID ="+loacalID);
//Get the Local Proxy
AgletProxy loacalProxy =
context.getAgletProxy(loacalID);
try
{
System.out.println(" localProxy is
:"+loacalProxy);
//Send message to the remote agent
loacalProxy.sendMessage(new
Message("HELLO"));
}
catch(Exception e)
{
System.out.println("Message is not
sent .Exception is :"+e);
}
}
catch(Exception e )
{
System.out.println("Exception is :"+e);
}
}
}
Error with local messaging .
$$$$$$$$$$ The new agent has ID
=e308f78be33d8ad4
localProxy is :AgletProxyImpl : Aglet [active]
ClassName [baglets.agletB]
Identifier[e308f78be33d8ad4]
Owner[CN=anilkumar, OU=erl, O=umr, L=rolla,
ST=mo, C=us]
CodeBase[atp://r24intelsys:4434/]
CN=anilkumar, OU=erl, O=umr, L=rolla, ST=mo, C=us
myID is :e308f78be33d8ad4
Message is not sent .Exception is
:com.ibm.aglet.NotHandledException: [Message : kind =
HELLO: arg = {}: priority = 5]
com.ibm.aglet.NotHandledException: [Message : kind =
HELLO: arg = {}: priority = 5]
at
com.ibm.aglets.FutureReplyImpl.cancel(Unknown Source)
at com.ibm.aglets.MessageImpl.handle(Unknown
Source)
at com.ibm.aglets.AgletThread.run(Unknown
Source)
Plase let me know what is wrong ...?
Thanks
Anil
--- Luca Ferrari <cat...@us...>
wrote:
> Anil Kumar's cat, on 11/10/2005 1.14, walking on the
> keyboard wrote:
> > Message is not sent .Exception is
> > :com.ibm.aglet.NotHandledException: [Message :
> kind =
> > HELLO: arg = {}: priority = 5]
>
>
> I suspect the problem is in the
> FutureReplyImpl.getReply method, but to
> be sure I'd like to see the stacktrace. It would be
> helpful if you
> kindly add to your catch clauses a printStackTrace()
> instruction, and
> send me back the backtrace.
>
> Thanks,
> Luca
>
> --
> +-------------------------------+
> Luca Ferrari
> cat...@us...
>
> The Aglets Project:
> http://aglets.sourceforge.net
> +-------------------------------+
>
__________________________________
Yahoo! Mail - PC Magazine Editors' Choice 2005
http://mail.yahoo.com
|