The Author Online Book Forums are Moving

The Author Online Book Forums will soon redirect to Manning's liveBook and liveVideo. All book forum content will migrate to liveBook's discussion forum and all video forum content will migrate to liveVideo. Log in to liveBook or liveVideo with your Manning credentials to join the discussion!

Thank you for your engagement in the AoF over the years! We look forward to offering you a more enhanced forum experience.

339950 (3) [Avatar] Offline
#1
Hi!

I have a very basic flow in which I am trying to achieve redelivery of the messages in case ActiveMQ is down.
The flow is as below. Currently I am testing it manually by bringing down ActiveMQ, then submitting the request and then bringing ActiveMQ up again and checking on the ActiveMQ console if message was lost (which it was). I am not sure how to use persistence on JMS. Any help would be appreciated.

<?xml version="1.0" encoding="UTF-8"?>

<mule xmlns:context="http://www.springframework.org/schema/context" xmlns:jms="http://www.mulesoft.org/schema/mule/jms" xmlns:http="http://www.mulesoft.org/schema/mule/http" xmlns="http://www.mulesoft.org/schema/mule/core" xmlns:doc="http://www.mulesoft.org/schema/mule/documentation"
xmlns:spring="http://www.springframework.org/schema/beans" version="CE-3.5.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-current.xsd
http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd
http://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd
http://www.mulesoft.org/schema/mule/jms http://www.mulesoft.org/schema/mule/jms/current/mule-jms.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
<jms:activemq-connector name="jmsConnector" specification="1.1" brokerURL="tcp://localhost:61616" validateConnections="true" doc:name="Active MQ" />
<context:property-placeholder location="dev.properties"/>
<flow name="queueupMemberRegistrationMessages" doc:name="queueupMemberRegistrationMessages">
<http:inbound-endpoint exchange-pattern="one-way" host="${inbound_host}" port="${inbound_port}" path="registration" doc:name="HTTP"/>
<byte-array-to-string-transformer doc:name="Byte Array to String"/>
<logger level="INFO" doc:name="Logger"/>
<jms:outbound-endpoint queue="registration" connector-ref="jmsConnector" doc:name="JMS" />
</flow>
</mule>

Regards,
Mohib
339950 (3) [Avatar] Offline
#2
Any one!!!???
David Dossot (233) [Avatar] Offline
#3
This forum is for questions related to Mule in Action, Second Edition and its related source code.

General questions should be asked on MuleSoft forums or StackOverflow.
339950 (3) [Avatar] Offline
#4
Oops. Sorry about that. I will post it on SO