Fixes #107.

Add guide on testing

Add `assert_correlated/4` test assertion helper

Transient subscriptions

Support process manager routing to multiple instances

Add `EventStore.subscribe/1` to create a transient subscription to events appended to a given st...

Add a section in README for testing scheduled jobs

Replace aggregate lifespan `after_command/1` callback with `after_event/1`

Closes #126.

Test usage of PostgreSQL's `LISTEN` / `NOTIFY` for long running subscription processes.

Starts ...

Retry subscription failures after interval. Defaults to retry every minute.

Defer event handler and process router init until after subscribed

Event store adapter sends a `{:subscribed, subscription}` message once the subscription has succ...

Support distributed dispatch consistency

To prevent clashes between pub/sub and tracking topics.

Used for dispatch with strong consistency for subscription ack's.

Initial implementation uses E...

Event handler `error/3` callback

Passed to event handler `error/3` callback on failure.

Document event handler error handling.

Retry command execution on concurrency error

Retry executing a command if appending events to the aggregate's stream fails with an `{:error, ...

Subscription notification message once successfully subscribed

Connection will be opened for each subscribe request. This reduces the number of permanently ope...

Once the subscription has successfully subscribed to the stream it will send the subscriber a `{...

Link existing events to another stream

Fix: Use IO.warn for compile time warning

Use event linking to populate `$all` stream. This removes the need to special case all stream op...

Fix typo in Read Model Projections.md

Fix typo in Aggregates.md

Use PostgreSQL's NOTIFY/LISTEN for event pub/sub

Schedules are unique per schedule UUID and name.

Ensure command is decoded from map to actual s...

Using PostgreSQL for pub/sub removes need for EventStore to form a cluster of nodes. It can be u...

Include #100 in CHANGELOG

Create PostgreSQL connection for notify test.
Allow short delay for distributed subscription tes...

Listener module is now a cluster singleton so only one PostgreSQL `LISTEN` connection is used pe...

Batch scheduling

```elixir
Scheduler.batch(reservation_id, fn batch ->
batch
|> Scheduler.schedule_once(%Time...

To allow consumers to use `Commanded.Scheduler.schedule_once/3` and `Commanded.Scheduler.schedul...

Feature: Process manager state on error

Remove stream process

Lookup column data type in statement module

Query storage for stream info before each operation (append, read, events stream events).

This changes the tests and add a compile-time warning for error/3
definition.