list vhost connections

rabbithole_test.go

@@ -1071,6 +1071,36 @@ var _ = Describe("RabbitMQ HTTP API client", func() {
 		})
 	})
 
+	Context("GET /vhosts/{name}/connections", func() {
+		It("returns decoded response", func() {
+
+			conn := openConnection("rabbit/hole")
+			defer conn.Close()
+
+			ch, err := conn.Channel()
+			Ω(err).Should(BeNil())
+			defer ch.Close()
+
+			err = ch.Publish("",
+				"",
+				false,
+				false,
+				amqp.Publishing{Body: []byte("")})
+			Ω(err).Should(BeNil())
+
+			// give internal events a moment to be
+			// handled
+			awaitEventPropagation()
+
+			xs, err := rmqc.ListVhostConnections("rabbit/hole")
+			Ω(err).Should(BeNil())
+
+			c1 := xs[0]
+			Ω(c1.Protocol).Should(Equal("AMQP 0-9-1"))
+			Ω(c1.User).Should(Equal("guest"))
+		})
+	})
+
 	Context("vhost-limits", func() {
 		maxConnections := 1
 		maxQueues := 2

vhosts_connections.go

@@ -0,0 +1,19 @@
+package rabbithole
+
+import (
+	"net/url"
+)
+
+// ListVhostConnections returns the current connections to a specified vhost
+func (c *Client) ListVhostConnections(vhostname string) (rec []ConnectionInfo, err error) {
+	req, err := newGETRequest(c, "vhosts/"+url.PathEscape(vhostname)+"/connections")
+	if err != nil {
+		return []ConnectionInfo{}, err
+	}
+
+	if err = executeAndParseRequest(c, req, &rec); err != nil {
+		return []ConnectionInfo{}, err
+	}
+
+	return rec, nil
+}