From version 1.27.0 - Ecotone brings possibility to emit events directly from projections.
This will help with Eventual Consistency problems, as end users will be able to subscribe to projection changes :)
@AHeissenberger_twitter besides the official demo at the end of documentation page, I've create one for you: https://github.com/dgafka/ecotone-emitting-events :)
As you were asking about Event Subscription, you may achieve it fetching the stream directly.
In here, you can find the example how to make use of EventStore Gateway to get fresh events from events that were published by the Projection:
https://github.com/dgafka/ecotone-emitting-events/blob/main/src/ReadModel/NotificationService.php#L17
aggregateType based on class name of an aggregate, I've opened PR introducing an attribute and a mapper which allow to set custom aggregate type the same way as custom stream name. ecotoneframework/event-sourcing#5
3 replies
New feature, projections with state. (Not yet documented) :)
https://github.com/ecotoneframework/quickstart-examples/tree/master/StatefulProjection
In order calculate result without the need for any extra storage and to pass it between Event Handlers.
2 replies
getWrappedConnection() method was not returning expected value. However it was deprecated in all supported versions. Suggested getNativeConnection() method is already returning \PDO instance ecotoneframework/event-sourcing#6
Hi!
When I connect consumer directly to a AMQP Queue (RabbitMQ) is it possible to get some information from message, not only payload ?
For example, routing key ?
class Consumer
{
#[MessageConsumer("consumer")]
public function execute(string $message) : void
{
// do something with Message
// if you have converter registered you can type hint exact type you expect
// $message is eq payload in RAW
// is RabbitMQ's routing key accessible ?
}
}
Exists a way to separate completely aggregates/entities/handlers from PHP Attributes?
I really want to separate my domain from infrastructure calls trying to implant hexagonal, and I know that Doctrine offers alternatives to attributes and annotations, using XML or yaml definitions. I really appreciate if exists, or will exists in the future.
Thanks.
1 reply
From today, you may start using Ecotone Pulse. Solution to manage full life cycle of your error messages.
- Provide way to control error messages for all your services from one place.
- Allows for listing and debugging error messages
- Adds possibility to replay and delete error messages.
Uncaught JMS\Serializer\Exception\RuntimeException: You must define a type for App\Domain\Booking\Event\EventWasCreated::$defaultValues.class EventWasCreated
{
public function __construct(
public readonly int $eventId,
public readonly int $courseId,
public readonly array $defaultValues,
) {
}
}Serialization works but deserialization fails
Fatal error: Uncaught Doctrine\Instantiator\Exception\InvalidArgumentException: The provided class "App\ValueObjects\PublishState" is an enum, and cannot be instantiated in /vendor/doctrine/instantiator/src/Doctrine/Instantiator/Exception/InvalidArgumentException.php:45
3 replies
https://www.baeldung.com/java-axon-multi-entity-aggregates
9 replies
- I have entity "Course" with default values for e.g. maxParticipants.
- A "Course" can have many "Events" which inherit the maxParticipants from "Course"
- The maxParticipant can be overwritten by an event specific value
- when a reservationCommand for an event is placed and the value for maxParticipant have not been overwritten I need to use the value for maxParticipants from Courses
I would like to avoid to place all entities into one big aggregate but the other options are with two aggregate roots:
A) with query - querying the maxParticipant value from course aggregate
- do the business rule which verifies the EventPlaceReservationCommand.
- create 2 events as result: EventMaxParticipantUpdated, EventReservationPlaced
B) saga
an other option would be to create a saga which keeps a list of open events, reacts to all CourseUpdated events, issuing a EventUpdateMaxParticipant Command for all events related to the course
4 replies
https://github.com/ecotoneframework/quickstart-examples/tree/main/MicroservicesAdvanced
Okay, I've stupid question. I'm working on something, suppose that's a store, and I've a Product entity, but what should I do when my entity is going to be too heavy? Should I create a ProductWithPhotos or do something else? It's not necessary to fetching a huge entity when I want to show only a few informations.
4 replies
Hey,
I am building test support for Ecotone.
Right now, I've support for:
- Isolating message flows (you may target given set of class to run tests for)
- Switching from asynchronous to synchronous message handlers only for test scenario
- Possibility to spy messages (which events were sent to command/query/event bus)
- enabling in memory repositories (in progress)
Can you tell me what would helpful for you when writing tests?
5 replies
Hello Dariusz, I'm trying to follow the tutorial, but having problems installing ecotone/jms-converter. I'm working from the composer.json provided and am running PHP 8.1.12.
Your requirements could not be resolved to an installable set of packages.
Problem 1
- ecotone/jms-converter[dev-main, v1.x-dev] require symfony/cache ^5.4|^6.1 -> found symfony/cache[v5.4.0-BETA1, ..., 5.4.x-dev, v6.1.0-BETA1, ..., 6.2.x-dev] but the package is fixed to v5.0.11 (lock file version) by a partial update and that version does not match. Make sure you list it as an argument for the update command.
- ecotone/jms-converter 1.53.0 requires ecotone/ecotone 1.53 -> found ecotone/ecotone[1.53.0] but the package is fixed to 1.32.2 (lock file version) by a partial update and that version does not match. Make sure you list it as an argument for the update command.
- ecotone/jms-converter 1.54.x-dev is an alias of ecotone/jms-converter dev-main and thus requires it to be installed too.
- Root composer.json requires ecotone/jms-converter ^1.53 -> satisfiable by ecotone/jms-converter[1.53.0, 1.54.x-dev (alias of dev-main), v1.x-dev].Hey guys,
I was told few times that gitter does not send notifications or there are problems with opening threads, so I decided to move community channel to different medium. I was looking for options for quite some time and I think I found the best one :)
Community channel is moving to #ddd-cqrs-es discord channel. This is a channel where there is a lot of people involved into CQRS, DDD and Event Sourcing. They will be hosting channel for Ecotone Framework :)
Gitter will no be used from now on :)
So please move here: https://discord.com/channels/514783899440775168/1046488555830120649