diff --git a/glide.lock b/glide.lock
index a3f64efc..a3c829e6 100644
--- a/glide.lock
+++ b/glide.lock
@@ -1,5 +1,5 @@
 hash: 7c938e591b0602b9fd3412aeffd3f1438fc77eaea80c8d9dd03431adb0e1e1c9
-updated: 2017-11-01T16:18:51.144141389+08:00
+updated: 2017-11-28T13:53:51.161369563+08:00
 imports:
 - name: cloud.google.com/go
   version: 3b1ae45394a234c385be014e9a488f2bb6eef821
@@ -112,7 +112,7 @@ imports:
 - name: github.com/mholt/archiver
   version: 26cf5bb32d07aa4e8d0de15f56ce516f4641d7df
 - name: github.com/nats-io/go-nats
-  version: 9147cfac69833916f9c73353ba43f939815c330a
+  version: 6f06d34c19fc8607adf14668b5bb2c9465d78348
   subpackages:
   - encoders/builtin
   - util
@@ -121,7 +121,7 @@ imports:
   subpackages:
   - pb
 - name: github.com/nats-io/nats-streaming-server
-  version: 9ebc07951af540e177f6a5bb0424f716fd867074
+  version: f9638df9ef7ee548313eeb5a9dda9c888dc769a0
   subpackages:
   - util
 - name: github.com/nats-io/nuid
diff --git a/mqtrigger/messageQueue/nats.go b/mqtrigger/messageQueue/nats.go
index d2fde7a9..a562eeff 100644
--- a/mqtrigger/messageQueue/nats.go
+++ b/mqtrigger/messageQueue/nats.go
@@ -88,7 +88,7 @@ func (nats Nats) unsubscribe(subscription messageQueueSubscription) error {
 
 func isTopicValidForNats(topic string) bool {
 	// nats-streaming does not support wildcard channel.
-	return nsUtil.IsSubjectValid(topic, false)
+	return nsUtil.IsChannelNameValid(topic, false)
 }
 
 func msgHandler(nats *Nats, trigger *crd.MessageQueueTrigger) func(*ns.Msg) {