生产者 ¶

助手函数调用 ¶

php

/**
 * 添加到队列
 * @param string        $connectName   连接名称
 * @param string        $exchangeName  交换机名称
 * @param string|array  $queueName     队列名称
 * @param string|array  $msg           队列数据
 * @param int           $delay         延迟时间
 */
function queue_producer($connectName, $exchangeName = '', $queueName = null, $msg = 0, $delay)

/**
 * 添加到队列
 * @param string        $connectName   连接名称
 * @param string        $exchangeName  交换机名称
 * @param string|array  $queueName     队列名称
 * @param string|array  $msg           队列数据
 * @param int           $delay         延迟时间
 */
function queue_producer($connectName, $exchangeName = '', $queueName = null, $msg = 0, $delay)

单利调用 ¶

方法

所属	方法名	作用
base
connect
	setConnectName(string $name )	设置连接配置
channel
	setExchangeName (string $name )	设置交换机名
	setQueueName (string $name )	设置队列名
message
	addMessage(string\array $msg )	添加内容	可以多次调用追加
	setMessage(string\array $msg )	设置内容	最后覆盖
	setMsgDelay( int $delay )	设置延迟时间
	setMsgEncrypt( int $falg )	设置消息是否加密
job
	setJobServer( )
	setJobFunc( )