импорт io.socket *.
импорт org.json *.
импорт net.tootallnate.websocket *.

общественный класс MtGoxStreaming {
    
    частная статическая конечная строка tickerChannel = "d5f06780-30a8-4a48-a2f8-7ed181b4a13f";
    частная статическая конечная строка tradesChannel = "dbf1dee9-4f2e-4a08-8cb7-748919a71b21";
    частная статическая конечная строка depthChannel = "24e67e0d-1cad-4cc0-9e7a-f8523ef460fe";

    государственной статической силы основных (String [] арг) бросает исключение {
        SocketIO сокет = новый SocketIO ("https://socketio.mtgox.com/mtgox");
        Socket.connect (новый IOCallback () {
                @Override
                    общественного недействительными OnMessage (JSONObject JSON, IOAcknowledge извед) {
                    пытаться {
                        System.out.println ("Мы получили сообщение: " + Json.toString (2));
                    } Задвижка (JSONException е) {
                        e.printStackTrace ();
                    }
                }

                @Override
                    общественного недействительный OnMessage (строковые данные, IOAcknowledge извед) {
                    System.out.println ("Мы получили сообщение:" + данные);
                }
                
                @Override
                    общественного недействительными OnError (SocketIOException socketIOException) {
                    System.out.println ("Что-то пошло не так: " + SocketIOException);
                    socketIOException.printStackTrace ();
                    //System.exit(0);
                }

                @Override
                    общественного недействительный OnDisconnect () {
                    System.out.println ("Отключенные");
                    System.exit (0);
                }

                @Override
                    общественного недействительный OnConnect () {
                    System.out.println ("Связанный");
                }

                @Override
                    общественного недействительными на (событие Строка, IOAcknowledge ACK, объект ... арг) {
                    System.out.println ("получил: " + Событие);
                    ack.ack ("Заметано!");
                    //socket.emit ("ответ", Новый JSONObject (). Положим ("тзд", "Привет снова Socket.io!"));
                }
            });

        // Это будет храниться в кэше, пока сервер не подключен.
        //socket.emit ("Здравствуйте", Новый JSONObject (). Положим ("тзд", "Привет Socket.io! : D"));
 
        JSONObject OBJ = новый JSONObject ();
        obj.put ("оп",      "подписываться");
        //obj.put ("канал", DepthChannel);
        obj.put ("канал", "d5f06780-30a8-4a48-a2f8-7ed181b4a13f");
        socket.send (OBJ);
 
    }
}

Связанный
> 1 :: / mtgox
> 4 :: / mtgox: {"оп":"подписываться","канал":"d5f06780-30a8-4a48-a2f8-7ed181b4a13f"}
> 2 ::
> 2 ::
> 2 ::
> 2 ::
> 2 ::
> 2 ::
> 2 ::
< 7 ::: 1 + 0
Что-то пошло не так: io.socket.SocketIOException: 1 + 0
io.socket.SocketIOException: 1 + 0