Sets statuses for sets of messages.

@param conversationId ID of a conversation to modify.
@param msgStatusList  List of status modifications.
@param callback       Callback to deliver new session instance.
353421
public void updateMessageStatus(@NonNull final String conversationId, @NonNull final List<MessageStatusUpdate> msgStatusList, @Nullable Callback<ComapiResult<Void>> callback) {
        adapter.adapt(updateMessageStatus(conversationId, msgStatusList), callback);
    }
1074876
Observable<ComapiResult<Void>> markDelivered(String conversationId, Set<String> ids) {

        final List<MessageStatusUpdate> updates = new ArrayList<>();
        updates.add(MessageStatusUpdate.builder().setMessagesIds(ids).setStatus(MessageStatus.delivered).setTimestamp(DateHelper.getCurrentUTC()).build());

        return checkState().flatMap(client -> client.service().messaging().updateMessageStatus(conversationId, updates)
                .retryWhen(observable -> {
                    return observable.zipWith(Observable.range(1, 3), (Func2<Throwable, Integer, Integer>) (throwable, integer) -> integer).flatMap(new Func1<Integer, Observable<Long>>() {
                        @Override
                        public Observable<Long> call(Integer retryCount) {
                            return Observable.timer((long) Math.pow(1, retryCount), TimeUnit.SECONDS);
                        }
                    });
                }
                ));
    }
916328
function(item, callback) {
                for (var i = 0; i < chatSendQueue.length; i++) {
                    if (chatSendQueue[i].message.uniqueId == item.message.uniqueId) {
                        chatSendQueue.splice(i, 1);
                    }
                }
                callback && callback();
            }
60937
public Observable<ComapiResult<Void>> isTyping(@NonNull final String conversationId) {

        final String token = getToken();

        if (sessionController.isCreatingSession() || TextUtils.isEmpty(token)) {
            return Observable.error(getSessionStateErrorDescription());
        } else {
            return doIsTyping(token, conversationId, true);
        }
    }
1167809
protected void updateConferenceStatus(String status){
        if(cdr != null){
            final ConferenceDetailRecordsDao dao = storage.getConferenceDetailRecordsDao();
            cdr = dao.getConferenceDetailRecord(conferenceSid);
            cdr = cdr.setStatus(status);
            dao.updateConferenceDetailRecordStatus(cdr);
        }
    }
1012778
public int addReply(int conversationId, String text) {
		return getResourceFactory()
				.getApiResource("/conversation/" + conversationId + "/reply")
				.entity(new MessageCreate(text),
						MediaType.APPLICATION_JSON_TYPE)
				.get(MessageCreateResponse.class).getMessageId();
	}
500125
@Override
    protected void setConnectionObjectID(int i) {
        if (tc.isEntryEnabled())
            SibTr.entry(this, tc, "setConnectionObjectID", "" + i);

        // Retrieve Client Conversation State if necessary
        validateConversationState();

        sConState.setConnectionObjectId((short) i);

        if (tc.isEntryEnabled())
            SibTr.exit(this, tc, "setConnectionObjectID");
    }
301153
public void setStatus(java.util.Collection<BulkEmailDestinationStatus> status) {
        if (status == null) {
            this.status = null;
            return;
        }

        this.status = new com.amazonaws.internal.SdkInternalList<BulkEmailDestinationStatus>(status);
    }
469495
public synchronized void onContextStatusMessages(final Iterable<ContextStatusPOJO>
                                                       contextStatusPOJOs,
                                                   final boolean notifyClientOnNewActiveContext) {
    for (final ContextStatusPOJO contextStatus : contextStatusPOJOs) {
      this.onContextStatusMessage(contextStatus, notifyClientOnNewActiveContext);
    }
  }
638609
function sendTypingStatus() {
    if (currentDialog.type == 3) {
        QB.chat.sendIsTypingStatus(opponentId);
    } else if (currentDialog && currentDialog.xmpp_room_jid) {
        QB.chat.sendIsTypingStatus(currentDialog.xmpp_room_jid);
    }
}
465399
public void setStatus(int code,String message)
    {
        setStatus(code);
        Integer code_integer=TypeUtil.newInteger(code);
        if (message == null)
        {
            message = (String)__statusMsg.get(code_integer);
            if (message==null)
                message=""+code;
            setReason(message);
        }
        else
            setReason(UrlEncoded.encodeString(message));
    }
102753
protected void setConversation(Conversation conversation)
   {
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.entry(this, tc, "setConversation", conversation);
      con = conversation;
      if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled()) SibTr.exit(this, tc, "setConversation");
   }
808205
public static function disable_conversation(int $conversationid) {
        global $DB;

        $conversation = new \stdClass();
        $conversation->id = $conversationid;
        $conversation->enabled = self::MESSAGE_CONVERSATION_DISABLED;
        $conversation->timemodified = time();
        $DB->update_record('message_conversations', $conversation);
    }
813927
@SuppressWarnings("unchecked")
	protected void addStatusMessage(final String statusMessage,
			final String solution) {
		this.json.put(ProtocolConstants.SOLUTION, solution);
		this.json.put(ProtocolConstants.STATUS_MESSAGE, statusMessage);
	}
1214818
public Conversation updateConversation(final String id, final ConversationStatus status)
            throws UnauthorizedException, GeneralException {
        if (id == null) {
            throw new IllegalArgumentException("Id must be specified.");
        }
        String url = String.format("%s%s/%s", CONVERSATIONS_BASE_URL, CONVERSATION_PATH, id);
        return messageBirdService.sendPayLoad("PATCH", url, status, Conversation.class);
    }
283168
public void getParticipants(@NonNull final String conversationId, @Nullable Callback<ComapiResult<List<Participant>>> callback) {
        adapter.adapt(getParticipants(conversationId), callback);
    }
1014405
public void getConversations(final boolean isPublic, @Nullable Callback<ComapiResult<List<Conversation>>> callback) {
        adapter.adapt(getConversations(isPublic), callback);
    }