Open Source
Enterprise Middleware
WSO2 is a leading open-source enterprise middleware provider, delivering software covering API management, integration, identity management, analytics, and IoT. Built for cloud-native deployments, WSO2 products run on-premise, in private clouds, and in hybrid environments.
Main WSO2 Products
Enterprise Integrator
Message brokering, visual tools, integration runtimes, business process modeling and analytics. Graphical drag-and-drop interface.
Enterprise Service Bus
Addresses integration standards, supports all integration patterns, enables interoperability between heterogeneous business applications.
Identity Server
Access management solution — manage the identity, security and privacy of a digital business across all platforms.
API Manager
Full lifecycle API management (like Google Apigee / IBM App Connect). Kubernetes operator converts microservices into managed APIs. Runs anywhere — on-premise, private cloud, hybrid cloud.
IoT Server
Connect and control various devices, create apps, secure devices and data, visualize sensor data and manage events.
Data Analytics Server
Real-time business operations information. Geolocation capabilities and analysis of past and present processes.
WSO2 Enterprise
Service Bus
WSO2 ESB is the main integration engine of WSO2 Enterprise Integrator — a lightweight, component-oriented, Java-based enterprise service bus. It allows developers to integrate services and applications in an easy, efficient and productive manner.
The core concept of the ESB architecture is that you integrate different applications by putting a communication bus between them and then enable each application to talk to the bus. This decouples systems from each other, allowing them to communicate without dependency on or knowledge of other systems on the bus.
When an enterprise uses ESB, only the ESB needs to know how to talk to each application. The applications themselves do not need to be modified. This is far more efficient than point-to-point integration.
It also provides ease of connecting cloud applications using a wide array of cloud connectors ready to be used.
WSO2 Enterprise
Integrator
ESB Profile
Core message mediation, routing and transformation engine
Message Broker
Reliable asynchronous messaging, publish/subscribe patterns
Business Process
BPEL and BPMN process execution and management
Analytics Profile
Real-time monitoring, reporting and dashboards
Integration Studio
Integration Studio is the Eclipse-based visual development environment for building WSO2 integration artifacts — APIs, sequences, proxies, connectors and more.
- Download Integration Studio from wso2.com/integration/integration-studio
- Create a new project: File → New → Integration Project
- Build a REST API: Right Click → New → REST API
- Configure lanes: Default lane and Fault lane for error handling
- Define flows: Multiple flows inside the same API with different contexts
- Add mediators: Drag from Mediators & End-Points palette
- Use connectors: Browse the WSO2 Connectors Store for 200+ pre-built connectors
- Run & test: Deploy on local MI at https://127.0.0.1:9743/
Mediators & Components
Filter Mediator
Evaluates XPath or JSONPath expressions to conditionally route messages along different mediation paths.
DBLookup Mediator
Execute SQL queries against a data source. Example: read JSON from request → query DB → return enriched payload with ID and name.
Validate Mediator
Validates message payload against an XML Schema or JSON Schema before processing continues downstream.
Cache Mediator
Caches responses for repeated identical requests to reduce backend load and improve response times.
Iterate Mediator
Splits a message into multiple smaller messages for parallel processing; aggregates results afterward.
Data Mapper Mediator
Visual data mapping tool for transforming message formats — JSON to XML, XML to CSV, and any combination.
Property Mediator
Read, set or remove properties on the message context. Supports JSONPath (json-eval) and XPath expressions.
Payload Factory
Construct a new message payload using a template with variable substitution from message context properties.
What You Can Build
WSO2 Micro Integrator supports a comprehensive range of enterprise integration patterns and use cases out of the box:
Simple Message Routing
Build and deploy a basic integration in Integration Studio
Build a simple service with WSO2 Integration Studio that routes an incoming HTTP request to a backend service. Use the ESB profile to define a REST API, add a Send mediator pointing to an endpoint, and deploy as a Carbon App.
CRUD RESTful API with Micro Integrator
Expose a database as a RESTful CRUD API
Using WSO2 Micro Integrator, create a full CRUD API backed by a relational database. Define data services with queries for read list, add city, and delete city. Create three resources that execute these queries, then expose them as RESTful endpoints (GET / POST / DELETE).
Retry Logic — 10 Retries on API Failure
Resilient service invocation with retry policy
Build a service that attempts to get data from a REST API and retries up to 10 times if the API is unavailable before returning a failure response. Use an Endpoint with a retry configuration and a Fault Sequence to handle ultimate failure gracefully.
Asynchronous Data Insertion
Message Store + Message Processor pattern
Insert data into an API asynchronously using the Message Store / Message Processor pattern. Define a Message Store (in-memory or JMS), a Message Processor that polls the store and forwards to the backend, and a Message Sequence to prepare the payload before storing.
Periodic Sequence Execution
Scheduled tasks with a Simple Trigger
Run a mediation sequence on a schedule using a Scheduled Task with a Simple Trigger. Define the CRON expression or interval, then point the task to the sequence that should execute. Useful for polling external systems, generating reports or batch processing.
Running Micro Integrator
with Docker
Micro Integrator is a cloud-native distribution of WSO2 Enterprise Integration (EI), designed for containerized environments.
On-premise setup (Windows):
WSO2 API Manager
Full lifecycle API management solution — similar to Google Apigee and IBM App Connect. Incorporates a Kubernetes operator that makes it easy to convert raw microservices into managed APIs. Runs anywhere: on-premise, private cloud, hybrid cloud.
Carbon Management Console — server administration, user management, registry
API Publisher — create, publish, version and manage APIs and API policies
Developer Portal — discover APIs, subscribe, generate tokens and test
WSO2 Streaming
Integrator
WSO2 Streaming Integrator enables streaming ETL, change data capture (CDC), large file processing, and real-time APIs. Connect and realize event-driven architectures with distributed streaming systems such as Kafka, Amazon SQS, and more.
Streaming ETL with CDC
Capture database changes in real-time and transform, enrich, aggregate and route data to downstream systems.
Large File Processing (MFT)
Process large files with Managed File Transfer capabilities — read, transform and write files efficiently at scale.
Event Stream Integration
Connect to Kafka, Amazon SQS, RabbitMQ and more for event-driven, decoupled architectures.
Real-Time APIs
Expose streaming data via WebSocket and SSE endpoints for real-time dashboards and applications.
Visual Tooling (SI Tooling)
GUI designer for building Siddhi applications visually — no need to write code for most streaming tasks.
Monitoring
Built-in dashboards to monitor streams, events, throughput, latency and processing metrics in real-time.
CDC Configuration
Change Data Capture enables capturing database changes (INSERT, UPDATE, DELETE) as events and streaming them to downstream systems in real-time.
SQL Server — Enable CDC
DB2 JDBC Connection
SQL Server JDBC Connection
DB2 — CDC Setup Steps
- Enable the CDC feature at the DB2 instance level
- Enable CDC for the specific database
- Create Capture Control Tables
- Enable CDC on the specific tables to monitor
Stream Processing Pipeline
- Extract — from databases, files, cloud storages, messaging systems
- Cleanse — filter and clean incoming data
- Transform — reshape data formats and structures
- Enrich — augment with additional data from lookups
- Aggregate — group, window, and summarize events
- Correlate — detect patterns across event streams
- Publish — write to DB, file, cloud storage or messaging system
Reference: ei.docs.wso2.com/en/latest/streaming-integrator/guides/use-cases/