Nail/fission-src
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update nats dependencies (#411)

Browse Source
This commit is contained in:
Ta-Ching Chen
2017-11-28 16:12:31 -08:00
committed by Soam Vasani
parent 36008f28d8
commit 140b132c8e
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
glide.lock
Generated
+3 -3
View File
@@ -1,5 +1,5 @@
hash: 7c938e591b0602b9fd3412aeffd3f1438fc77eaea80c8d9dd03431adb0e1e1c9 hash: 7c938e591b0602b9fd3412aeffd3f1438fc77eaea80c8d9dd03431adb0e1e1c9
updated: 2017-11-01T16:18:51.144141389+08:00 updated: 2017-11-28T13:53:51.161369563+08:00
imports: imports:
- name: cloud.google.com/go - name: cloud.google.com/go
version: 3b1ae45394a234c385be014e9a488f2bb6eef821 version: 3b1ae45394a234c385be014e9a488f2bb6eef821
@@ -112,7 +112,7 @@ imports:
- name: github.com/mholt/archiver - name: github.com/mholt/archiver
version: 26cf5bb32d07aa4e8d0de15f56ce516f4641d7df version: 26cf5bb32d07aa4e8d0de15f56ce516f4641d7df
- name: github.com/nats-io/go-nats - name: github.com/nats-io/go-nats
version: 9147cfac69833916f9c73353ba43f939815c330a version: 6f06d34c19fc8607adf14668b5bb2c9465d78348
subpackages: subpackages:
- encoders/builtin - encoders/builtin
- util - util
@@ -121,7 +121,7 @@ imports:
subpackages: subpackages:
- pb - pb
- name: github.com/nats-io/nats-streaming-server - name: github.com/nats-io/nats-streaming-server
version: 9ebc07951af540e177f6a5bb0424f716fd867074 version: f9638df9ef7ee548313eeb5a9dda9c888dc769a0
subpackages: subpackages:
- util - util
- name: github.com/nats-io/nuid - name: github.com/nats-io/nuid
mqtrigger/messageQueue/nats.go
+1 -1
View File
@@ -88,7 +88,7 @@ func (nats Nats) unsubscribe(subscription messageQueueSubscription) error {
func isTopicValidForNats(topic string) bool { func isTopicValidForNats(topic string) bool {
// nats-streaming does not support wildcard channel. // 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) { func msgHandler(nats *Nats, trigger *crd.MessageQueueTrigger) func(*ns.Msg) {