Skip to content
Snippets Groups Projects
Commit 441cb233 authored by Hendrik Buschmeier's avatar Hendrik Buschmeier
Browse files

ipaaca-python: It's now possible to specify a single string category interest...

ipaaca-python: It's now possible to specify a single string category interest on InputBuffer instantiation.
parent 82e76c45
No related branches found
No related tags found
No related merge requests found
...@@ -196,9 +196,7 @@ class InputBuffer(Buffer): ...@@ -196,9 +196,7 @@ class InputBuffer(Buffer):
# add own uuid as identifier for hidden category. # add own uuid as identifier for hidden category.
self._add_category_listener(str(self._uuid)) self._add_category_listener(str(self._uuid))
if category_interests is not None: if category_interests is not None:
for cat in category_interests: self.add_category_interests(category_interests)
self._add_category_listener(cat)
def _get_remote_server(self, iu): def _get_remote_server(self, iu):
'''Return (or create, store and return) a remote server.''' '''Return (or create, store and return) a remote server.'''
...@@ -216,13 +214,13 @@ class InputBuffer(Buffer): ...@@ -216,13 +214,13 @@ class InputBuffer(Buffer):
return remote_server return remote_server
def _add_category_listener(self, iu_category): def _add_category_listener(self, iu_category):
'''Return (or create, store and return) a category listener on a specific channel.''' '''Create and store a listener on a specific category.'''
if iu_category not in self._listener_store: if iu_category not in self._listener_store:
cat_listener = rsb.createListener(rsb.Scope("/ipaaca/channel/"+str(self._channel)+"/category/"+str(iu_category)), config=self._participant_config) cat_listener = rsb.createListener(rsb.Scope("/ipaaca/channel/"+str(self._channel)+"/category/"+str(iu_category)), config=self._participant_config)
cat_listener.addHandler(self._handle_iu_events) cat_listener.addHandler(self._handle_iu_events)
self._listener_store[iu_category] = cat_listener self._listener_store[iu_category] = cat_listener
self._category_interests.append(iu_category) self._category_interests.append(iu_category)
LOGGER.info("Added listener in scope "+"/ipaaca/channel/"+str(self._channel)+"/category/"+iu_category) LOGGER.info("Added listener in scope /ipaaca/channel/" + str(self._channel) + "/category/" + iu_category)
def _handle_iu_events(self, event): def _handle_iu_events(self, event):
'''Dispatch incoming IU events. '''Dispatch incoming IU events.
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment