aboutsummaryrefslogtreecommitdiff
path: root/weed/messaging/msgclient
diff options
context:
space:
mode:
Diffstat (limited to 'weed/messaging/msgclient')
-rw-r--r--weed/messaging/msgclient/chan_config.go5
-rw-r--r--weed/messaging/msgclient/chan_pub.go (renamed from weed/messaging/msgclient/pub_chan.go)0
-rw-r--r--weed/messaging/msgclient/chan_sub.go (renamed from weed/messaging/msgclient/sub_chan.go)0
3 files changed, 5 insertions, 0 deletions
diff --git a/weed/messaging/msgclient/chan_config.go b/weed/messaging/msgclient/chan_config.go
new file mode 100644
index 000000000..a75678815
--- /dev/null
+++ b/weed/messaging/msgclient/chan_config.go
@@ -0,0 +1,5 @@
+package msgclient
+
+func (mc *MessagingClient) DeleteChannel(chanName string) error {
+ return mc.DeleteTopic("chan", chanName)
+}
diff --git a/weed/messaging/msgclient/pub_chan.go b/weed/messaging/msgclient/chan_pub.go
index 9bc88f7c0..9bc88f7c0 100644
--- a/weed/messaging/msgclient/pub_chan.go
+++ b/weed/messaging/msgclient/chan_pub.go
diff --git a/weed/messaging/msgclient/sub_chan.go b/weed/messaging/msgclient/chan_sub.go
index 213ff4666..213ff4666 100644
--- a/weed/messaging/msgclient/sub_chan.go
+++ b/weed/messaging/msgclient/chan_sub.go