Git-Mirrors/haveno
1
0
Fork 0
mirror of https://github.com/haveno-dex/haveno.git synced 2025-04-11 18:59:03 -04:00
Code Issues Packages Projects Releases Wiki Activity

Refactor check if offer is available process

Browse Source
This commit is contained in:
Manfred Karrer 2015-03-09 12:46:59 +01:00
parent 090f2e7428
commit 74fced2f4b
3 changed files with 35 additions and 10 deletions

6
gui/src/main/java/io/bitsquare/trade/TradeMessageService.java

@ -21,7 +21,7 @@ import io.bitsquare.network.Message;
import io.bitsquare.network.MessageBroker;
import io.bitsquare.network.Peer;
import io.bitsquare.trade.listeners.GetPeerAddressListener;
import io.bitsquare.trade.listeners.HandleNewMessageListener;
import io.bitsquare.trade.listeners.NewMessageListener;
import io.bitsquare.trade.listeners.SendMessageListener;
import java.security.PublicKey;
@ -34,9 +34,9 @@ public interface TradeMessageService extends MessageBroker {
void sendMessage(Peer peer, Message message, SendMessageListener listener);
void addHandleNewMessageListener(HandleNewMessageListener listener);
void addHandleNewMessageListener(NewMessageListener listener);
void removeHandleNewMessageListener(HandleNewMessageListener listener);
void removeHandleNewMessageListener(NewMessageListener listener);
void getPeerAddress(PublicKey messagePublicKey, GetPeerAddressListener getPeerAddressListener);
}

25
gui/src/main/java/io/bitsquare/trade/listeners/NewMessageListener.java Normal file

@ -0,0 +1,25 @@
/*
* This file is part of Bitsquare.
*
* Bitsquare is free software: you can redistribute it and/or modify it
* under the terms of the GNU Affero General Public License as published by
* the Free Software Foundation, either version 3 of the License, or (at
* your option) any later version.
*
* Bitsquare is distributed in the hope that it will be useful, but WITHOUT
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
* FITNESS FOR A PARTICULAR PURPOSE. See the GNU Affero General Public
* License for more details.
*
* You should have received a copy of the GNU Affero General Public License
* along with Bitsquare. If not, see <http://www.gnu.org/licenses/>.
*/
package io.bitsquare.trade.listeners;
import io.bitsquare.network.Message;
import io.bitsquare.network.Peer;
public interface NewMessageListener {
void handleMessage(Message message, Peer sender);
}

14
gui/src/main/java/io/bitsquare/trade/tomp2p/TomP2PTradeMessageService.java

@ -23,7 +23,7 @@ import io.bitsquare.network.tomp2p.TomP2PNode;
import io.bitsquare.network.tomp2p.TomP2PPeer;
import io.bitsquare.trade.TradeMessageService;
import io.bitsquare.trade.listeners.GetPeerAddressListener;
import io.bitsquare.trade.listeners.HandleNewMessageListener;
import io.bitsquare.trade.listeners.NewMessageListener;
import io.bitsquare.trade.listeners.SendMessageListener;
import io.bitsquare.user.User;
@ -58,7 +58,7 @@ public class TomP2PTradeMessageService implements TradeMessageService {
private final TomP2PNode tomP2PNode;
private final User user;
private final List<HandleNewMessageListener> handleNewMessageListeners = new ArrayList<>();
private final List<NewMessageListener> newMessageListeners = new ArrayList<>();
private Executor executor;
@ -133,12 +133,12 @@ public class TomP2PTradeMessageService implements TradeMessageService {
// Event Listeners
///////////////////////////////////////////////////////////////////////////////////////////
public void addHandleNewMessageListener(HandleNewMessageListener listener) {
handleNewMessageListeners.add(listener);
public void addHandleNewMessageListener(NewMessageListener listener) {
newMessageListeners.add(listener);
}
public void removeHandleNewMessageListener(HandleNewMessageListener listener) {
handleNewMessageListeners.remove(listener);
public void removeHandleNewMessageListener(NewMessageListener listener) {
newMessageListeners.remove(listener);
}
@ -149,7 +149,7 @@ public class TomP2PTradeMessageService implements TradeMessageService {
@Override
public void handleMessage(Object message, Peer sender) {
if (message instanceof Message && sender instanceof TomP2PPeer) {
executor.execute(() -> handleNewMessageListeners.stream().forEach(e ->
executor.execute(() -> newMessageListeners.stream().forEach(e ->
e.handleMessage((Message) message, sender)));
}
}