This commit is contained in:
Manfred Karrer 2014-06-10 23:14:46 +02:00
parent 08d5639a95
commit ee9205fec9
9 changed files with 23 additions and 31 deletions

View file

@ -98,7 +98,7 @@ public class MessageFacade
try
{
createMyPeerInstance(keyName, port);
//setupStorage();
setupStorage();
//TODO save periodically or get informed if network address changes
saveMyAddressToDHT();
setupReplyHandler();
@ -160,10 +160,11 @@ public class MessageFacade
public void addOffer(Offer offer) throws IOException
{
Number160 locationKey = Number160.createHash(offer.getCurrency().getCurrencyCode());
Number160 contentKey = Number160.createHash(offer.getUid());
final Number160 contentKey = Number160.createHash(offer.getUid());
final Data offerData = new Data(offer);
//offerData.setTTLSeconds(5);
final FutureDHT addFuture = myPeer.put(locationKey).setData(contentKey, offerData).start();
//final FutureDHT addFuture = myPeer.add(locationKey).setData(offerData).start();
addFuture.addListener(new BaseFutureAdapter<BaseFuture>()
{
@Override