Merge pull request #5 from skolodyazhnyy/master

API to work with Exchange to Exchange bindings

Author: richardfullmer

src/RabbitMq/ManagementApi/Api/Binding.php

@@ -40,6 +40,21 @@ public function binding($vhost, $exchange, $queue)
         return $this->client->send(array('/api/bindings/{vhost}/e/{exchange}/q/{queue}', array('vhost' => $vhost, 'exchange' => $exchange, 'queue' => $queue)));
     }
 
+    /**
+     * A list of all bindings between two exchanges. Remember, two exchanges can be bound together many times with
+     * different parameters!
+     *
+     * @param string $vhost
+     * @param string $source
+     * @param string $destination
+     *
+     * @return array
+     */
+    public function exchangeBinding($vhost, $source, $destination)
+    {
+        return $this->client->send(array('/api/bindings/{vhost}/e/{source}/e/{destination}', array('vhost' => $vhost, 'source' => $source, 'destination' => $destination)));
+    }
+
     /**
      *  To create a new binding, POST to this URI. You will need a body looking something like this:
      *
@@ -73,6 +88,39 @@ public function create($vhost, $exchange, $queue, $routingKey = null, array $arg
         return $this->client->send(array('/api/bindings/{vhost}/e/{exchange}/q/{queue}', array('vhost' => $vhost, 'exchange' => $exchange, 'queue' => $queue)), 'POST', null, $parameters);
     }
 
+    /**
+     *  To create a new exchange to exchange binding, POST to this URI. You will need a body looking something like this:
+     *
+     * {
+     *     "routing_key": "my_routing_key",
+     *     "arguments": []
+     * }
+     *
+     * All keys are optional. The response will contain a Location header telling you the URI of your new binding.
+     *
+     * @param string $vhost
+     * @param string $source
+     * @param string $destination
+     * @param string|null $routingKey
+     * @param array|null $arguments
+     * @return array
+     */
+    public function createExchange($vhost, $source, $destination, $routingKey = null, array $arguments = null)
+    {
+        $parameters = array();
+
+        if ($routingKey) {
+            $parameters['routing_key'] = $routingKey;
+        } else {
+            $parameters['routing_key'] = '';
+        }
+        if ($arguments) {
+            $parameters['arguments'] = $arguments;
+        }
+
+        return $this->client->send(array('/api/bindings/{vhost}/e/{source}/e/{destination}', array('vhost' => $vhost, 'source' => $source, 'destination' => $destination)), 'POST', null, $parameters);
+    }
+
     /**
      * An individual binding between an exchange and a queue. The props part of the URI is a "name" for the binding
      * composed of its routing key and a hash of its arguments.
@@ -89,7 +137,22 @@ public function get($vhost, $exchange, $queue, $props)
     }
 
     /**
-     * Remove an individual binding.
+     * An individual binding between two exchanges. The props part of the URI is a "name" for the binding
+     * composed of its routing key and a hash of its arguments.
+     *
+     * @param string $vhost
+     * @param string $source
+     * @param string $destination
+     * @param string $props
+     * @return array
+     */
+    public function getExchange($vhost, $source, $destination, $props)
+    {
+        return $this->client->send(array('/api/bindings/{vhost}/e/{source}/e/{destination}/{props}', array('vhost' => $vhost, 'source' => $source, 'destination' => $destination, 'props' => $props)));
+    }
+
+    /**
+     * Remove an individual binding between an exchange and a queue.
      *
      * @param string $vhost
      * @param string $exchange
@@ -101,4 +164,18 @@ public function delete($vhost, $exchange, $queue, $props)
     {
         return $this->client->send(array('/api/bindings/{vhost}/e/{exchange}/q/{queue}/{props}', array('vhost' => $vhost, 'exchange' => $exchange, 'queue' => $queue, 'props' => $props)), 'DELETE');
     }
+
+    /**
+     * Remove an individual binding between two exchanges.
+     *
+     * @param string $vhost
+     * @param string $source
+     * @param string $destination
+     * @param string $props
+     * @return array
+     */
+    public function deleteExchange($vhost, $source, $destination, $props)
+    {
+        return $this->client->send(array('/api/bindings/{vhost}/e/{source}/e/{destination}/{props}', array('vhost' => $vhost, 'source' => $source, 'destination' => $destination, 'props' => $props)), 'DELETE');
+    }
 }