Upgrade hornetq version.
Use the client jar /w activemq.
Support using message listeners to consume messages.