|
|
@@ -47,7 +47,10 @@ class TestController extends BaseController
|
|
|
{
|
|
|
$producer = Yii::$app->rabbitmq->getProducer('stockProducer');
|
|
|
$msg = serialize(['type' => 'add', 'name' => 'shish']);
|
|
|
- $producer->publish($msg, 'stockExchange', 'stockRoute');
|
|
|
+ $producer->publish($msg, 'stockExchange', 'stockRoute',[
|
|
|
+ 'delivery_mode' => 2, // 2 表示持久化，1 表示非持久化
|
|
|
+ 'content_type' => 'application/octet-stream'
|
|
|
+ ]);
|
|
|
}
|
|
|
|
|
|
public function actionFx()
|
