agorise/graphenej
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Adding a WitnessResponseListener as a parameter for the SubscriptionMessagesHub class

Browse source
This commit is contained in:
Nelson R. Perez 2017-04-24 16:30:08 -05:00
parent 88ca47c378
commit 1c5d382891
1 changed files with 14 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

26
graphenej/src/main/java/de/bitsharesmunich/graphenej/api/SubscriptionMessagesHub.java
View file

@ -4,18 +4,8 @@ import com.google.gson.Gson;
import com.google.gson.GsonBuilder; import com.google.gson.GsonBuilder;
import com.google.gson.reflect.TypeToken; import com.google.gson.reflect.TypeToken;
import com.neovisionaries.ws.client.WebSocket; import com.neovisionaries.ws.client.WebSocket;
import com.neovisionaries.ws.client.WebSocketAdapter;
import com.neovisionaries.ws.client.WebSocketException; import com.neovisionaries.ws.client.WebSocketException;
import com.neovisionaries.ws.client.WebSocketFrame; import com.neovisionaries.ws.client.WebSocketFrame;
import de.bitsharesmunich.graphenej.AssetAmount;
import de.bitsharesmunich.graphenej.RPC;
import de.bitsharesmunich.graphenej.Transaction;
import de.bitsharesmunich.graphenej.operations.TransferOperation;
import de.bitsharesmunich.graphenej.interfaces.SubscriptionHub;
import de.bitsharesmunich.graphenej.interfaces.SubscriptionListener;
import de.bitsharesmunich.graphenej.models.ApiCall;
import de.bitsharesmunich.graphenej.models.SubscriptionResponse;
import de.bitsharesmunich.graphenej.models.WitnessResponse;
import java.io.Serializable; import java.io.Serializable;
import java.lang.reflect.Type; import java.lang.reflect.Type;
@ -23,12 +13,23 @@ import java.util.ArrayList;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import de.bitsharesmunich.graphenej.AssetAmount;
import de.bitsharesmunich.graphenej.RPC;
import de.bitsharesmunich.graphenej.Transaction;
import de.bitsharesmunich.graphenej.interfaces.SubscriptionHub;
import de.bitsharesmunich.graphenej.interfaces.SubscriptionListener;
import de.bitsharesmunich.graphenej.interfaces.WitnessResponseListener;
import de.bitsharesmunich.graphenej.models.ApiCall;
import de.bitsharesmunich.graphenej.models.SubscriptionResponse;
import de.bitsharesmunich.graphenej.models.WitnessResponse;
import de.bitsharesmunich.graphenej.operations.TransferOperation;
/** /**
* A websocket adapter prepared to be used as a basic dispatch hub for subscription messages. * A websocket adapter prepared to be used as a basic dispatch hub for subscription messages.
* *
* Created by nelson on 1/26/17. * Created by nelson on 1/26/17.
*/ */
public class SubscriptionMessagesHub extends WebSocketAdapter implements SubscriptionHub { public class SubscriptionMessagesHub extends BaseGrapheneHandler implements SubscriptionHub {
// Sequence of message ids // Sequence of message ids
private final static int LOGIN_ID = 1; private final static int LOGIN_ID = 1;
private final static int GET_DATABASE_ID = 2; private final static int GET_DATABASE_ID = 2;
@ -44,7 +45,8 @@ public class SubscriptionMessagesHub extends WebSocketAdapter implements Subscri
private int currentId = LOGIN_ID; private int currentId = LOGIN_ID;
private int databaseApiId = -1; private int databaseApiId = -1;
public SubscriptionMessagesHub(String user, String password){ public SubscriptionMessagesHub(String user, String password, WitnessResponseListener errorListener){
super(errorListener);
this.user = user; this.user = user;
this.password = password; this.password = password;
this.mSubscriptionDeserializer = new SubscriptionResponse.SubscriptionResponseDeserializer(); this.mSubscriptionDeserializer = new SubscriptionResponse.SubscriptionResponseDeserializer();