Page MenuHomePhabricator
Files F3247714

D6624.id22121.diff
No OneTemporary
Actions

D6624.id22121.diff
View Options

diff --git a/services/tunnelbroker/src/libcpp/Tunnelbroker.cpp b/services/tunnelbroker/src/libcpp/Tunnelbroker.cpp
--- a/services/tunnelbroker/src/libcpp/Tunnelbroker.cpp
+++ b/services/tunnelbroker/src/libcpp/Tunnelbroker.cpp
@@ -257,8 +257,12 @@
}});
messagesIDs.push_back(rust::String{messageID});
};
- comm::network::database::DatabaseManager::getInstance()
- .putMessageItemsByBatch(vectorOfMessages);
+ if (!comm ::network::config::ConfigManager::getInstance().isParameterSet(
+ comm::network::config::ConfigManager::
+ OPTION_MESSAGES_SKIP_PERSISTENCE)) {
+ comm::network::database::DatabaseManager::getInstance()
+ .putMessageItemsByBatch(vectorOfMessages);
+ };
for (auto message : vectorOfMessages) {
comm::network::AmqpManager::getInstance().send(&message);
}

File Metadata

Mime Type
text/plain
Expires
Sat, Nov 16, 6:27 AM (21 h, 33 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
2496679
Default Alt Text
D6624.id22121.diff (840 B)

Event Timeline