Home
last modified time | relevance | path

Searched refs:messageProcessor (Results 1 – 18 of 18) sorted by relevance

/dports/net-im/qTox/qTox-1.17.4/test/model/
H A Dmessageprocessor_test.cpp63 auto messageProcessor = MessageProcessor(sharedParams); in testSelfMention() local
64 messageProcessor.enableMentions(); in testSelfMention()
73 processedMessage = messageProcessor.processIncomingMessage(true, str % " hi"); in testSelfMention()
77 processedMessage = messageProcessor.processIncomingMessage(false, str % "2"); in testSelfMention()
88 processedMessage = messageProcessor.processIncomingMessage(false, chopped); in testSelfMention()
113 processedMessage = messageProcessor.processIncomingMessage(false, ""); in testSelfMention()
117 processedMessage = messageProcessor.processIncomingMessage(false, "a"); in testSelfMention()
128 auto messageProcessor = MessageProcessor(sharedParams); in testOutgoingMessage() local
136 auto messages = messageProcessor.processOutgoingMessage(false, testStr); in testOutgoingMessage()
149 auto messageProcessor = MessageProcessor(sharedParams); in testIncomingMessage() local
[all …]
H A Dfriendmessagedispatcher_test.cpp97 std::unique_ptr<MessageProcessor> messageProcessor; member in TestFriendMessageDispatcher
115messageProcessor = std::unique_ptr<MessageProcessor>(new MessageProcessor(*sharedProcessorParams)); in init()
117 new FriendMessageDispatcher(*f, *messageProcessor, *messageSender)); in init()
H A Dgroupmessagedispatcher_test.cpp196 std::unique_ptr<MessageProcessor> messageProcessor; member in TestGroupMessageDispatcher
218messageProcessor = std::unique_ptr<MessageProcessor>(new MessageProcessor(*sharedProcessorParams)); in init()
220 new GroupMessageDispatcher(*g, *messageProcessor, *coreIdHandler, *messageSender, in init()
/dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/java-modules/elastic-v2/src/main/java/org/syslog_ng/elasticsearch_v2/client/esnative/
H A DESNativeClient.java46 protected ESNativeMessageProcessor messageProcessor; field in ESNativeClient
54 messageProcessor = ESMessageProcessorFactory.getMessageProcessor(options, this); in ESNativeClient()
96 messageProcessor.init(); in open()
106 messageProcessor.flush(); in close()
107 messageProcessor.deinit(); in close()
144 return messageProcessor.send(index); in send()
/dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/java-modules/elastic-v2/src/main/java/org/syslog_ng/elasticsearch_v2/client/http/
H A DESHttpClient.java63 private HttpMessageProcessor messageProcessor; field in ESHttpClient
90 messageProcessor = ESMessageProcessorFactory.getMessageProcessor(options, this); in ESHttpClient()
131 messageProcessor.init(); in open()
157 return messageProcessor.send(index); in send()
177 return messageProcessor.flush(); in flush()
/dports/textproc/uim-gtk/uim-d1ac9d9/qt5/applet/plasmoid/contents/ui/
H A Dmain.qml9 import "messageProcessor.js" as MessageProcessor
/dports/textproc/uim-m17nlib/uim-d1ac9d9/qt5/applet/plasmoid/contents/ui/
H A Dmain.qml9 import "messageProcessor.js" as MessageProcessor
/dports/textproc/uim-qt5/uim-d1ac9d9/qt5/applet/plasmoid/contents/ui/
H A Dmain.qml9 import "messageProcessor.js" as MessageProcessor
/dports/textproc/uim-el/uim-d1ac9d9/qt5/applet/plasmoid/contents/ui/
H A Dmain.qml9 import "messageProcessor.js" as MessageProcessor
/dports/textproc/uim-gtk3/uim-d1ac9d9/qt5/applet/plasmoid/contents/ui/
H A Dmain.qml9 import "messageProcessor.js" as MessageProcessor
/dports/japanese/uim-anthy/uim-d1ac9d9/qt5/applet/plasmoid/contents/ui/
H A Dmain.qml9 import "messageProcessor.js" as MessageProcessor
/dports/irc/quassel/quassel-0.14-rc2/src/client/
H A Dclientbacklogmanager.cpp174 Client::messageProcessor()->process(msgs); in dispatchMessages()
H A Dclient.cpp451 messageProcessor()->reset(); in setDisconnectedFromCore()
552 messageProcessor()->process(msg_); in recvMessage()
H A Dclient.h119 …static inline AbstractMessageProcessor* messageProcessor() { return instance()->_messageProcessor;… in messageProcessor() function
/dports/irc/quassel-core/quassel-0.14-rc2/src/client/
H A Dclientbacklogmanager.cpp174 Client::messageProcessor()->process(msgs); in dispatchMessages()
H A Dclient.cpp451 messageProcessor()->reset(); in setDisconnectedFromCore()
552 messageProcessor()->process(msg_); in recvMessage()
H A Dclient.h119 …static inline AbstractMessageProcessor* messageProcessor() { return instance()->_messageProcessor;… in messageProcessor() function
/dports/net-im/qTox/qTox-1.17.4/src/widget/
H A Dwidget.cpp1138 auto messageProcessor = MessageProcessor(sharedMessageProcessorParams); in addFriend() local
1140 std::make_shared<FriendMessageDispatcher>(*newfriend, std::move(messageProcessor), *core); in addFriend()
2092 auto messageProcessor = MessageProcessor(sharedMessageProcessorParams); in createGroup() local
2094 std::make_shared<GroupMessageDispatcher>(*newgroup, std::move(messageProcessor), *core, in createGroup()