rabbitmq-flow's People
Forkers
dnd-magnumrabbitmq-flow's Issues
Collision between current repo and configuration
Hello,
I'm in a trouble using this plugin on satellite because of some collisions. In the documentation, it's mentioned:
"This plugin is already integrated into the Satellite package, so you can’t require it with the composer."
But I don't find any dependency to this plugin in satellite main repository.
I solve it by require it manually: composer require php-etl/rabbitmq-flow
But I guess there is some delay between the current version and the configuration.
In Kiboko\Component\Flow\RabbitMQ\Rejection
Construct:
public function __construct(
private Client $connection,
private string $stepUuid,
private string $topic,
private ?string $exchange = null,
) {
$this->channel = $this->connection->channel();
$this->channel->queueDeclare(
queue: $this->topic,
passive: false,
durable: true,
exclusive: false,
autoDelete: true,
);
}
When the configuration is like this:
rabbitmq:
host: 127.0.0.1
port: 5672
user: 'guest'
password: 'guest'
vhost: /
topic: product.api_rejects
Configuration seems to be based on the old version of the construct: 38ce28e
Could you tell me the good way to define MQ with Satellite ?
Thank you,
Didier
Use fastmap and nested node "map"
Hello,
We can't use nested nodes with fastmap configuration. This below example can't be executed:
- fastmap:
expression_language:
- 'Kiboko\Component\ExpressionLanguage\Akeneo\AkeneoFilterProvider'
map:
- field: '[translations][en_US]'
expression: 'input'
map:
- field: '[name]'
expression: 'input["identifier"] ~" | "~ attribute(input["values"]["variation_name"], locale("en_US"), scope(null, "ecommerce"))'
- field: '[slug]'
expression: 'input["identifier"]'
- field: '[description]'
expression: 'attribute(input["values"]["description"], locale("en_US"), scope("ecommerce"))'
The error :
Invalid configuration for path "etl.satellite.pipeline.steps.1.fastmap.map.1": Your configuration should either con
tain the "expression" or the "map" field, not both.
It's related to this node part of the configuration:
map:
- field: '[translations][en_US]'
expression: 'input'
map:
I don't find any hints on the code source or in documentation to solve this.
Thank you !
Didier
Order of load method arguments
Hello,
I have a trouble with the load method :
while (true) {
$this->channel->publish(
\json_encode($line, JSON_THROW_ON_ERROR),
[
'content-type' => 'application/json',
],
$this->topic,
$this->exchange,
);
$line = yield new AcceptanceResultBucket($line);
}
The publish method :
public function publish($body, array $headers = [], $exchange = '', $routingKey = '', $mandatory = false, $immediate = false)
The topic and exchange arguments are reversed.
Thank you,
Geoffrey
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.