Skip to content
Snippets Groups Projects
Unverified Commit 2b7d5802 authored by David Bohn's avatar David Bohn
Browse files

Fixed merge conflicts

parents 8a4b6fd0 52740f26
No related branches found
No related tags found
2 merge requests!5Configuration system,!4Added tell supervisor action to make system init work
...@@ -2,9 +2,13 @@ package fucoin.actions.join; ...@@ -2,9 +2,13 @@ package fucoin.actions.join;
import akka.actor.ActorRef; import akka.actor.ActorRef;
import akka.actor.UntypedActorContext; import akka.actor.UntypedActorContext;
import akka.dispatch.OnSuccess;
import fucoin.actions.ClientAction; import fucoin.actions.ClientAction;
import fucoin.actions.persist.ActionSearchMyWallet; import fucoin.actions.persist.ActionSearchMyWallet;
import fucoin.wallet.AbstractWallet; import fucoin.wallet.AbstractWallet;
import scala.Function1;
import scala.concurrent.Future;
import scala.runtime.BoxedUnit;
import java.util.HashMap; import java.util.HashMap;
import java.util.Map.Entry; import java.util.Map.Entry;
......
...@@ -15,6 +15,8 @@ import java.util.List; ...@@ -15,6 +15,8 @@ import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.Map.Entry; import java.util.Map.Entry;
import static akka.dispatch.Futures.future;
public class SuperVisorImpl extends AbstractNode implements TransactionLogger{ public class SuperVisorImpl extends AbstractNode implements TransactionLogger{
private AmountTableModel amountTableModel; private AmountTableModel amountTableModel;
......
...@@ -3,6 +3,7 @@ package fucoin.wallet; ...@@ -3,6 +3,7 @@ package fucoin.wallet;
import akka.actor.ActorRef; import akka.actor.ActorRef;
import fucoin.AbstractNode; import fucoin.AbstractNode;
import fucoin.gui.TransactionLogger; import fucoin.gui.TransactionLogger;
import scala.concurrent.Future;
import java.io.Serializable; import java.io.Serializable;
......
...@@ -12,6 +12,9 @@ import fucoin.actions.persist.ActionInvokeRevive; ...@@ -12,6 +12,9 @@ import fucoin.actions.persist.ActionInvokeRevive;
import fucoin.actions.transaction.ActionGetAmountAnswer; import fucoin.actions.transaction.ActionGetAmountAnswer;
import fucoin.actions.transaction.ActionInvokeSentMoney; import fucoin.actions.transaction.ActionInvokeSentMoney;
import fucoin.gui.WalletGuiControl; import fucoin.gui.WalletGuiControl;
import scala.concurrent.Future;
import static akka.dispatch.Futures.future;
import java.util.concurrent.ConcurrentLinkedQueue; import java.util.concurrent.ConcurrentLinkedQueue;
...@@ -153,6 +156,11 @@ public class WalletImpl extends AbstractWallet { ...@@ -153,6 +156,11 @@ public class WalletImpl extends AbstractWallet {
return remoteSuperVisorActor; return remoteSuperVisorActor;
} }
public Future<ActorRef> resolveSuperVisorActor() {
// TODO: this should return only, if getRemoteSuperVisorActor() != null
return future(() -> getRemoteSuperVisorActor(), context().system().dispatcher());
}
@Override @Override
public void setRemoteSuperVisorActor(ActorRef remoteSuperVisorActor) { public void setRemoteSuperVisorActor(ActorRef remoteSuperVisorActor) {
if (this.remoteSuperVisorActor == null) { if (this.remoteSuperVisorActor == null) {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment