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 Credentials	credentials
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 void	doRun()
protected abstract ClientMessage	encodeAuth(byte status, Address thisAddress, String uuid, String ownerUuid, byte serializationVersion, List<Member> cleanedUpMembers)
protected abstract String	getClientType()
Permission	getRequiredPermission()
protected abstract boolean	isOwnerConnection()
void	processMessage()
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, 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

credentials

protected transient Credentials credentials

Method Detail

createOperationSupplier

protected Supplier<Operation> createOperationSupplier()

resolve

protected Object resolve(Object response)

Specified by:

resolve in class AbstractStableClusterMessageTask<P>

doRun

protected void doRun()
              throws Throwable

Overrides:

doRun in class AbstractMessageTask<P>

Throws:

Throwable

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)

isOwnerConnection

protected abstract boolean isOwnerConnection()

getClientType

protected abstract String getClientType()

getRequiredPermission

public Permission getRequiredPermission()

Specified by:

getRequiredPermission in interface SecureRequest