gvsafronov/tile38
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fixed AMQP and AMQPS webhook endpoints to support namespaces.

Browse Source
This commit is contained in:
Brantley Harris 2018-05-14 14:56:24 -05:00
parent 57feef2429
commit d5af91c453
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
pkg/endpoint/endpoint.go
View File

@ -469,6 +469,7 @@ func parseEndpoint(s string) (Endpoint, error) {
// Basic AMQP connection strings in HOOKS interface // Basic AMQP connection strings in HOOKS interface
// amqp://guest:guest@localhost:5672/<queue_name>/?params=value // amqp://guest:guest@localhost:5672/<queue_name>/?params=value
// or amqp://guest:guest@localhost:5672/<namespace>/<queue_name>/?params=value
// //
// Default params are: // Default params are:
// //
@ -486,7 +487,14 @@ func parseEndpoint(s string) (Endpoint, error) {
endpoint.AMQP.Durable = true endpoint.AMQP.Durable = true
endpoint.AMQP.DeliveryMode = amqp.Transient endpoint.AMQP.DeliveryMode = amqp.Transient
// Bind queue name // Fix incase of namespace, e.g. example.com/namespace/queue
// but not example.com/queue/ - with an endslash.
if len(sp) > 2 && len(sp[2]) > 0 {
endpoint.AMQP.URI = endpoint.AMQP.URI + "/" + sp[1]
sp = append([]string{endpoint.AMQP.URI}, sp[2:]...)
}
// Bind queue name with no namespace
if len(sp) > 1 { if len(sp) > 1 {
var err error var err error
endpoint.AMQP.QueueName, err = url.QueryUnescape(sp[1]) endpoint.AMQP.QueueName, err = url.QueryUnescape(sp[1])