diff --git a/src/main/java/fucoin/actions/join/ActionJoinAnswer.java b/src/main/java/fucoin/actions/join/ActionJoinAnswer.java index 677d1ff4d097bce815c72c3891a8f91651e8d971..89c4aadba026ce04ef9b2190b21566fdb7e68874 100644 --- a/src/main/java/fucoin/actions/join/ActionJoinAnswer.java +++ b/src/main/java/fucoin/actions/join/ActionJoinAnswer.java @@ -2,9 +2,13 @@ package fucoin.actions.join; import akka.actor.ActorRef; import akka.actor.UntypedActorContext; +import akka.dispatch.OnSuccess; import fucoin.actions.ClientAction; import fucoin.actions.persist.ActionSearchMyWallet; import fucoin.wallet.AbstractWallet; +import scala.Function1; +import scala.concurrent.Future; +import scala.runtime.BoxedUnit; import java.util.HashMap; import java.util.Map.Entry; diff --git a/src/main/java/fucoin/supervisor/SuperVisorImpl.java b/src/main/java/fucoin/supervisor/SuperVisorImpl.java index 2333a97f635ba869eae7263d7e89fb018f3c1620..dfff7f1f906f8c196128e3f53a231f224326eae3 100644 --- a/src/main/java/fucoin/supervisor/SuperVisorImpl.java +++ b/src/main/java/fucoin/supervisor/SuperVisorImpl.java @@ -15,6 +15,8 @@ import java.util.List; import java.util.Map; import java.util.Map.Entry; +import static akka.dispatch.Futures.future; + public class SuperVisorImpl extends AbstractNode implements TransactionLogger{ private AmountTableModel amountTableModel; diff --git a/src/main/java/fucoin/wallet/AbstractWallet.java b/src/main/java/fucoin/wallet/AbstractWallet.java index 1069cf8a8f5c0786ecd943a5ccb30591429b7734..d9f99f719ad6bf7799d802143a670b7a80cf26e5 100644 --- a/src/main/java/fucoin/wallet/AbstractWallet.java +++ b/src/main/java/fucoin/wallet/AbstractWallet.java @@ -3,6 +3,7 @@ package fucoin.wallet; import akka.actor.ActorRef; import fucoin.AbstractNode; import fucoin.gui.TransactionLogger; +import scala.concurrent.Future; import java.io.Serializable; diff --git a/src/main/java/fucoin/wallet/WalletImpl.java b/src/main/java/fucoin/wallet/WalletImpl.java index dd52e86c3db51b2f12693453102eca1b5d6b36b1..ef38e97f476e337e25c86b3e5b80548f54b5979d 100644 --- a/src/main/java/fucoin/wallet/WalletImpl.java +++ b/src/main/java/fucoin/wallet/WalletImpl.java @@ -12,6 +12,9 @@ import fucoin.actions.persist.ActionInvokeRevive; import fucoin.actions.transaction.ActionGetAmountAnswer; import fucoin.actions.transaction.ActionInvokeSentMoney; import fucoin.gui.WalletGuiControl; +import scala.concurrent.Future; + +import static akka.dispatch.Futures.future; import java.util.concurrent.ConcurrentLinkedQueue; @@ -153,6 +156,11 @@ public class WalletImpl extends AbstractWallet { return remoteSuperVisorActor; } + public Future<ActorRef> resolveSuperVisorActor() { + // TODO: this should return only, if getRemoteSuperVisorActor() != null + return future(() -> getRemoteSuperVisorActor(), context().system().dispatcher()); + } + @Override public void setRemoteSuperVisorActor(ActorRef remoteSuperVisorActor) { if (this.remoteSuperVisorActor == null) {