Wie man Jawampa (Java WAMP-Implementierung) verwendet, um bei einem Ereignis zu subskribieren

Question

Ich möchte die polonex api über das Wamp-Protokoll und die Jawampa-Bibliothek verwenden. Mein erster Versuch ist für Ticker Ereignisse zu abonnieren, hier ist die Dokumentation für diese Veranstaltung:

Um Ticker-Updates zu erhalten, abonnieren Sie den „Ticker“. Die Aktualisierungen haben folgendes Format: ['BTC_BBR', '0.00069501', '0.00074346', '0.00069501', '- 0.00742634', '8.63286802', '11983.47150109', 0, '0.00107920', '0.00045422'] entsprechende Etiketten für diese Daten sind in der Reihenfolge: currencyPair, last, lowestAsk, highestBid, percentChange, baseVolume, quoteVolume, IsFrozen, 24hrHigh, 24hrLow

ich dieses Stück Code für das Abonnement verwenden:

 clientp.statusChanged().subscribe(new Action1<WampClient.State>() { 
     @Override 
     public void call(WampClient.State t1) { 
      System.out.println("Sessione R ora è " + t1); 

      if (t1 instanceof WampClient.ConnectedState) { 
       System.out.println("Client P ricevuto " + t1); 
        eventSubscription = clientp.makeSubscription("ticker", String.class) 
        .subscribe(new Action1<String>() { 

     @Override 
     public void call(String t1) { 
     System.out.println("ES ricevuto " + eventSubscription); 
     System.out.println("Client P ricevuto " + t1); 

Ich erhalte nur das erste Feld des Updates (currencyPair) wie auch das vollständige Update gelesen?

Vielen Dank im Voraus für jede Hilfe. :)

Answer 1

Die Nachrichten, die Sie erhalten nicht vom Typ String sind, sondern sind vom Typ PubSubData. Versuchen Sie, diese (Java Pseudo-Code, ich bin mit Scala):

if (t1 instanceof WampClient.ConnectedState) { 
       System.out.println("Client P ricevuto " + t1); 
        eventSubscription = clientp.makeSubscription("ticker") 
        .subscribe(new Action1<PubSubData>() { 

     @Override 
     public void call(PubSubData message) { 
     System.out.println("Received " + message.arguments().toString());