Guest User

Untitled

a guest
Jun 21st, 2018
90
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Scala 3.37 KB | None | 0 0
  1. //on one node
  2. class EndpointManager extends TypedActor with EndpointManager{
  3. remote.start()
  4. remote.registerTypedActor(Constants.endpointManagerServiceId, this)
  5. //...
  6. dispatcher ! Register(hostname, port)
  7. def getTrue: Boolean = true
  8. }
  9.  
  10. //on one other node
  11. remote.start()
  12. def receive = {
  13. case Register(hostname, port)=> {
  14.       val endpointManager = Actor.remote.typedActorFor(classOf[EndpointManager],   Constants.endpointManagerServiceId, 5000L, hostname, port)
  15.       println(endpointManager.getTrue)
  16.   }
  17. //...
  18. }
  19.  
  20. //and the result is
  21. 21:35:04.563 [akka:event-driven:dispatcher:event:handler-12] DEBUG akka.event.slf4j.Slf4jEventHandler -
  22.     [RemoteClientStarted(akka.remote.netty.NettyRemoteSupport@60a1e929,/192.168.1.44:2552)]
  23. 21:35:04.563 [akka:event-driven:dispatcher:event:handler-12] DEBUG akka.event.slf4j.Slf4jEventHandler -
  24.     [RemoteClientConnected(akka.remote.netty.NettyRemoteSupport@60a1e929,/192.168.1.44:2552)]
  25. 21:35:14.723 [akka:event-driven:dispatcher:event:handler-16] DEBUG akka.event.slf4j.Slf4jEventHandler -
  26.     [RemoteClientShutdown(akka.remote.netty.NettyRemoteSupport@60a1e929,/192.168.1.44:2552)]
  27. 21:35:14.742 [akka:event-driven:dispatcher:event:handler-17] DEBUG akka.event.slf4j.Slf4jEventHandler -
  28.     [RemoteClientDisconnected(akka.remote.netty.NettyRemoteSupport@60a1e929,/192.168.1.44:2552)]
  29. 21:35:49.183 [akka:event-driven:dispatcher:event:handler-20] DEBUG akka.event.slf4j.Slf4jEventHandler -
  30.     [RemoteServerClientConnected(akka.remote.netty.NettyRemoteSupport@60a1e929,Some(/192.168.1.44:53581))]
  31. 21:35:49.184 [akka:event-driven:dispatcher:event:handler-20] ERROR akka.event.slf4j.Slf4jEventHandler -
  32.     [akka.remote.netty.RemoteServerHandler]
  33.     [null]
  34.     [java.lang.NullPointerException
  35.     at akka.remote.netty.RemoteServerHandler.dispatchToTypedActor(NettyRemoteSupport.scala:1165)
  36.     at akka.remote.netty.RemoteServerHandler.handleRemoteMessageProtocol(NettyRemoteSupport.scala:1020)
  37.     at akka.remote.netty.RemoteServerHandler.messageReceived(NettyRemoteSupport.scala:1002)
  38.     at org.jboss.netty.channel.SimpleChannelUpstreamHandler.handleUpstream(SimpleChannelUpstreamHandler.java:80)
  39.     at org.jboss.netty.channel.StaticChannelPipeline.sendUpstream(StaticChannelPipeline.java:372)
  40.     at org.jboss.netty.channel.StaticChannelPipeline$StaticChannelHandlerContext.sendUpstream(StaticChannelPipeline.java:534)
  41.     at org.jboss.netty.handler.execution.ChannelEventRunnable.run(ChannelEventRunnable.java:69)
  42.     at org.jboss.netty.handler.execution.OrderedMemoryAwareThreadPoolExecutor$ChildExecutor.run(OrderedMemoryAwareThreadPoolExecutor.java:316)
  43.     at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
  44.     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
  45.     at java.lang.Thread.run(Thread.java:662)
  46. ]
  47. 21:35:49.196 [akka:event-driven:dispatcher:event:handler-21] DEBUG akka.event.slf4j.Slf4jEventHandler -
  48.     [RemoteServerError(java.lang.NullPointerException,akka.remote.netty.NettyRemoteSupport@60a1e929)]
  49. 21:35:59.309 [akka:event-driven:dispatcher:event:handler-22] DEBUG akka.event.slf4j.Slf4jEventHandler -
  50.     [RemoteServerClientDisconnected(akka.remote.netty.NettyRemoteSupport@60a1e929,Some(/192.168.1.44:53581))]
  51. 21:35:59.311 [akka:event-driven:dispatcher:event:handler-23] DEBUG akka.event.slf4j.Slf4jEventHandler -
  52.     [RemoteServerClientClosed(akka.remote.netty.NettyRemoteSupport@60a1e929,Some(/192.168.1.44:53581))]
Add Comment
Please, Sign In to add comment