函数名称:Stomp::commit()
函数描述:该函数用于提交事务。
适用版本:PHP 5 >= 5.3.0, PHP 7, PECL stomp >= 0.1.0
用法:
bool Stomp::commit ( string $transaction_id [, array $headers ] )
参数:
返回值:
示例:
// 创建一个 Stomp 对象
$stomp = new Stomp('tcp://localhost:61613');
// 连接到消息队列服务器
$stomp->connect();
// 开始一个事务
$transactionId = 'transaction-1';
$stomp->begin($transactionId);
// 发送一条消息到队列
$queue = '/queue/test';
$message = 'Hello, World!';
$headers = array('persistent' => 'true');
$stomp->send($queue, $message, $headers);
// 提交事务
$stomp->commit($transactionId);
// 断开与消息队列服务器的连接
$stomp->disconnect();
注意事项:
commit()
之前,必须先调用 begin()
开始一个事务。commit()
只能提交指定的事务,如果事务不存在或已经提交,将返回 false。commit()
之前发生了错误,应该使用 abort()
方法回滚事务。