Worked Examples¶

A separate github repo hosting worked examples of using the library is available:

Mongoose github example repo ¶

The examples in this repository demonstrate various aspects of Mongoose:

These examples range from simple "getting started" tutorials to more complex case studies showing real-world usage patterns.

Five Minute Tutorial - A programmatic approach to configuring a Mongoose server with multiple named event feeds and selective event processing.
Five Minute YAML Tutorial - The same functionality as the Five Minute Tutorial, but using YAML configuration instead of programmatic configuration.
Stream Programming Tutorial - Demonstrates native Fluxtion DataFlow stream programming in Mongoose where lifecycle and feed subscriptions are handled automatically.

Event Source Example - Demonstrates how to create a custom event source by extending the AbstractAgentHostedEventSourceService class, allowing you to generate events at regular intervals.
Event Source Non-Agent Example - Shows how to create a custom event source that manages its own threading using a ScheduledExecutorService instead of relying on the Mongoose agent infrastructure.
Message Sink Example - Illustrates how to create a custom message sink by extending the AbstractMessageSink class, with configurable formatting options for console output.
Service Plugin Example - Demonstrates how to create custom service plugins that can be registered with Mongoose server, including both simple lifecycle services and worker services that run background tasks.

Subscribing to Named Event Feeds - Shows how to subscribe to specific named EventFeeds and ignore others, demonstrating selective event processing.
Data Mapping - Demonstrates how to transform incoming feed events to a different type using value mapping with Function mappers.
Using the Scheduler Service - Shows how to use the built-in SchedulerService for delayed actions, periodic jobs, and scheduled triggers.
Injecting Config into a Processor - Demonstrates how to inject configuration data into event processors for customizable behavior.
Handler Pipe - Shows how to use HandlerPipe for in-VM communication between handlers, enabling message passing patterns.
Object Pool - Demonstrates zero-GC object pooling techniques for high-performance event processing with minimal garbage collection.
Replay - Shows how to implement deterministic replay with ReplayRecord and the data-driven clock for testing and debugging.
Core Pin - Shows how to pin agent threads to specific CPU cores for optimal performance in latency-sensitive applications.
Writing a Custom Event to Invoke Strategy - Demonstrates how to create custom EventToInvokeStrategy implementations for specialized event handling patterns.
Scheduler processAsNewEventCycle - Demonstrates re-entrant publishing with processAsNewEventCycle and SchedulerService.