public abstract class AuthenticationBaseMessageTask<P> extends AbstractStableClusterMessageTask<P>
Modifier and Type | Field and Description |
---|---|
protected String |
clientName |
protected String |
clusterId |
protected Credentials |
credentials |
protected Set<String> |
labels |
protected Integer |
partitionCount |
protected ClientPrincipal |
principal |
clientEngine, clientMessage, connection, endpoint, logger, nodeEngine, parameters, serializationService
Modifier and Type | Method and Description |
---|---|
protected Supplier<Operation> |
createOperationSupplier() |
protected abstract ClientMessage |
encodeAuth(byte status,
Address thisAddress,
String uuid,
String ownerUuid,
byte serializationVersion,
List<Member> cleanedUpMembers,
int partitionCount,
String clusterId) |
protected abstract String |
getClientType() |
Permission |
getRequiredPermission() |
protected abstract boolean |
isOwnerConnection() |
void |
processMessage() |
protected boolean |
requiresAuthentication() |
protected Object |
resolve(Object response) |
onFailure, onResponse
decodeClientMessage, encodeResponse, getDistributedObjectName, getDistributedObjectType, getMemberBuildInfo, getMethodName, getParameters, getPartitionId, getService, getServiceName, handleProcessingFailure, isAdvancedNetworkEnabled, run, sendClientMessage, sendClientMessage, sendClientMessage, sendResponse
protected transient ClientPrincipal principal
protected transient String clientName
protected transient Credentials credentials
protected transient String clusterId
protected transient Integer partitionCount
protected Object resolve(Object response)
resolve
in class AbstractStableClusterMessageTask<P>
protected boolean requiresAuthentication()
requiresAuthentication
in class AbstractMessageTask<P>
public void processMessage() throws Throwable
processMessage
in class AbstractStableClusterMessageTask<P>
Throwable
protected abstract ClientMessage encodeAuth(byte status, Address thisAddress, String uuid, String ownerUuid, byte serializationVersion, List<Member> cleanedUpMembers, int partitionCount, String clusterId)
protected abstract boolean isOwnerConnection()
protected abstract String getClientType()
public Permission getRequiredPermission()
Copyright © 2019 Hazelcast, Inc.. All Rights Reserved.