forked from ringcentral/pubnub-jtools
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathMtGox.java
More file actions
49 lines (39 loc) · 1.06 KB
/
Copy pathMtGox.java
File metadata and controls
49 lines (39 loc) · 1.06 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
package com.pubnub.api;
import java.util.HashMap;
import org.json.*;
public class MtGox {
Pubnub pubnub;
HashMap<String,MtGoxCallback> map = new HashMap<String,MtGoxCallback>();
public MtGox() {
}
public void subscribe(String tag, MtGoxCallback callback) {
map.put(tag, callback);
if (pubnub == null) {
pubnub = new Pubnub("","sub-c-50d56e1e-2fd9-11e3-a041-02ee2ddab7fe");
String[] channels = new String[] {
"d5f06780-30a8-4a48-a2f8-7ed181b4a13f",
"dbf1dee9-4f2e-4a08-8cb7-748919a71b21"
};
try {
pubnub.subscribe(channels, new Callback(){
@Override
public void successCallback(String channel,
Object message) {
String channel_name = null;
try {
channel_name = (String)((JSONObject)message).get("channel_name");
} catch (JSONException e) {
return;
}
MtGoxCallback cb = map.get(channel_name);
if (cb != null) cb.callback((JSONObject)message);
}
});
} catch (PubnubException e) {
}
}
}
public void unsubscribe(String tag) {
map.remove(tag);
}
}