Class SaslNettyClient

java.lang.Object
org.apache.storm.messaging.netty.SaslNettyClient

public class SaslNettyClient extends Object
Implements SASL logic for storm worker client processes.
  • Constructor Details

    • SaslNettyClient

      public SaslNettyClient(String topologyName, byte[] token)
      Create a SaslNettyClient for authentication with servers.
  • Method Details

    • isComplete

      public boolean isComplete()
    • saslResponse

      public byte[] saslResponse(SaslMessageToken saslTokenMessage)
      Respond to server's SASL token.
      Parameters:
      saslTokenMessage - contains server's SASL token
      Returns:
      client's response SASL token