diff --git a/src/swsssdk/interface.py b/src/swsssdk/interface.py index 668588685..2ab1ad820 100644 --- a/src/swsssdk/interface.py +++ b/src/swsssdk/interface.py @@ -254,6 +254,13 @@ def get_redis_client(self, db_name): """ return self.redis_clients[db_name] + def publish(self, db_name, channel, message): + """ + Publish message via the channel + """ + client = self.redis_clients[db_name] + return client.publish(channel, message) + @blockable def keys(self, db_name, pattern='*'): """