🚀 Integration Quick Start

1
2
3
4
5
# Start all integration services
docker-compose up -d nats postgres

# Verify services are healthy
docker-compose ps

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
# Create SEA_EVENTS stream
nats stream add SEA_EVENTS \
  --subjects "sea.event.>" \
  --retention limits \
  --max-age 7d \
  --max-bytes 10GB \
  --storage file

# Create default consumer
nats consumer add SEA_EVENTS sea__default \
  --filter "sea.event.>" \
  --ack explicit \
  --wait 120s \
  --max-deliver 20 \
  --pull

1
2
3
4
5
6
# Apply outbox/inbox tables
just db-migrate

# Verify tables exist
psql $DATABASE_URL -c "\dt *outbox*"
psql $DATABASE_URL -c "\dt *inbox*"

1
2
3
4
5
# Start the messaging worker
just run-mq-worker

# In another terminal, start the handler service
just run-handlers

1
2
3
4
5
6
7
8
# Insert an event into the outbox
psql $DATABASE_URL -c "
INSERT INTO outbox_events (id, aggregate_type, aggregate_id, event_type, payload)
VALUES (gen_random_uuid(), 'Test', 'test-1', 'test_created', '{\"message\": \"Hello\"}');
"

# Watch the worker logs
docker logs -f sea-mq-worker

1
2
3
4
# Check stream message count
nats stream info SEA_EVENTS

# Should show: Messages: 1