Code Duplication    Length = 14-15 lines in 2 locations

DependencyInjection/CmobiRabbitmqExtension.php 2 locations

@@ 56-70 (lines=15) @@
53
        $container->setParameter('cmobi_rabbitmq.connection.factories', $factories);
54
    }
55
56
    public function loadRpcServers(ContainerBuilder $container, array $configs)
57
    {
58
        foreach ($configs['rpc_servers'] as $server) {
59
60
            $container->addCompilerPass(new RpcServerPass(
61
                $server['queue']['name'],
62
                $server['queue']['connection'],
63
                $server['service'],
64
                $server['queue']['basic_qos'],
65
                $server['queue']['durable'],
66
                $server['queue']['auto_delete'],
67
                $server['queue']['arguments']
68
            ));
69
        }
70
    }
71
72
    public function loadWorkers(ContainerBuilder $container, array $configs)
73
    {
@@ 85-98 (lines=14) @@
82
        }
83
    }
84
85
    public function loadSubscribers(ContainerBuilder $container, array $configs)
86
    {
87
        foreach ($configs['subscribers'] as $subscriber) {
88
            $container->addCompilerPass(new SubscriberPass(
89
                $subscriber['queue']['exchange'],
90
                $subscriber['queue']['exchange_type'],
91
                $subscriber['queue']['name'],
92
                $subscriber['queue']['connection'],
93
                $subscriber['service'],
94
                $subscriber['queue']['basic_qos'],
95
                $subscriber['queue']['arguments']
96
            ));
97
        }
98
    }
99
}
100