Event Handler
Qiscus Chat SDK provides a simple way to let applications publish and listen to some real-time events. You can publish typing, read, user status, and custom event so that you can handle freely in the event handler. This lets you inform users that another participant is actively engaged in communicating with them.
Qiscus Chat SDK is using EventBus for broadcasting event to the entire applications. You can learn more about EventBus on this website. What you need to do is register the object which will receive event from EventBus. You can call it like this:
EventBus.getDefault().register(this);
Once you don't need to listen to the event anymore, you have to unregister the receiver by calling this method:
EventBus.getDefault().unregister(this);
This is an example on how to register an activity to receive event from EventBus:
public class MyActivity extends AppCompatActivity {
protected void onCreate( Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_my);
}
protected void onResume() {
super.onResume();
EventBus.getDefault().register(this); // register to EventBus
}
protected void onPause() {
super.onPause();
EventBus.getDefault().unregister(this); // unregister from EventBus
}
}
After you register the receiver, now you can subscribe to a specific event you need to know. What you need to do is you have to create a method with org.greenrobot.eventbus.Subscribe annotation. The method's name is up to you, but the parameter in your method must be equal with the event class which you want to listen to.
Receiving Message
You need to subscribe chat room listen chat room event in order to receive the message, this only for channel type. To subscribe the chat room you can follow this below code:
QiscusPusherApi.getInstance().subscribeChatRoom(chatRoom);
To get the chat room object you can refer to this docs chat room.
You need to subscribeChatRoom in order to receive message for a channel type, otherwise you don't receive message. Then messages can be received through onMessageReceived event
Messages can be received through a onMessageReceived
event. This event is triggered whenever users send a message. you can implement this event, for example:
public void onMessageReceived(QiscusCommentReceivedEvent event) {
event.getQiscusComment(); // to get the comment
}
The implementation of activity class will be like this:
public class MyActivity extends AppCompatActivity {
protected void onCreate( Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_my);
}
protected void onResume() {
super.onResume();
EventBus.getDefault().register(this); // register to EventBus
}
protected void onPause() {
super.onPause();
EventBus.getDefault().unregister(this); // unregister from EventBus
}
public void onMessageReceived(QiscusCommentReceivedEvent event) {
event.getQiscusComment(); // to get the message
}
}
QiscusCommentReceivedEvent does not guarantee the event only published once per unique comment. There will be the same QiscusCommentReceivedEvent published, so you need to handle it.
Listening Chat Room Event
Chat room event consist of 3 events that happen in a chat room, such as typing, delivered, and read. These events only work for 1-on-1 chat and group chat, for channel you need to subscribe in order to receive a message. To able receive these events you need to subscribe a chat room, for example:
QiscusPusherApi.getInstance().subscribeChatRoom(chatRoom);
Once you don't need to listen these events, you can simply unsubscribe related a chat room, for example:
QiscusPusherApi.getInstance().unsubscribeChatRoom(chatRoom);
Channel only get a message through messageReceived event after subscribe a chat room event
Sending Typing Status
You can have a typing status by publishing the typing event. You need to pass roomId
and typing
status. Set true to indicate the typing
event is active, set false to indicate the event is inactive, you can use the code below:
QiscusPusherApi.getInstance().publishTyping(roomId, typing);
Receiving Typing Status
You can receive typing status once you have subscribed the a chat room event, for example:
public void onUserTyping(QiscusChatRoomEvent roomEvent) {
switch (roomEvent.getEvent()) {
case TYPING:
roomEvent.getRoomId(); // this is the room id
roomEvent.getUser(); // this is the qiscus user id
roomEvent.isTyping(); // true if the user is typing
break;
}
}
You need to subscribe a chat room event first, otherwise you will not receive this event
Receiving Message Status
After you listen some of events in a chat room, You can receive the real time message status which defined by the event, such as delivered, and read, for example:
public void onReceiveChatRoomEvent(QiscusChatRoomEvent roomEvent) {
switch (roomEvent.getEvent()) {
case DELIVERED:
roomEvent.getRoomId(); // this is the room id
roomEvent.getUser(); // this is the qiscus user id
roomEvent.getCommentId(); // the comment id was delivered
break;
case READ:
roomEvent.getRoomId(); // this is the room id
roomEvent.getUser(); // this is the qiscus user id
roomEvent.getCommentId(); // the comment id was read
break;
}
}
Receiving Participant Online Status
This section suits when you want to know whether the participant is online or not (last active). This case is only for 1-on-1 chat room. You can get participant's online status by passing related userId
, for example:
QiscusPusherApi.getInstance().subscribeUserOnlinePresence(userId);
After that, you can create method that subscribes to event with com.qiscus.sdk.event.QiscusUserStatusEvent class, for example:
public void onUserOnlinePresence(QiscusUserStatusEvent event) {
event.getUser(); // this is the qiscus user id
event.isOnline(); // true if user is online
event.getLastActive(); // Date of last active user
}
Once you don't need this event anymore, you need to unsubscribe the related userId
, for example:
QiscusPusherApi.getInstance().unsubscribeUserOnlinePresence(userId);
Receiving Deleted Message
You can receive deleted message through onMessageDeleted
. This event is triggered whenever users delete a message, you can implement this event, for example:
public void onMessageDeleted(QiscusCommentDeletedEvent event) {
event.getQiscusComment() // get new message
}
}
Customizing Real-Time Event
You can publish and listen to any events such as when participant is listening to music, writing document, and many other cases that you need to tell to other participants in a Chat Room.
First, you need to pass roomId with related ChatRoom you want to set, and the structured data to define what event that you want to send. Below is the example of structured data of writing document event:
{
"sender": "John Doe",
"event": "writing document...",
"active": "true"
}
After that, you can send event using this following method publishEvent():
QiscusPusherApi.getInstance().publishCustomEvent(long roomId, JSONObject data)
If you need to stop telling other participants that event is ended, you can send a flag to be false within your structured data, for example:
{
"sender": "John Doe",
"event": "writing document...",
"active": "false"
}
After sending an event, then you need to listen to the event with related roomId
, for example:
QiscusPusherApi.getInstance().subsribeCustomEvent(roomId);
To retrieve event data, you can use EventBus by implementing @Subscribe annotation, for example:
public void onReceiveRoomEvent(QiscusChatRoomEvent roomEvent) {
switch (roomEvent.getEvent()) {
case CUSTOM:
//here, you can listen custom event
roomEvent.getRoomId(); // this is the room id
roomEvent.getUser(); // this is the sender's qiscus user id
roomEvent.getEventData(); //event data (JSON)
break;
}
}
Connection to Qiscus Server
You can have a control in your App when you are connected or disconnected from Qiscus Server. You need to subscribe using EventBus, for example:
public void onConnection(QiscusMqttStatusEvent mqttStatusEvent){
switch (mqttStatusEvent) {
case CONNECTED:
// you can do anyting
break;
case DISCONNECTED:
// you can do anyting
break;
..
}
}
This is the complete version of using Qiscus Event Handler:
public class MyActivity extends AppCompatActivity {
protected void onCreate( Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_my);
// listen room event
QiscusPusherApi.getInstance().subscribeChatRoom(qiscusChatRoom);
// listen user status
QiscusPusherApi.getInstance().subscribeUserOnlinePresence(userId);
}
protected void onResume() {
super.onResume();
EventBus.getDefault().register(this); // register to EventBus
}
protected void onPause() {
super.onPause();
EventBus.getDefault().unregister(this); // unregister from EventBus
}
public void onMessageReceived(QiscusCommentReceivedEvent event) {
event.getQiscusComment(); // to get the comment
}
public void onReceiveRoomEvent(QiscusChatRoomEvent roomEvent) {
switch (roomEvent.getEvent()) {
case TYPING:
roomEvent.getRoomId(); // this is the room id
roomEvent.getUser(); // this is the qiscus user id
roomEvent.isTyping(); // true if the user is typing
break;
case DELIVERED:
roomEvent.getRoomId(); // this is the room id
roomEvent.getUser(); // this is the qiscus user id
roomEvent.getCommentId(); // the comment id was delivered
break;
case READ:
roomEvent.getRoomId(); // this is the room id
roomEvent.getUser(); // this is the qiscus user id
roomEvent.getCommentId(); // the comment id was read
break;
case CUSTOM:
//here, you can listen custom event
roomEvent.getRoomId(); // this is the room id
roomEvent.getUser(); // this is the qiscus user id
roomEvent.getEventData(); //event data (JSON)
break;
}
}
public void onUserOnlinePresence(QiscusUserStatusEvent event) {
event.getUser(); // this is the qiscus user id
event.isOnline(); // true if user is online
event.getLastActive(); // Date of last active user
}
protected void onDestroy() {
super.onDestroy();
// stop listening room event
QiscusPusherApi.getInstance().unsubscribeChatRoom(qiscusChatRoom);
// stop listening user status
QiscusPusherApi.getInstance().unsubscribeUserOnlinePresence(userId);
}
}