THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
if (channelBuilder.isInstanceOf[SaslChannelBuilder]) channelBuilder.asInstanceOf[SaslChannelBuilder].authenticationRequestEnqueuer( new AuthenticationRequestEnqueuer() { def enqueueRequest(nodeId: String, apiVersionsRequestBuilder: ApiVersionsRequest.Builder, callback: AuthenticationRequestCompletionHandler): Unit = sendRequest(nodeId.toInt, apiVersionsRequestBuilder.apiKey(), apiVersionsRequestBuilder, null, callback) def enqueueRequest(nodeId: String, saslHandshakeRequestBuilder: SaslHandshakeRequest.Builder, callback: AuthenticationRequestCompletionHandler): Unit = sendRequest(nodeId.toInt, saslHandshakeRequestBuilder.apiKey(), saslHandshakeRequestBuilder, null, callback) def enqueueRequest(nodeId: String, saslAuthenticateRequestBuilder: SaslAuthenticateRequest.Builder, callback: AuthenticationRequestCompletionHandler): Unit = sendRequest(nodeId.toInt, saslAuthenticateRequestBuilder.apiKey(), saslAuthenticateRequestBuilder, null, callback) }) |
...