File tree Expand file tree Collapse file tree 2 files changed +4
-15
lines changed
src/FintechFab/LaravelQueueRabbitMQ/Queue Expand file tree Collapse file tree 2 files changed +4
-15
lines changed Original file line number Diff line number Diff line change @@ -117,18 +117,7 @@ public function attempts()
117117 */
118118 public function getJobId ()
119119 {
120- return $ this ->message ->body ;
120+ return $ this ->message ->get ( ' correlation_id ' ) ;
121121 }
122122
123- /**
124- * Get queue name
125- *
126- * @return string
127- */
128- public function getQueue ()
129- {
130- return $ this ->queue ->getName ();
131- }
132-
133-
134123}
Original file line number Diff line number Diff line change @@ -142,15 +142,15 @@ public function pop($queue = null)
142142 *
143143 * @return string
144144 */
145- public function getQueueName ($ queue )
145+ private function getQueueName ($ queue )
146146 {
147147 return $ queue ?: $ this ->defaultQueue ;
148148 }
149149
150150 /**
151151 * @return AMQPChannel
152152 */
153- public function getChannel ()
153+ private function getChannel ()
154154 {
155155 return $ this ->connection ->channel ();
156156 }
@@ -190,7 +190,7 @@ private function declareQueue($name)
190190 *
191191 * @return string
192192 */
193- public function declareDelayedQueue ($ destination , $ delay )
193+ private function declareDelayedQueue ($ destination , $ delay )
194194 {
195195 $ delay = $ this ->getSeconds ($ delay );
196196 $ destination = $ this ->getQueueName ($ destination );
You can’t perform that action at this time.
0 commit comments