Chat Docs Introduction

String apiKey = "{{ api_key }}";
String token = "{{ chat_user_token }}";
Context context = getApplicationContext();
ChatClient client = new ChatClient.Builder(apiKey, context).build();

// Set the user to establish the websocket connection
// Usually done when you open the chat interface
// extraData allows you to add any custom fields you want to store about your user
// the UI components will pick up name and image by default

User user = new User("user-id");

user.getExtraData().put("name", "Bender");
user.getExtraData().put("image", "https://bit.ly/321RmWb");

client.setUser(user, token, new InitConnectionListener() {
    @Override
    public void onSuccess(@NotNull ConnectionData data) {
        User user = data.getUser();
        String connectionId = data.getConnectionId();
    }

    @Override
    public void onError(@NotNull ChatError error) {
        error.printStackTrace();
    }
});
                    

// initialize a channel object with an extra data hashmap
HashMap<string, object=""> extraData = new HashMap&lt;&gt;();
extraData.put("name", "Talking about life");

Channel channel = client.channel(channelType, channelID, extraData);

// watching a channel's state
ChannelQueryRequest request = new ChannelQueryRequest().
          withMessages(Constant.DEFAULT_LIMIT).withWatch();

// note how the withWatch() argument ensures that we are watching the channel for any changes/new messages
channel.query(
  request,
  new QueryChannelCallback() {
      @Override
      public void onSuccess(ChannelState response) {          
      }

      @Override
      public void onError(String errMsg, int errCode) {          
      }
  }
);</string,>
                    

// prepare the message
Message message = new Message();
message.setText("hello world");

// send the message to the channel
channelController.sendMessage(message).enqueue(result -> {

    if (result.isSuccess()) {
        Message msg = result.data();
    } else {
        result.error().printStackTrace();
    }

    return Unit.INSTANCE;
});
                    

// Subscribe
Subscription subscription = client.events().subscribe(event -> {

    if (event instanceof NewMessageEvent) {
        Message message = event.message;
    }

    return Unit.INSTANCE;
});
// Unsubscribe
subscription.unsubscribe();