mcorten / rabbitmq_api

use mcorten87\rabbitmq_api\objects\Url;

use mcorten87\rabbitmq_api\services\MqManagementConfig;

class JobBindingToExchangeCreateMapper extends BaseMapper

{

    protected function mapMethod(JobBase $job) : Method

    {

        return new Method(Method::METHOD_POST);

    }

    /**

     * @param JobBindingToExchangeCreate $job

     * @return Url

     */

    protected function mapUrl(JobBase $job) : Url

    {

        return new Url('bindings/'

            .urlencode($job->getVirtualHost()).'/'

            .'e/'

            .urlencode($job->getExchangeName()).'/'

            .$job->getDestinationType().'/'

            .urlencode($job->getToExchange())

        );

    }

    /**

     * @param JobBindingToExchangeCreate $job

     * @return array

     */

    protected function mapConfig(JobBase $job) : array {

        $body = [

            'arguments'         => [],

            'destination'       => (string)$job->getToExchange(),

            'destination_type'  => $job->getDestinationType(),

            'routing_key'       => (string)$job->getRoutingKey(),

            'source'            => (string)$job->getExchangeName(),

            'vhost'             => $job->getVirtualHost(),

        ];

        return array_merge(parent::mapConfig($job), [

            'json'      =>  $body,

        ]);

    }

}

use mcorten87\rabbitmq_api\objects\Url;

use mcorten87\rabbitmq_api\services\MqManagementConfig;

class JobBindingToQueueCreateMapper extends BaseMapper

{

    protected function mapMethod(JobBase $job) : Method

    {

        return new Method(Method::METHOD_POST);

    }

    /**

     * @param JobBindingToExchangeCreate $job

     * @return Url

     */

    protected function mapUrl(JobBase $job) : Url

    {

        return new Url('bindings/'

            .urlencode($job->getVirtualHost()).'/'

            .'e/'

            .urlencode($job->getExchangeName()).'/'

            .$job->getDestinationType().'/'

            .urlencode($job->getQueueName())

        );

    }

    /**

     * @param JobBindingToExchangeCreate $job

     * @return array

     */

    protected function mapConfig(JobBase $job) : array {

        $body = [

            'arguments'         => [],

            'destination'       => (string)$job->getQueueName(),

            'destination_type'  => $job->getDestinationType(),

            'routing_key'       => (string)$job->getRoutingKey(),

            'source'            => (string)$job->getExchangeName(),

            'vhost'             => $job->getVirtualHost(),

        ];

        return array_merge(parent::mapConfig($job), [

            'json'      =>  $body,

        ]);

    }

}