File tree 1 file changed +3
-4
lines changed
1 file changed +3
-4
lines changed Original file line number Diff line number Diff line change 10
10
use Enqueue \Stomp \StompConnectionFactory ;
11
11
use Enqueue \Stomp \StompContext ;
12
12
use Enqueue \Stomp \StompMessage ;
13
- use Interop \Queue \PsrMessage ;
14
13
use yii \base \Application as BaseApp ;
15
14
use yii \base \Event ;
16
15
use yii \base \NotSupportedException ;
@@ -196,7 +195,7 @@ public function run($repeat, $timeout = 0)
196
195
});
197
196
}
198
197
199
- protected function setMessageId (PsrMessage $ message )
198
+ protected function setMessageId (StompMessage $ message )
200
199
{
201
200
$ message ->setMessageId (uniqid ('' , true ));
202
201
return $ message ;
@@ -258,8 +257,8 @@ public function status($id)
258
257
/**
259
258
* @param StompMessage $message
260
259
* @throws \Interop\Queue\Exception
261
- * @throws \Interop\Queue\InvalidDestinationException
262
- * @throws \Interop\Queue\InvalidMessageException
260
+ * @throws \Interop\Queue\Exception\ InvalidDestinationException
261
+ * @throws \Interop\Queue\Exception\ InvalidMessageException
263
262
*/
264
263
protected function redeliver (StompMessage $ message )
265
264
{
You can’t perform that action at this time.
0 commit comments