raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

added invocation object + equals/hashCode methods

Browse source
This commit is contained in:
Jonas Boner 2009-05-25 15:18:18 +02:00
parent eadd316a34
commit 8c11f04262
8 changed files with 131 additions and 142 deletions
Download patch file Download diff file Expand all files Collapse all files

31
kernel/src/main/scala/ActiveObject.scala
View file

@ -160,10 +160,10 @@ sealed class TransactionalAroundAdvice(target: Class[_],
threadBoundTx.set(Some(tx))
}
private def sendOneWay(joinpoint: JoinPoint) = server ! (activeTx, joinpoint)
private def sendOneWay(joinpoint: JoinPoint) = server ! Invocation(joinpoint, activeTx)
private def sendAndReceiveEventually(joinpoint: JoinPoint): ErrRef[AnyRef] = {
server !!! ((activeTx, joinpoint), {
server !!! (Invocation(joinpoint, activeTx), {
var ref = ErrRef(activeTx)
ref() = throw new ActiveObjectInvocationTimeoutException("Invocation to active object [" + targetInstance.getClass.getName + "] timed out after " + server.timeout + " milliseconds")
ref
@ -240,6 +240,33 @@ private[kernel] class Dispatcher(val targetName: String) extends GenericServer {
override def toString(): String = "GenericServer[" + targetName + "]"
}
/**
* Represents a snapshot of the current invocation.
*
* @author <a href="http://jonasboner.com">Jonas Bon&#233;r</a>
*/
private[kernel] case class Invocation(val joinpoint: JoinPoint, val transaction: Option[Transaction]) {
override def toString: String = synchronized {
"Invocation [joinpoint: " + joinpoint.toString+ " | transaction: " + transaction.toString + "]"
}
override def hashCode(): Int = synchronized {
var result = HashCode.SEED
result = HashCode.hash(result, joinpoint)
if (transaction.isDefined) result = HashCode.hash(result, transaction.get)
result
}
override def equals(that: Any): Boolean = synchronized {
that != null &&
that.isInstanceOf[Invocation] &&
that.asInstanceOf[Invocation].joinpoint == joinpoint &&
that.asInstanceOf[Invocation].transaction.getOrElse(false) == transaction.getOrElse(false)
}
}
/*
ublic class CamelInvocationHandler implements InvocationHandler {
private final Endpoint endpoint;