blob: 072127ee2940a47d790b84011ee1a6050f353c0e [file] [log] [blame]
<?php
// This file is auto-generated, don't edit it. Thanks.
namespace RocketMQ\Eventbridge\SDK\Demo;
use RocketMQ\Eventbridge\SDK\SDKClient;
use AlibabaCloud\Tea\Utils\Utils;
use AlibabaCloud\Tea\Console\Console;
use \Exception;
use AlibabaCloud\Tea\Exception\TeaError;
use Darabonba\OpenApi\Models\Config;
use RocketMQ\Eventbridge\SDK\Models\CreateEventRuleRequest;
use RocketMQ\Eventbridge\SDK\Models\GetEventRuleRequest;
use RocketMQ\Eventbridge\SDK\Models\DeleteEventRuleRequest;
use RocketMQ\Eventbridge\SDK\Models\UpdateEventRuleRequest;
use RocketMQ\Eventbridge\SDK\Models\ListEventRulesRequest;
use RocketMQ\Eventbridge\SDK\Models\EnableEventRuleRequest;
use RocketMQ\Eventbridge\SDK\Models\DisableEventRuleRequest;
class Demo {
protected $_sdkClient;
protected $_endpoint;
public function __construct(){
$this->_endpoint = "127.0.0.1:7001";
$config = new Config([
"endpoint" => $this->_endpoint
]);
$this->_sdkClient = new SDKClient($config);
}
/**
* EventRule Controller apis:
* * createEventRule *
* * getEventRule *
* * deleteEventRule *
* * updateEventRule *
* * listEventRules *
* * enableEventRule *
* * disableEventRule *
* @return void
*/
public function testCreateEventRule(){
$request = new CreateEventRuleRequest([
"eventBusName" => "newBus",
"eventRuleName" => "newRule",
"description" => "an event rule for test",
"filterPattern" => "{}"
]);
try {
$res = $this->_sdkClient->createEventRule($request);
Console::log(Utils::toJSONString($res->body));
}
catch (Exception $err) {
if (!($err instanceof TeaError)) {
$err = new TeaError([], $err->getMessage(), $err->getCode(), $err);
}
Console::log("err!");
Console::log($err->message);
}
finally {
Console::log("test end!");
}
}
/**
* @return void
*/
public function testGetEventRule(){
$request = new GetEventRuleRequest([
"eventBusName" => "newBus",
"eventRuleName" => "newRule"
]);
try {
$res = $this->_sdkClient->getEventRule($request);
Console::log(Utils::toJSONString($res->body));
}
catch (Exception $err) {
if (!($err instanceof TeaError)) {
$err = new TeaError([], $err->getMessage(), $err->getCode(), $err);
}
Console::log("err!");
Console::log($err->message);
}
finally {
Console::log("test end!");
}
}
/**
* @return void
*/
public function testDeleteEventRule(){
$request = new DeleteEventRuleRequest([
"eventBusName" => "newBus",
"eventRuleName" => "newRule"
]);
try {
$res = $this->_sdkClient->deleteEventRule($request);
Console::log(Utils::toJSONString($res->body));
}
catch (Exception $err) {
if (!($err instanceof TeaError)) {
$err = new TeaError([], $err->getMessage(), $err->getCode(), $err);
}
Console::log("err!");
Console::log($err->message);
}
finally {
Console::log("test end!");
}
}
/**
* @return void
*/
public function testUpdateEventRule(){
$request = new UpdateEventRuleRequest([
"eventBusName" => "newBus",
"eventRuleName" => "newRule",
"description" => "new description for testing update API",
"filterPattern" => "{}"
]);
try {
$res = $this->_sdkClient->updateEventRule($request);
Console::log(Utils::toJSONString($res->body));
}
catch (Exception $err) {
if (!($err instanceof TeaError)) {
$err = new TeaError([], $err->getMessage(), $err->getCode(), $err);
}
Console::log("err!");
Console::log($err->message);
}
finally {
Console::log("test end!");
}
}
/**
* @return void
*/
public function testListEventRules(){
$request = new ListEventRulesRequest([
"eventBusName" => "newBus",
"maxResults" => 2,
"nextToken" => "0"
]);
try {
$res = $this->_sdkClient->listEventRules($request);
Console::log(Utils::toJSONString($res->body));
}
catch (Exception $err) {
if (!($err instanceof TeaError)) {
$err = new TeaError([], $err->getMessage(), $err->getCode(), $err);
}
Console::log("err!");
Console::log($err->message);
}
finally {
Console::log("test end!");
}
}
/**
* @return void
*/
public function testEnableEventRule(){
$request = new EnableEventRuleRequest([
"eventBusName" => "newBus",
"eventRuleName" => "newRule"
]);
try {
$res = $this->_sdkClient->enableEventRule($request);
Console::log(Utils::toJSONString($res->body));
}
catch (Exception $err) {
if (!($err instanceof TeaError)) {
$err = new TeaError([], $err->getMessage(), $err->getCode(), $err);
}
Console::log("err!");
Console::log($err->message);
}
finally {
Console::log("test end!");
}
}
/**
* @return void
*/
public function testDisableEventRule(){
$request = new DisableEventRuleRequest([
"eventBusName" => "newBus",
"eventRuleName" => "newRule"
]);
try {
$res = $this->_sdkClient->disableEventRule($request);
Console::log(Utils::toJSONString($res->body));
}
catch (Exception $err) {
if (!($err instanceof TeaError)) {
$err = new TeaError([], $err->getMessage(), $err->getCode(), $err);
}
Console::log("err!");
Console::log($err->message);
}
finally {
Console::log("test end!");
}
}
}