Hi
im having some problems with Remote Actors and ActiveObjectConfigurator.
SimplePojo is just a serialisible class with one String field and a get/set
when i do:
RemoteNode.start();
SimplePojo instance = ActiveObject.newRemoteInstance(SimplePojo.class, 10000l, "localhost", 9999);
instance.setName("nils");
System.out.println("name: " + instance.getName());
it works
but when i use
RemoteNode.start();
SimplePojo instance = conf.getInstance(SimplePojo.class);
instance.setName("nils");
System.out.println("name: " + instance.getName());
it doesnt
configuration for the later:
ActiveObjectConfigurator conf = new ActiveObjectConfigurator();
conf.configure(new RestartStrategy(new AllForOne(), 3, 5000, new Class[]{Exception.class}),
new Component[]{
new Component(SimplePojo.class, new LifeCycle(new Permanent()), 10000, new RemoteAddress("localhost", 9999))
}).inject().supervise();
log:
DEB [20100408-09:35:34.296] actor: [Actor[se.rty.akka.akka_sample_java.SimplePojo:1270728910494]] has started
DEB [20100408-09:35:34.422] internal: Interceptors creation: 109ms
DEB [20100408-09:35:34.428] internal: Scopes creation: 6ms
DEB [20100408-09:35:34.437] internal: Converters creation: 9ms
DEB [20100408-09:35:34.451] internal: Binding creation: 14ms
DEB [20100408-09:35:34.452] internal: Binding indexing: 1ms
DEB [20100408-09:35:34.456] internal: Static injection: 4ms
DEB [20100408-09:35:34.456] internal: Validation: 0ms
DEB [20100408-09:35:34.457] internal: Static validation: 1ms
DEB [20100408-09:35:34.457] internal: Instance member validation: 0ms
DEB [20100408-09:35:34.459] internal: Provider verification: 2ms
DEB [20100408-09:35:34.459] internal: Static member injection: 0ms
DEB [20100408-09:35:34.460] internal: Instance injection: 1ms
DEB [20100408-09:35:34.462] internal: Preloading: 2ms
DEB [20100408-09:35:34.474] actor: [Actor[se.scalablesolutions.akka.actor.Supervisor:1270728911683]] has started
DEB [20100408-09:35:34.476] actor: [Actor[se.rty.akka.akka_sample_java.SimplePojo:1270728910494]] has started
DEB [20100408-09:35:34.478] actor: Linking actor [Actor[se.rty.akka.akka_sample_java.SimplePojo:1270728910494]] to actor [Actor[se.scalablesolutions.akka.actor.Supervisor:1270728911683]]
DEB [20100408-09:35:34.479] actor: [Actor[se.scalablesolutions.akka.actor.Supervisor:1270728911683]] has started
DEB [20100408-09:35:34.480] actor: [Actor[se.scalablesolutions.akka.actor.Supervisor:1270728911683]] has started
DEB [20100408-09:35:34.481] config: Retrieving active object [se.rty.akka.akka_sample_java.SimplePojo]
Testcase: testRemote(se.rty.akka.akka_sample_java.IntegrationTest): Caused an ERROR
None.get
java.util.NoSuchElementException: None.get
at scala.None$.get(Option.scala:169)
at scala.None$.get(Option.scala:167)
at se.scalablesolutions.akka.actor.Actor$class.registerSupervisorAsRemoteActor(Actor.scala:1037)
at se.scalablesolutions.akka.actor.Dispatcher.registerSupervisorAsRemoteActor(ActiveObject.scala:366)
at se.scalablesolutions.akka.actor.ActiveObjectAspect.remoteDispatch(ActiveObject.scala:290)
at se.scalablesolutions.akka.actor.ActiveObjectAspect.dispatch(ActiveObject.scala:260)
at se.scalablesolutions.akka.actor.ActiveObjectAspect.invoke(ActiveObject.scala:256)
at se.rty.akka.akka_sample_java.SimplePojo$$ProxiedByAWSubclassing$$1270728910693_1__1184972270_1618486575___AW_JoinPoint.proceed(Unknown Source)
at se.rty.akka.akka_sample_java.SimplePojo$$ProxiedByAWSubclassing$$1270728910693_1__1184972270_1618486575___AW_JoinPoint.invoke(Unknown Source)
at se.rty.akka.akka_sample_java.SimplePojo$$ProxiedByAWSubclassing$$1270728910693.setName(Unknown Source)
at se.rty.akka.akka_sample_java.IntegrationTest.testRemote(IntegrationTest.java:75)