Skip to content

Commit f65173f

Browse files
keboliulguohan
authored andcommitted
add publish interface for DBInterface (#29)
1 parent cd4cb27 commit f65173f

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

src/swsssdk/interface.py

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -254,6 +254,13 @@ def get_redis_client(self, db_name):
254254
"""
255255
return self.redis_clients[db_name]
256256

257+
def publish(self, db_name, channel, message):
258+
"""
259+
Publish message via the channel
260+
"""
261+
client = self.redis_clients[db_name]
262+
return client.publish(channel, message)
263+
257264
@blockable
258265
def keys(self, db_name, pattern='*'):
259266
"""

0 commit comments

Comments
 (0)