Skip to main content
Manjiri Shastri 님이 #Message에 질문했습니다

Here is my flow

 

I tried to acknowledged but having "The Consumer is closed " error

 Flow :

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

 <mule 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:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="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:listener-config name="HTTP_Listener_config" doc:name="HTTP Listener config" doc:id="89e0f34b-6b83-4776-99d1-080637d3150b" >

 

<http:listener-connection host="0.0.0.0" port="8081" />

 

</http:listener-config>

 

<jms:config name="JMS_Config" doc:name="JMS Config" doc:id="e8e28a6d-297f-43ae-8f73-699b80d70980" >

 

<jms:active-mq-connection username="admin" password="******" >

 

<jms:caching-strategy >

 

<jms:no-caching />

 

</jms:caching-strategy>

 

<jms:factory-configuration brokerUrl="tcp://localhost:61616" />

 

</jms:active-mq-connection>

 

<expiration-policy maxIdleTime="1000000" timeUnit="MILLISECONDS" />

 

<jms:producer-config timeToLive="100000" />

 

</jms:config>

 

<flow name="consumemessageactivemqFlow" doc:id="d4448da9-afad-46c4-b328-7cf25fcb70e5" >

 

<http:listener doc:name="Listener" doc:id="7af095a3-903b-4cef-bcea-c04744cd8ce9" config-ref="HTTP_Listener_config" path="/consume"/>

 

<jms:consume doc:name="Consume" doc:id="0ed7c1f3-56e8-4a93-9ab6-e0e3c852eb03" config-ref="JMS_Config" destination="test1" ackMode="MANUAL" maximumWait="100000" transactionalAction="NOT_SUPPORTED" target="test" targetValue="#message">

 

<reconnect-forever />

 

<jms:consumer-type >

 

<jms:queue-consumer />

 

</jms:consumer-type>

 

</jms:consume>

 

<logger level="INFO" doc:name="Logger" doc:id="4b81f117-0b1e-490a-a681-dc07b78b7bea" message="#payload"/>

 

<jms:ack doc:name="Ack" doc:id="f1f780d8-67ac-4859-963c-8c9c9edbfc90" ackId="#vars.test.attributes.ackId" />

 

</flow>

 

</mule>

 

 Exception:

 

INFO 2021-04-10 09:39:37,390 [[MuleRuntime].uber.03: [consumemessageactivemq].consumemessageactivemqFlow.CPU_LITE @10875769] [processor: consumemessageactivemqFlow/processors/1; event: 907642f0-99b2-11eb-b7f5-7c76357e16b6] org.mule.runtime.core.internal.processor.LoggerMessageProcessor: 

 

ERROR 2021-04-10 09:39:37,496 [[MuleRuntime].uber.03: [consumemessageactivemq].consumemessageactivemqFlow.CPU_LITE @10875769] [processor: consumemessageactivemqFlow/processors/2; event: 907642f0-99b2-11eb-b7f5-7c76357e16b6] org.mule.runtime.core.internal.exception.OnErrorPropagateHandler: 

 

********************************************************************************

 

Message    : The Consumer is closed

 

Element    : consumemessageactivemqFlow/processors/2 @ consumemessageactivemq:consumemessageactivemq.xml:30 (Ack)

 

Element DSL   : <jms:ack doc:name="Ack" doc:id="f1f780d8-67ac-4859-963c-8c9c9edbfc90" ackId="#vars.test.attributes.ackId"></jms:ack>

 

Error type   : MULE:UNKNOWN

 

FlowStack    : at consumemessageactivemqFlow(consumemessageactivemqFlow/processors/2 @ consumemessageactivemq:consumemessageactivemq.xml:30 (Ack)

0/9000