Package org.jppf.server.nio.nodeserver.async

Class AsyncNodeMessageHandler

java.lang.Object
org.jppf.server.nio.nodeserver.async.AsyncNodeMessageHandler
public class AsyncNodeMessageHandler extends Object
Handles messages received from and to send to the nodes.
Author:
Laurent Cohen

  • Field Details

    • resolveIPs

      protected final boolean resolveIPs
      Whether to resolve the nodes' ip addresses into host names.

  • Constructor Details

    • AsyncNodeMessageHandler

      public AsyncNodeMessageHandler(JPPFDriver driver)
      COnstruct this object.
      Parameters:
      driver - reference to the driver.

  • Method Details

    • sendHandshakeBundle

      public void sendHandshakeBundle(AsyncNodeContext context, ServerTaskBundleNode bundle) throws Exception
      Send a hanshake bundle to a node.
      Parameters:
      context - the channel sending the bundle.
      bundle - the task bundle to send.
      Throws:
      Exception - if any error occurs.

    • handshakeReceived

      public void handshakeReceived(AsyncNodeContext context, AbstractTaskBundleMessage message) throws Exception
      Called when a hanshake response is received from a node.
      Parameters:
      context - the channel that received the repsonse.
      message - the handshake response.
      Throws:
      Exception - if any error occurs.

    • resultsReceived

      public void resultsReceived(AsyncNodeContext context, AbstractTaskBundleMessage message) throws Exception
      Called when job results are received from a node.
      Parameters:
      context - the channel that received the response.
      message - the received results.
      Throws:
      Exception - if any error occurs.