View GitHub Repository kueueingbundle-stomp

Schedule Inspection
Subscribe

Code Duplication    Length = 3-3 lines in 2 locations

DependencyInjection/KaliopQueueingPluginsStompExtension.php 2 locations

@@ 59-61 (lines=3) @@
56 
        }
57 

                                

                                                            

                                    58
                                    
                                    
        foreach ($this->config['producers'] as $key => $producer) {

                                

                                                            

                                    59
                                    
                                    
            if (!isset($this->config['connections'][$producer['connection']])) {

                                

                                                            

                                    60
                                    
                                    
                throw new \RuntimeException("Stomp producer '$key' can not use connection '{$producer['connection']}' because it is not defined in the connections section");

                                

                                                            

                                    61
                                    
                                    
            }

                                

                                                            

                                    62
                                    
                                    

                                

                                                            

                                    63
                                    
                                    
            $connectionDefinition = $this->config['connections'][$producer['connection']];

                                

                                                            

                                    64
                                    
                                    

                                

                                                                                

                                
                                
                                    @@ 91-93 (lines=3) @@
                                
                            


                                                            

                                    88
                                    
                                    
        }

                                

                                                            

                                    89
                                    
                                    

                                

                                                            

                                    90
                                    
                                    
        foreach ($this->config['consumers'] as $key => $consumer) {

                                

                                                            

                                    91
                                    
                                    
            if (!isset($this->config['connections'][$consumer['connection']])) {

                                

                                                            

                                    92
                                    
                                    
                throw new \RuntimeException("Stomp consumer '$key' can not use connection '{$consumer['connection']}' because it is not defined in the connections section");

                                

                                                            

                                    93
                                    
                                    
            }

                                

                                                            

                                    94
                                    
                                    

                                

                                                            

                                    95
                                    
                                    
            $connectionDefinition = $this->config['connections'][$consumer['connection']];

                                

                                                            

                                    96