Message Queue Adapters
Overview
Message queue adapters enable asynchronous, reliable messaging between webMethods Integration Server and various messaging systems. These adapters support publish-subscribe patterns, guaranteed delivery, and distributed messaging architectures.
Apache Kafka
- WmKafkaAdapter - Apache Kafka streaming platform adapter | Registry: licensed | Versions: 15
IBM MQ
- WmMQAdapter - IBM MQ (formerly WebSphere MQ) adapter | Registry: licensed | Versions: 9
Microsoft MSMQ
- WmMSMQAdapter - Microsoft Message Queue adapter | Registry: licensed | Versions: 2
Key Characteristics
- Asynchronous Communication: Decouple producers and consumers
- Guaranteed Delivery: Ensure messages are not lost
- Scalability: Handle high message volumes
- Reliability: Built-in retry and error handling
- Message Ordering: Maintain sequence when required
- Transaction Support: Coordinate with other resources
Use Cases
When to Use Kafka Adapter
- Event Streaming: Real-time data pipelines and streaming analytics
- Log Aggregation: Centralized logging from multiple sources
- Microservices Communication: Event-driven architectures
- High Throughput: Millions of messages per second
- Data Integration: Connect multiple systems with event streams
- Most actively maintained (15 versions)
When to Use IBM MQ Adapter
- Enterprise Messaging: Mission-critical business transactions
- Legacy Integration: Connect to existing IBM MQ infrastructure
- Guaranteed Delivery: When message loss is unacceptable
- Transactional Messaging: Coordinate with databases and other resources
- Mainframe Integration: Connect to z/OS and other IBM platforms
When to Use MSMQ Adapter
- Windows Environments: Native Windows messaging
- Local Queuing: On-premises message queuing
- Simple Messaging: Straightforward queue-based communication
- .NET Integration: Connect with .NET applications
Common Patterns
- Event-Driven Architecture: React to business events in real-time
- Load Leveling: Buffer requests during traffic spikes
- Decoupling: Separate producers from consumers
- Fan-out: Distribute messages to multiple consumers
- Request-Reply: Asynchronous request-response patterns
- Dead Letter Handling: Manage failed message processing
Comparison
| Feature |
Kafka |
IBM MQ |
MSMQ |
| Throughput |
Very High |
High |
Medium |
| Persistence |
Disk-based log |
Queue-based |
Queue-based |
| Ordering |
Per-partition |
Per-queue |
Per-queue |
| Scalability |
Horizontal |
Vertical/Horizontal |
Limited |
| Use Case |
Streaming, Analytics |
Enterprise Messaging |
Windows Apps |
| Versions |
15 |
9 |
2 |
Integration Patterns
Kafka Streaming Pipeline
Source System → Kafka Producer → Kafka Topic → Kafka Consumer → Target System
↓
Stream Processing
IBM MQ Request-Reply
Requestor → Request Queue → Service → Reply Queue → Requestor
MSMQ Local Processing
Application → Local Queue → Worker Process → Database
See Also