This is an automated email from the ASF dual-hosted git repository.
pnoltes pushed a commit to branch feature/pstm_missing_receiver_fix
in repository https://gitbox.apache.org/repos/asf/celix.git
The following commit(s) were added to
refs/heads/feature/pstm_missing_receiver_fix by this push:
new d7d6ef4a Fix wrong needsMatch assignment in pstm
d7d6ef4a is described below
commit d7d6ef4a5e2d43886fbfd179f310725b0968cc75
Author: Pepijn Noltes <[email protected]>
AuthorDate: Mon Dec 5 17:29:46 2022 +0100
Fix wrong needsMatch assignment in pstm
---
bundles/pubsub/pubsub_topology_manager/src/pubsub_topology_manager.c | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/bundles/pubsub/pubsub_topology_manager/src/pubsub_topology_manager.c
b/bundles/pubsub/pubsub_topology_manager/src/pubsub_topology_manager.c
index 3e95e5db..a204668b 100644
--- a/bundles/pubsub/pubsub_topology_manager/src/pubsub_topology_manager.c
+++ b/bundles/pubsub/pubsub_topology_manager/src/pubsub_topology_manager.c
@@ -998,7 +998,7 @@ static void
pstm_setupTopicSenders(pubsub_topology_manager_t *manager) {
celix_logHelper_warning(manager->loghelper, "Cannot setup
TopicSender for %s/%s\n", setupEntry->scope == NULL ? "(null)" :
setupEntry->scope, setupEntry->topic);
celixThreadMutex_lock(&manager->topicSenders.mutex);
pstm_topic_receiver_or_sender_entry_t* entry =
hashMap_get(manager->topicSenders.map, setupEntry->key);
- entry->matching.needsMatch = false;
+ entry->matching.needsMatch = true;
celixThreadMutex_unlock(&manager->topicSenders.mutex);
celix_properties_destroy(setupEntry->topicProperties);
celix_properties_destroy(setupEntry->endpointResult);