Session session = new Session();
// Add all onJoin listenerssession.addOnJoinListener(this::demonstrateSubscribe);
session.addOnJoinListener(this::demonstratePublish);
// Now create a transport list to try and add transports to it.
// In our case, we currnetly only have Netty based WAMP-over-WebSocket.
List<ITransport> transports = new ArrayList<>();
transports.add(new NettyTransport("wss://xxxxxx/wss2/"));
// Now provide a list of authentication methods.
// We only support anonymous auth currently.
List<IAuthenticator> authenticators = new ArrayList<>();
authenticators.add(new AnonymousAuth());
// finally, provide everything to a Client instance and connect
Client client = new Client(transports);
client.add(session, "streamName", authenticators);
client.connect();
Please let me know if I am missing something.