Skip to content

Commit 49bc57c

Browse files
committed
adding RPC client demo
1 parent f3bb2a1 commit 49bc57c

File tree

1 file changed

+28
-0
lines changed

1 file changed

+28
-0
lines changed
Lines changed: 28 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,28 @@
1+
package samples.rpc;
2+
3+
import realtime.pubsub.*;
4+
5+
import java.util.logging.Logger;
6+
7+
public class Client {
8+
9+
public static void main(String[] args) throws Exception {
10+
var logger = Logger.getLogger(samples.ClientDemoMinimal.class.getName());
11+
12+
var accessToken = System.getenv("ACCESS_TOKEN");
13+
var appId = System.getenv("APP_ID");
14+
15+
var config = new RealtimeClientConfig(()
16+
-> String.format("wss://genesis.r7.21no.de/apps/%s?access_token=%s", appId, accessToken));
17+
var client = new RealtimeClient(config);
18+
client.connect();
19+
20+
client.waitFor("session.started").get();
21+
22+
var publishWaitFor = client.send("", "gettime");
23+
var response = publishWaitFor.waitForReply().get()[0];
24+
logger.info("Server Time: " + response);
25+
26+
client.disconnect();
27+
}
28+
}

0 commit comments

Comments
 (0)