Apache Pekko Documentation CQRS
Type to start searching
    apache/incubator-pekko
    apache/incubator-pekko
    • Security Announcements
      • Receiving Security Advisories
      • Reporting Vulnerabilities
      • Security Related Documentation
    • Getting Started Guide
      • Introduction to Apache Pekko
      • Why modern systems need a new programming model
      • How the Actor Model Meets the Needs of Modern, Distributed Systems
      • Overview of Apache Pekko libraries and modules
      • Introduction to the Example
      • Part 1: Actor Architecture
      • Part 2: Creating the First Actor
      • Part 3: Working with Device Actors
      • Part 4: Working with Device Groups
      • Part 5: Querying Device Groups
    • General Concepts
      • Terminology, Concepts
      • Actor Systems
      • What is an Actor?
      • Supervision and Monitoring
      • Actor References, Paths and Addresses
      • Location Transparency
      • Apache Pekko and the Java Memory Model
      • Message Delivery Reliability
      • Configuration
      • Default configuration
    • Actors
      • Introduction to Actors
      • Actor lifecycle
      • Interaction Patterns
      • Fault Tolerance
      • Actor discovery
      • Routers
      • Stash
      • Behaviors as finite state machines
      • Coordinated Shutdown
      • Dispatchers
      • Mailboxes
      • Testing
      • Coexistence
      • Style guide
      • Learning Pekko Typed from Classic
    • Cluster
      • Cluster Usage
      • Cluster Specification
      • Cluster Membership Service
      • Phi Accrual Failure Detector
      • Distributed Data
      • Cluster Singleton
      • Cluster Sharding
      • Cluster Sharding concepts
      • Sharded Daemon Process
      • Multi-DC Cluster
      • Distributed Publish Subscribe in Cluster
      • Reliable delivery
      • Serialization
      • Serialization with Jackson
      • Multi JVM Testing
      • Multi Node Testing
      • Artery Remoting
      • Classic Remoting (Deprecated)
      • Split Brain Resolver
      • Coordination
      • Choosing Pekko Cluster
    • Persistence (Event Sourcing)
      • Event Sourcing
      • Replicated Event Sourcing
      • CQRS
      • Style Guide
      • Snapshotting
      • Testing
      • EventSourced behaviors as finite state machines
      • Schema Evolution for Event Sourced Actors
      • Apache Persistence Query
      • Persistence Query for LevelDB
      • Persistence Plugins
      • Persistence - Building a storage backend
      • Replicated Event Sourcing Examples
    • Persistence (Durable State)
      • Durable State
      • Style Guide
      • CQRS
      • Persistence Query
    • Streams
      • Module info
      • Introduction
      • Streams Quickstart Guide
      • Design Principles behind Apache Pekko Streams
      • Basics and working with Flows
      • Working with Graphs
      • Modularity, Composition and Hierarchy
      • Buffers and working with rate
      • Context Propagation
      • Dynamic stream handling
      • Custom stream processing
      • Futures interop
      • Actors interop
      • Reactive Streams Interop
      • Error Handling in Streams
      • Working with streaming IO
      • StreamRefs - Reactive Streams over the network
      • Pipelining and Parallelism
      • Testing streams
      • Substreams
      • Streams Cookbook
      • Configuration
      • Operators
    • Discovery
      • Module info
      • How it works
      • Discovery Method: DNS
      • Discovery Method: Configuration
      • Discovery Method: Aggregate multiple discovery methods
      • Migrating from Pekko Management Discovery (before 1.0.0)
    • Utilities
      • Logging
      • Circuit Breaker
      • Futures patterns
      • Extending Apache Pekko
    • Other Apache Pekko modules
      • Pekko HTTP
      • Pekko gRPC
      • Pekko Connectors
      • Pekko Kafka Connector
      • Pekko Projections
      • Cassandra Plugin for Pekko Persistence
      • JDBC Plugin for Pekko Persistence
      • R2DBC Plugin for Pekko Persistence
      • Google Cloud Spanner Plugin for Pekko Persistence
      • Apache Pekko Management
    • Package, Deploy and Run
      • Packaging
      • Operating a Cluster
      • Deploying
      • Rolling Updates
    • Project Information
      • Binary Compatibility Rules
      • Scala 3 support
      • Downstream upgrade strategy
      • Modules marked “May Change”
      • IDE Tips
      • Immutability using Lombok
      • Apache Pekko in OSGi
      • Migration Guides
      • Rolling Updates and Versions
      • Issue Tracking
      • Licenses
      • Frequently Asked Questions
      • Books and Videos
      • Example projects
      • Project
    • Pekko Classic
      • Classic Actors
      • Classic Clustering
      • Classic Networking
      • Classic Utilities
    • link Apache Software Foundation
    • link License
    • link Security
    • link Donate
    • link Thanks

    CQRS

    EventSourcedBehaviors along with Pekko Projections can be used to implement Command Query Responsibility Segregation (CQRS). The Microservices with Pekko tutorial explains how to use Event Sourcing and Projections together. For implementing CQRS using DurableStateBehavior, please take a look at the corresponding CQRS documentation.

    Edit this page
    0.0.0+26605-0f20b284+20230301-2309*
    Previous Replicated Event Sourcing
    Next Style Guide
    Copyright © 2022, 2023 The Apache Software Foundation, Licensed under the Apache License, Version 2.0. This product contains significant parts that were originally based on software from Lightbend (Akka). Copyright (C) 2009-2022 Lightbend Inc. <https://www.lightbend.com> Apache Pekko is derived from Akka 2.6.x, the last version that was distributed under the Apache License, Version 2.0 License.
    Powered by Paradox and Paradox Material Theme