Class MultiMsgCollectorImpl<T extends OfHeader>

    • Method Detail

      • addMultipartMsg

        public void addMultipartMsg​(@NonNull T reply,
                                    boolean reqMore,
                                    @Nullable EventIdentifier eventIdentifier)
        Description copied from interface: MultiMsgCollector
        Method adds a reply multipart message to the collection and if the message has marker "I'M A LAST" method set whole Collection to Future object and remove from cache.
        Specified by:
        addMultipartMsg in interface MultiMsgCollector<T extends OfHeader>
        Parameters:
        reply - reply
        reqMore - request more replies
        eventIdentifier - event identifier
      • endCollecting

        public void endCollecting​(@Nullable EventIdentifier eventIdentifier)
        Description copied from interface: MultiMsgCollector
        Null response could be a valid end multipart collecting event for barrier response scenario. We are not able to resolve an issue (it is or it isn't barrier scenario) so we have to finish collecting multipart messages successfully.
        Specified by:
        endCollecting in interface MultiMsgCollector<T extends OfHeader>
        Parameters:
        eventIdentifier - event identifier