Download as PDF, PPTX
Uploaded byelliando dias
Enterprise Messaging with Apache ActiveMQ
This document provides an overview of enterprise messaging with Apache ActiveMQ. It discusses what messaging is, describes the core components of Apache ActiveMQ like topics, queues, clients, selectors, wildcards, broker architecture, message persistence, security, transports, failover, wire formats including OpenWire and STOMP, monitoring, testing, visualization tools, prefetch, exclusive consumers, message groups, total ordering, consumer priority, virtual destinations, bridging to other protocols, and includes an example of routing messages with Apache Camel.
In this document
Powered by AI
Introduction to enterprise messaging with Apache ActiveMQ. Covers basic messaging concepts and details on ActiveMQ.
Describes message filtering using selectors with SQL-like syntax and wildcard usage for topic subscriptions.
Introduces broker architecture and methods for message persistence within ActiveMQ.
Discusses security measures and various transport protocols using URIs in ActiveMQ.
Explains the failover configuration for ActiveMQ, ensuring message delivery reliability.
Introduces wire formats like OpenWire and STOMP, detailing each format’s benefits for messaging.
Detailed commands and examples for connecting, sending, subscribing, and receiving messages using STOMP.
Further exploration of broker architecture in message queuing systems.
Discusses the various types of connectors and messages topologies used in ActiveMQ.
Explains clustering options with Master/Slave configurations to enhance scalability and reliability.
Presents advanced features such as monitoring, unit testing, message groups, and visualizations.Demonstrates how to integrate ActiveMQ with other protocols through Camel with practical examples.
Provides URLs for further information and concludes with a session for questions.
Enterprise Messaging with Apache ActiveMQ
- 1. Enterprise Messaging with Apache ActiveMQ James Strachan http://macstrac.blogspot.com/ http://open.iona.com/
- 2.
- 3.
- 4.
- 5.
- 6. What is ApacheActiveMQ?
- 7. What is ApacheActiveMQ http://activemq.apache.org/
- 8. Clients C Java Pike C++ JavaScript Python C#/.NET Perl Ruby Flash PHP Smalltalk
- 9. Selectors • Provide contentbased filtering on messages using SQL 92 syntax • Customer = ‘gold’ and product in (1, 2, 3) and JMSPriority > 5 • Supports XPath on the message body for XML messages
- 10.
- 11.
- 12.
- 13.
- 14.
- 15. URIs <protocol>://<host>:<port>?<transport-options> Examples tcp://localhost:61616 vm://localhost?broker.persistent=false
- 16.
- 17.
- 18. Wire Formats: OpenWire •binary •smalland fast •code generated marshalling in C, C++, C# and Java •a fair amount of work to port to other languages
- 19. Wire Formats: STOMP •text based for the headers like HTTP • very easy to create a client in any language • tons of clients in most popular programming languages
- 20. Stomp : Connecting CONNECT login:<username> passcode:<passcode> ^@
- 21. Stomp : Sending SEND destination:/queue/orders.books reply-to:/temporaryQueue/James correlation-id:4324234 amazonSecurityToken:abc234 amazonCustomerRating:gold <order id=“123” customer=“jstrachan”> <book isin=“1234”/> <book isin=“456”/> </order> ^@
- 22. Stomp: Subscribe SUBSCRIBE destination:/queue/orders.books ^@
- 23. Stomp : Receivemessages MESSAGE destination:/queue/orders.books Message-id:abc123 reply-to:/temporaryQueue/james134 This is the message ^@
- 24.
- 25.
- 26.
- 27.
- 28.
- 29. Clustering with Master/ Slave •Pure •Shared File System •Shared Database
- 30.
- 31.
- 32. Easy Unit Testingof JMS code ConnectionFactory factory = new ActiveMQConnectionFactory(“vm://localhost?broker.persistent=false”);
- 33.
- 34.
- 35.
- 36.
- 37.
- 38. Consumer Priority new ActiveMQQueue("TEST.QUEUE?consumer.priority=10");
- 39.
- 40.
- 41. Enterprise Integration Patternsvia Camel http://activemq.apache.org/camel/
- 42. Bridge to otherprotocols http://activemq.apache.org/camel/components.html activemq ibatis mail rmi udp activemq.journal imap mina rnc validation bean irc mock rng velocity cxf jdbc msv seda vm direct jetty multicast sftp xmpp event jbi pojo smtp xquery file jms pop string-template xslt ftp jpa quartz timer webdav http log queue tcp
- 43. Example <camelContext xmlns="http://activemq.apache.org/camel/schema/spring"> <route> <from uri="file://quotes"/> <filter> <xpath>/quote/product = ‘widget’</xpath> <to uri="activemq:WidgetQuotes"/> </filter> </route> </camelContext>
- 44. Where do Iget more info? http://activemq.apache.org/
- 45.
- 46. James Strachan blog http://macstrac.blogspot.com/