spryker/message-broker

消息经纪人模块


README

Latest Stable Version Minimum PHP Version

将消息包装在 Symfony 封装器中并通过配置的传输发送。为定义的通道启动工作进程。

安装

composer require spryker/message-broker

文档

Spryker 文档

配置示例(config_x.php)

这只是一个用于测试目的的示例,实际的配置将通过环境变量完成。

$config[MessageBrokerAwsConstants::SNS_SENDER_CONFIG] = [
    'endpoint' => 'https://sns.eu-central-1.amazonaws.com',
    'accessKeyId' => '...',
    'accessKeySecret' => '...',
    'region' => 'eu-central-1',
    'topic' => 'arn:aws:sns:eu-central-1:...:message-broker-test',
];

$config[MessageBrokerAwsConstants::SQS_RECEIVER_CONFIG] = [
    'endpoint' => 'https://sqs.eu-central-1.amazonaws.com',
    'account' => '...',
    'accessKeyId' => '...',
    'accessKeySecret' => '...',
    'region' => 'eu-central-1',
    'queue_name' => 'message-broker-test',
    'poll_timeout' => 5,
    'queueUrl' => 'https://sqs.eu-central-1.amazonaws.com/.../message-broker-test',
    'auto_setup' => false,
];

$config[MessageBrokerAwsConstants::CHANNEL_TO_SENDER_CLIENT_MAP] = [
    'payment' => 'sns',
];

$config[MessageBrokerAwsConstants::CHANNEL_TO_RECEIVER_CLIENT_MAP] = [
    'payment' => 'sqs',
];

$config[MessageBrokerConstants::MESSAGE_TO_CHANNEL_MAP] = [
    PaymentMethodTransfer::class => 'payment',
];


$config[MessageBrokerAwsConstants::MESSAGE_TO_CHANNEL_MAP] = [
    PaymentMethodTransfer::class => 'payment',
];