nebulous/optimiser-solver
Code Issues Proposed changes

Final first release now with application ID filtering effective

Browse Source 
Change-Id: Ief16b069c20394f3f48dcd038b57766b6c3771c0
This commit is contained in:
Geir Horn 2024-02-14 22:00:36 +01:00
parent 4486393c02
commit 5c67c7c7e0
1 changed files with 20 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
SolverComponent.cpp
View File

@ -228,31 +228,31 @@ int main( int NumberOfCLIOptions, char ** CLIOptionStrings )
// 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() );
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 SelectorString;
std::ostringstream SelectorString;
// SelectorString << "application = '" << ApplicationID << "'";
SelectorString << "application = '" << ApplicationID << "'";
// EncodedFilter << proton::codec::start::described()
// << proton::symbol("apache.org:selector-filter:string")
// << SelectorString.str()
// << proton::codec::finish();
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 );
TheFilter.put( FilterKey, FilterValue );
TheSourceOptions.filters( TheFilter );
TheOptions.source( TheSourceOptions );
// return TheOptions;
// }
return TheOptions;
}
// The application identifier must also be provided in every message to
// allow other receivers to filter on this.