org.opendaylight.controller.cluster.datastore

Class TransactionReadyReplyMapper

java.lang.Object

scala.runtime.AbstractFunction1<T,R>

akka.dispatch.Mapper<Object,akka.actor.ActorSelection>

org.opendaylight.controller.cluster.datastore.TransactionReadyReplyMapper

All Implemented Interfaces:

scala.Function1<Object,akka.actor.ActorSelection>

public class TransactionReadyReplyMapper
extends akka.dispatch.Mapper<Object,akka.actor.ActorSelection>

A Mapper extracting the ActorSelection pointing to the actor which is backing a particular transaction.

This class is not for general consumption. It is public only to support the pre-lithium compatibility package. TODO: once we remove compatibility, make this class package-private and final.

Field Summary

Fields

Modifier and Type	Field and Description
protected static akka.dispatch.Mapper<Throwable,Throwable>	SAME_FAILURE_TRANSFORMER

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TransactionReadyReplyMapper(ActorContext actorContext, TransactionIdentifier identifier)

Method Summary

Modifier and Type	Method and Description
akka.actor.ActorSelection	checkedApply(Object serializedReadyReply)
protected String	extractCohortPathFrom(ReadyTransactionReply readyTxReply)
protected ActorContext	getActorContext()

Methods inherited from class akka.dispatch.Mapper

apply

Methods inherited from class scala.runtime.AbstractFunction1

andThen, apply$mcDD$sp, apply$mcDF$sp, apply$mcDI$sp, apply$mcDJ$sp, apply$mcFD$sp, apply$mcFF$sp, apply$mcFI$sp, apply$mcFJ$sp, apply$mcID$sp, apply$mcIF$sp, apply$mcII$sp, apply$mcIJ$sp, apply$mcJD$sp, apply$mcJF$sp, apply$mcJI$sp, apply$mcJJ$sp, apply$mcVD$sp, apply$mcVF$sp, apply$mcVI$sp, apply$mcVJ$sp, apply$mcZD$sp, apply$mcZF$sp, apply$mcZI$sp, apply$mcZJ$sp, compose, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.Function1

$init$

Field Detail

SAME_FAILURE_TRANSFORMER

protected static final akka.dispatch.Mapper<Throwable,Throwable> SAME_FAILURE_TRANSFORMER

Constructor Detail

TransactionReadyReplyMapper

protected TransactionReadyReplyMapper(ActorContext actorContext,
                                      TransactionIdentifier identifier)

Method Detail

getActorContext

protected final ActorContext getActorContext()

extractCohortPathFrom

protected String extractCohortPathFrom(ReadyTransactionReply readyTxReply)

checkedApply

public final akka.actor.ActorSelection checkedApply(Object serializedReadyReply)

Overrides:

checkedApply in class akka.dispatch.Mapper<Object,akka.actor.ActorSelection>