View GitHub Repository qpush-bundle

Schedule Inspection
Subscribe

Code Duplication    Length = 5-5 lines in 2 locations

src/Provider/IronMqProvider.php 2 locations

@@ 117-121 (lines=5) @@
114 
        try {
115 
            $this->ironmq->deleteQueue($this->getNameWithPrefix());
116 
        } catch ( \Exception $e) {
117 
            if (false !== strpos($e->getMessage(), "Queue not found")) {
118 
                $this->log(400, "Queue did not exist");
119 
            } else {
120 
                throw $e;
121 
            }
122 
        }
123 

                                

                                                            

                                    124
                                    
                                    
        $key = $this->getNameWithPrefix();

                                

                                                                                

                                
                                
                                    @@ 218-222 (lines=5) @@
                                
                            


                                                            

                                    215
                                    
                                    
            $result = $this->ironmq->deleteMessage($this->getNameWithPrefix(), $id);

                                

                                                            

                                    216
                                    
                                    
            $this->log(200, "Message deleted.", ['message_id' => $id]);

                                

                                                            

                                    217
                                    
                                    
        } catch ( \Exception $e) {

                                

                                                            

                                    218
                                    
                                    
            if (false !== strpos($e->getMessage(), "Queue not found")) {

                                

                                                            

                                    219
                                    
                                    
                $this->log(400, "Queue did not exist");

                                

                                                            

                                    220
                                    
                                    
            } else {

                                

                                                            

                                    221
                                    
                                    
                throw $e;

                                

                                                            

                                    222
                                    
                                    
            }

                                

                                                            

                                    223
                                    
                                    
        }

                                

                                                            

                                    224
                                    
                                    

                                

                                                            

                                    225
                                    
                                    
        return true;