README

使用 AWS SNS 发送事件消息

安装

添加

"dafiti/messagebus": "dev-master"

到您的 composer.json

或者运行

composer require dafiti/messagebus

用法

<?php

use Aws\Kinesis\KinesisClient;
use Dafiti\MessageBus\Config;
use Dafiti\MessageBus\Dispatcher\Adapter\Kinesis;
use Dafiti\MessageBus\Dispatcher\Dispatcher;
use Dafiti\MessageBus\Entity\Order\OrderEntity;
use Dafiti\MessageBus\Events\EventCollection;
use Dafiti\MessageBus\Events\Order\CreateOrder;
use Dafiti\MessageBus\MessageBus;

require __DIR__ . "/../vendor/autoload.php";

// Create library configuration
$config = new Config(Config::ENV_LOCAL, 'fake-steeam-name', 'fake-sender', 'partition-key');

// Initialize dispatcher adapter
$kinesisClient = new KinesisClient([
    'profile' => 'default',
    'region' => 'us-east-1',
    'version' => 'latest',
]);
$adapter = new Kinesis($kinesisClient, $config);

// Create dispatcher
$dispatcher = new Dispatcher($adapter);

// Create the main object
$messageBus = new MessageBus($dispatcher, $config);

// Configure the event to be dispatched
$order = new OrderEntity(...);
$event = new CreateOrder($order);

$messageBus->dispatch(new EventCollection([$event]));

这将通过配置的适配器发送您创建的事件的有效负载消息。

dafiti / messagebus

维护者

详细信息

README

安装

用法