nebulous/optimiser-solver
Code Issues Proposed changes

Correct applicaton ID message filtering

Browse Source 
Change-Id: I951b739e438bc346c4b910e4a41cfa01f1e12a88
This commit is contained in:
Geir Horn 2024-02-08 15:36:46 +01:00
parent 9fcd0a1aca
commit 52d2a5626a
1 changed files with 15 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
SolverComponent.cpp
View File

@ -223,20 +223,31 @@ int main( int NumberOfCLIOptions, char ** CLIOptionStrings )
};
// Setting the application filter is slightly more complicated as it
// involves setting the filter map for the sender.
// involves setting the filter map for the sender. However, this is not
// well documented and the current implmenentation is based on the
// example for an earlier Proton version (0.32.0) and the example at
// https://qpid.apache.org/releases/qpid-proton-0.32.0/proton/cpp/examples/selected_recv.cpp.html
virtual proton::receiver_options ReceiverOptions( void ) const override
{
proton::source::filter_map TheFilter;
proton::source_options TheSourceOptions;
proton::symbol FilterKey("selector");
proton::value FilterValue;
proton::codec::encoder EncodedFilter( FilterValue );
proton::receiver_options TheOptions(
Theron::AMQ::NetworkLayer::AMQProperties::ReceiverOptions() );
std::ostringstream FilterValue;
std::ostringstream SelectorString;
FilterValue << "application = '" << ApplicationID << "'";
SelectorString << "application = '" << ApplicationID << "'";
TheFilter.put("apache.org:selector-filter:string", FilterValue.str() );
EncodedFilter << proton::codec::start::described()
<< proton::symbol("apache.org:selector-filter:string")
<< SelectorString.str()
<< proton::codec::finish();
TheFilter.put( FilterKey, FilterValue );
TheSourceOptions.filters( TheFilter );
TheOptions.source( TheSourceOptions );