diff options
Diffstat (limited to 'cpp/src/qpid/messaging/ConnectionOptions.cpp')
| -rw-r--r-- | cpp/src/qpid/messaging/ConnectionOptions.cpp | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/cpp/src/qpid/messaging/ConnectionOptions.cpp b/cpp/src/qpid/messaging/ConnectionOptions.cpp index e534920876..26bb699565 100644 --- a/cpp/src/qpid/messaging/ConnectionOptions.cpp +++ b/cpp/src/qpid/messaging/ConnectionOptions.cpp @@ -52,7 +52,7 @@ void merge(const qpid::types::Variant::List& from, std::vector<std::string>& to) ConnectionOptions::ConnectionOptions(const std::map<std::string, qpid::types::Variant>& options) : replaceUrls(false), reconnect(false), timeout(FOREVER), limit(-1), minReconnectInterval(0.001), maxReconnectInterval(2), - retries(0), reconnectOnLimitExceeded(true), nestAnnotations(false) + retries(0), reconnectOnLimitExceeded(true), nestAnnotations(false), setToOnSend(false) { for (qpid::types::Variant::Map::const_iterator i = options.begin(); i != options.end(); ++i) { set(i->first, i->second); @@ -117,6 +117,8 @@ void ConnectionOptions::set(const std::string& name, const qpid::types::Variant& identifier = value.asString(); } else if (name == "nest-annotations" || name == "nest_annotations") { nestAnnotations = value; + } else if (name == "set-to-on-send" || name == "set_to_on_send") { + setToOnSend = value; } else { throw qpid::messaging::MessagingException(QPID_MSG("Invalid option: " << name << " not recognised")); } |