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

All Implemented Interfaces:

SecureRequest, BlockingMessageTask, MessageTask, UrgentMessageTask, UrgentSystemOperation, PartitionSpecificRunnable, Runnable

Direct Known Subclasses:

AuthenticationCustomCredentialsMessageTask, AuthenticationMessageTask

public abstract class AuthenticationBaseMessageTask<P>
extends AbstractMessageTask<P>
implements BlockingMessageTask, UrgentMessageTask

Base authentication task

Field Summary

Fields

Modifier and Type	Field and Description
protected String	clientName
protected UUID	clientUuid
protected UUID	clusterId
protected Credentials	credentials
protected Set<String>	labels
protected int	partitionCount

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 abstract ClientMessage	encodeAuth(byte status, Address thisAddress, UUID uuid, byte serializationVersion, int partitionCount, UUID clusterId)
protected abstract String	getClientType()
int	getPartitionId() Returns the partition ID.
Permission	getRequiredPermission()
void	processMessage()
protected boolean	requiresAuthentication()

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

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Runnable

run

Field Detail

clientUuid

protected transient UUID clientUuid

clientName

protected transient String clientName

labels

protected transient Set<String> labels

credentials

protected transient Credentials credentials

clusterId

protected transient UUID clusterId

partitionCount

protected transient int partitionCount

Method Detail

getPartitionId

public int getPartitionId()

Description copied from interface: PartitionSpecificRunnable

Returns the partition ID. If the partition ID is smaller than 0, than it isn't specific to a partition.

Specified by:

getPartitionId in interface PartitionSpecificRunnable

Returns:

the partition ID

requiresAuthentication

protected boolean requiresAuthentication()

Overrides:

requiresAuthentication in class AbstractMessageTask<P>

processMessage

public void processMessage()

Specified by:

processMessage in class AbstractMessageTask<P>

encodeAuth

protected abstract ClientMessage encodeAuth(byte status,
                                            Address thisAddress,
                                            UUID uuid,
                                            byte serializationVersion,
                                            int partitionCount,
                                            UUID clusterId)

getClientType

protected abstract String getClientType()

getRequiredPermission

public Permission getRequiredPermission()

Specified by:

getRequiredPermission in interface SecureRequest