Balance RabbitMQ Product Export Bundle - Overview

This is a prototype bundle for demonstrating how Akeneo PIM could communicate with RabbitMQ, specifically for trialing the JSON over AMQP integration for Magento Commerce and Order Management Systems.

This bundle is created to export product data in JSON format based on the Magento defined template.

more information can be found at Magento DevDocs

How does it work?

The bundle generates a message about a single product in the predefined format and pushes the message to the queue. The relevant configuration for the queue is set in the export profile.

What is the format?

{
    "product": {
        "associations": [
            {
                "products": [
                    "WB-WD7S",
                    "WB-WD10S"
                ],
                "type": "upsell"
            },
            {
                "products": [
                    "WB-WD7S",
                    "WB-WD10S"
                ],
                "type": "crosssell"
            }
        ],
        "attribute_set": "4",
        "created_at": "2016-03-03T08:56:46+00:00",
        "enabled": true,
        "id": "WB-WD13S",
        "modified_at": "2016-03-03T08:58:33+00:00",
        "name": [
            {
                "channel": null,
                "locale": null,
                "value": "Washburn WD13S"
            }
        ],
        "sku": "WB-WD13S",
        "visibility": [
            "catalog",
            "search"
        ]
    }
}

How to define what fields should be exported?

Array list can be managed in the file Balance/Bundle/RabbitMQBundle/RabbitMQ/Normalizer/ProductNormalizer.php

Installation

Put the code into "scr" folder
Add to composer.json "php-amqplib/rabbitmq-bundle" and run composer update.
Enable the bundle in the app/AppKernel.php file:

    public function registerBundles()
    {
        $bundles = [
            new Balance\Bundle\RabbitMQBundle\BalanceRabbitMQBundle(),
        ]
        return $bundles;
    }

Clear cache
Go to "Export profiles" and create a new export using "Products Export RabbitMQ" connector.
Configure the export profile, the variables responsible for RabbitMQ connection are:

AMQP Host
AMQP Port
AMQP Username
AMQP Password
AMQP Virtualhost
AMQP Exchange
AMQP Route-key
AMQP Header "to"

Run the export profile and see how your messages appears in the RabbitMQ UI.

Roadmap