com.hazelcast.client.impl.protocol.task

Class AuthenticationBaseMessageTask<P>

java.lang.Object

com.hazelcast.client.impl.protocol.task.AbstractMessageTask<P>

com.hazelcast.client.impl.protocol.task.AbstractStableClusterMessageTask<P>

com.hazelcast.client.impl.protocol.task.AuthenticationBaseMessageTask<P>

All Implemented Interfaces:

SecureRequest, BlockingMessageTask, MessageTask, ExecutionCallback, PartitionSpecificRunnable, Runnable

Direct Known Subclasses:

AuthenticationCustomCredentialsMessageTask, AuthenticationMessageTask

public abstract class AuthenticationBaseMessageTask<P>
extends AbstractStableClusterMessageTask<P>
implements BlockingMessageTask

Base authentication task

Field Summary

Fields

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

Fields inherited from class com.hazelcast.client.impl.protocol.task.AbstractMessageTask

clientEngine, clientMessage, connection, endpoint, logger, nodeEngine, parameters, serializationService

Method Summary

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)

Methods inherited from class com.hazelcast.client.impl.protocol.task.AbstractStableClusterMessageTask

onFailure, onResponse

Methods inherited from class com.hazelcast.client.impl.protocol.task.AbstractMessageTask

decodeClientMessage, encodeResponse, getDistributedObjectName, getDistributedObjectType, getMemberBuildInfo, getMethodName, getParameters, getPartitionId, getService, getServiceName, handleProcessingFailure, isAdvancedNetworkEnabled, run, sendClientMessage, sendClientMessage, sendClientMessage, sendResponse

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

principal

protected transient ClientPrincipal principal

clientName

protected transient String clientName

labels

protected transient Set<String> labels

credentials

protected transient Credentials credentials

clusterId

protected transient String clusterId

partitionCount

protected transient Integer partitionCount

Method Detail

createOperationSupplier

protected Supplier<Operation> createOperationSupplier()

resolve

protected Object resolve(Object response)

Specified by:

resolve in class AbstractStableClusterMessageTask<P>

requiresAuthentication

protected boolean requiresAuthentication()

Overrides:

requiresAuthentication in class AbstractMessageTask<P>

processMessage

public void processMessage()
                    throws Throwable

Overrides:

processMessage in class AbstractStableClusterMessageTask<P>

Throws:

Throwable

encodeAuth

protected abstract ClientMessage encodeAuth(byte status,
                                            Address thisAddress,
                                            String uuid,
                                            String ownerUuid,
                                            byte serializationVersion,
                                            List<Member> cleanedUpMembers,
                                            int partitionCount,
                                            String clusterId)

isOwnerConnection

protected abstract boolean isOwnerConnection()

getClientType

protected abstract String getClientType()

getRequiredPermission

public Permission getRequiredPermission()

Specified by:

getRequiredPermission in interface SecureRequest