What are the Slack Archives?

It’s a history of our time together in the Slack Community! There’s a ton of knowledge in here, so feel free to search through the archives for a possible answer to your question.

Because this space is not active, you won’t be able to create a new post or comment here. If you have a question or want to start a discussion about something, head over to our categories and pick one to post in! You can always refer back to a post from Slack Archives if needed; just copy the link to use it as a reference..

Hii everyone i want to use rabbitMQ for send some message for testing and i have write some code &l

U04SA0H260N
U04SA0H260N Posts: 30 🧑🏻‍🚀 - Cadet

Hii everyone i want to use rabbitMQ for send some message for testing and i have write some code

<?php

/**
* This file is part of the Spryker Commerce OS.
* For full license information, please view the LICENSE file that was distributed with this source code.
*/

namespace Pyz\Yves\HelloWorld\Controller;

use Spryker\Yves\Kernel\Controller\AbstractController;
use Symfony\Component\HttpFoundation\Request;
use Generated\Shared\Transfer\RabbitMqOptionTransfer;
use Spryker\Zed\RabbitMq\Business\RabbitMqFacade;
use Spryker\Shared\RabbitMq\RabbitMqConfig;
use Spryker\Zed\RabbitMq\Communication\Plugin\Queue\RabbitMqProducerPlugin;

class IndexController extends AbstractController
{
protected $producerPlugin;

public function __construct()
{
    // $this->producerPlugin = new RabbitMqProducerPlugin();
}
/**
 * @param \Symfony\Component\HttpFoundation\Request $request
 *
 * @return \Spryker\Yves\Kernel\View\View
 */
public function indexAction(Request $request)
{
    $optionsTransfer = new RabbitMqOptionTransfer();
    $optionsTransfer->setType(RabbitMqConfig::EXCHANGE_DIRECT);

    $this->producerPlugin
        ->setRoutingKey('my_routing_key')
        ->publish('Testing Message..', $optionsTransfer);

    $data = ['helloWorld' => 'Message Sent !'];

    return $this->view(
        $data,
        [],
        '@HelloWorld/views/index/index.twig'
    );
}

}

It gives me error

Comments

  • fsmeier
    fsmeier Senior Software Engineer & Developer Enablement Advocate Sprykee Posts: 1,084 ⚖️ - Guardians (admin)

    Where do you have the RabbitMqConfig::EXCHANGE_DIRECT from? Was it somewhere documented to use it like that? because i can not find that constant in Spryker.