org.opendaylight.controller.cluster.access.client

Class ClientActorBehavior<T extends BackendInfo>

java.lang.Object

org.opendaylight.controller.cluster.access.client.AbstractClientActorBehavior<C>

org.opendaylight.controller.cluster.access.client.ClientActorBehavior<T>

All Implemented Interfaces:

AutoCloseable, org.opendaylight.yangtools.concepts.Identifiable<ClientIdentifier>

@Beta
public abstract class ClientActorBehavior<T extends BackendInfo>
extends AbstractClientActorBehavior<C>
implements org.opendaylight.yangtools.concepts.Identifiable<ClientIdentifier>

A behavior, which handles messages sent to a AbstractClientActor.

Author:

Robert Varga

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static interface	ClientActorBehavior.ConnectionConnectCohort Connection reconnect cohort, driven by this class.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ClientActorBehavior(ClientActorContext context, BackendInfoResolver<T> resolver)

Method Summary

Modifier and Type	Method and Description
void	close()
protected abstract ClientActorBehavior.ConnectionConnectCohort	connectionUp(ConnectedClientConnection<T> newConn) Callback invoked when a new connection has been established.
AbstractClientConnection<T>	getConnection(Long shard) Get a connection to a shard.
ClientIdentifier	getIdentifier()
protected abstract void	haltClient(Throwable cause) Halt And Catch Fire.
protected abstract ClientActorBehavior<T>	onCommand(Object command) Override this method to handle any command which is not handled by the base behavior.
protected BackendInfoResolver<T>	resolver() Override this method to provide a backend resolver instance.

Methods inherited from class org.opendaylight.controller.cluster.access.client.AbstractClientActorBehavior

context, persistenceId, self

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientActorBehavior

protected ClientActorBehavior(@Nonnull
                              ClientActorContext context,
                              @Nonnull
                              BackendInfoResolver<T> resolver)

Method Detail

getIdentifier

@Nonnull
public final ClientIdentifier getIdentifier()

Specified by:

getIdentifier in interface org.opendaylight.yangtools.concepts.Identifiable<ClientIdentifier>

close

public void close()

Specified by:

close in interface AutoCloseable

Overrides:

close in class AbstractClientActorBehavior<ClientActorContext>

getConnection

public final AbstractClientConnection<T> getConnection(Long shard)

Get a connection to a shard.

Parameters:

shard - Shard cookie

Returns:

Connection to a shard

Throws:

InversibleLockException - if the shard is being reconnected

haltClient

protected abstract void haltClient(@Nonnull
                                   Throwable cause)

Halt And Catch Fire. Halt processing on this client. Implementations need to ensure they initiate state flush procedures. No attempt to use this instance should be made after this method returns. Any such use may result in undefined behavior.

Parameters:

cause - Failure cause

onCommand

@Nullable
protected abstract ClientActorBehavior<T> onCommand(@Nonnull
                                                              Object command)

Override this method to handle any command which is not handled by the base behavior.

Parameters:

command - the command to process

Returns:

Next behavior to use, null if this actor should shut down.

resolver

@Nonnull
protected final BackendInfoResolver<T> resolver()

Override this method to provide a backend resolver instance.

Returns:

a backend resolver instance

connectionUp

@Nonnull
protected abstract ClientActorBehavior.ConnectionConnectCohort connectionUp(@Nonnull
                                                                                     ConnectedClientConnection<T> newConn)

Callback invoked when a new connection has been established. Implementations are expected perform preparatory tasks before the previous connection is frozen.

Parameters:

newConn - New connection

Returns:

ConnectionConnectCohort which will be used to complete the process of bringing the connection up.