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.AbstractMultiTargetMessageTask<P>

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

All Implemented Interfaces:

SecureRequest, MessageTask, PartitionSpecificRunnable, Runnable

Direct Known Subclasses:

AuthenticationCustomCredentialsMessageTask, AuthenticationMessageTask

public abstract class AuthenticationBaseMessageTask<P>
extends AbstractMultiTargetMessageTask<P>

Base authentication task

Field Summary

Fields

Modifier and Type	Field and Description
protected byte	clientSerializationVersion
protected String	clientVersion
protected Credentials	credentials
protected ClientPrincipal	principal

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

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

Constructor Summary

Constructors

Constructor and Description
AuthenticationBaseMessageTask(ClientMessage clientMessage, Node node, Connection connection)

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)
protected abstract String	getClientType()
protected ClientEndpointImpl	getEndpoint()
Permission	getRequiredPermission()
Collection<Member>	getTargets()
protected boolean	isAuthenticationMessage()
protected abstract boolean	isOwnerConnection()
void	processMessage()
protected Object	reduce(Map<Member,Object> map)

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

decodeClientMessage, encodeResponse, getClientVersion, 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

clientSerializationVersion

protected transient byte clientSerializationVersion

clientVersion

protected transient String clientVersion

Constructor Detail

AuthenticationBaseMessageTask

public AuthenticationBaseMessageTask(ClientMessage clientMessage,
                                     Node node,
                                     Connection connection)

Method Detail

createOperationSupplier

protected Supplier<Operation> createOperationSupplier()

Specified by:

createOperationSupplier in class AbstractMultiTargetMessageTask<P>

reduce

protected Object reduce(Map<Member,Object> map)
                 throws Throwable

Specified by:

reduce in class AbstractMultiTargetMessageTask<P>

Throws:

Throwable

getTargets

public Collection<Member> getTargets()

Specified by:

getTargets in class AbstractMultiTargetMessageTask<P>

getEndpoint

protected ClientEndpointImpl getEndpoint()

Overrides:

getEndpoint in class AbstractMessageTask<P>

isAuthenticationMessage

protected boolean isAuthenticationMessage()

Overrides:

isAuthenticationMessage in class AbstractMessageTask<P>

processMessage

public void processMessage()
                    throws Throwable

Overrides:

processMessage in class AbstractMultiTargetMessageTask<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()