All geek questions in one place

Spring Integration Time Management JMSTemplate for Time Delay

I have JMS messages sent to the IBM MQ queue if the remote client (I do not control the remote client) does not consume the message in a certain amount of time (say 1 minute) The message should expire (I have an Expire job, "MQ deletes the message" using setExplicitQosEnabled and setTimeToLive on the JMSTemplate), and the sender of the message (My SI Code) must be notified that the message was not delivered to the remote client so that the expired message can be redirected to another queue.

I'm not sure how to implement this template using Spring Integration, especially when messages are sent asynchronously and only correlated with return (MessageID → CorrelationID).

I thought I could have some form:

1) ErrorMessageExceptionTypeRouter, but I need a payload, so I can send the message again, and I'm not sure how to implement it (how to call back from MQ to JMSTemplate or Route to another Queue on Time out and have a secondary route listening to this queue and redirecting)

2) WireTap, but I think that this would mean blocking threads on the sender (request / response model) with a timer that monitors msg removal by the remote client. Again, I'm not sure how to implement this.

Any help on how to best implement the above is much appreciated.

: MQ, JMSTemplate.receiveSelected(destination, messageSelector);, . , , . ( messageID , , TimeToLive). ( ) , . , IBM MQ , : JMSTemplate.receiveSelected(destination, messageSelector); :

org.springframework.jms.InvalidSelectorException: JMSWMQ2008: Failed to open MQ queue ‘MY.TEST.IN'.; nested exception is com.ibm.msg.client.jms.DetailedInvalidSelectorException: JMSWMQ2008: Failed to open MQ queue 'MY.TEST.IN'. JMS attempted to perform an MQOPEN, but WebSphere MQ reported an error. Use the linked exception to determine the cause of this error. Check that the specified queue and queue manager are defined correctly.; nested exception is com.ibm.mq.MQException: JMSCMQ0001: WebSphere MQ call failed with compcode '2' ('MQCC_FAILED') reason '2459' ('MQRC_SELECTOR_SYNTAX_ERROR').

JMSTemplate.receive(destination); .

+4
2

IBM MQ V8 JMSReplyTo ( JoshMc )

jmsTemplate.setTimeToLive(3000l);
jmsTemplate.setExplicitQosEnabled(true);
jmsTemplate.setSessionAcknowledgeMode(Session.AUTO_ACKNOWLEDGE);
jmsTemplate.setDeliveryMode(DeliveryMode.PERSISTENT);
jmsTemplate.setPriority(Message.DEFAULT_PRIORITY);
jmsTemplate.send(destinationName, session -> {
    TextMessage toSend = session.createTextMessage(message)
    toSend.setIntProperty("JMS_IBM_Report_Expiration", 14680064);
    Queue queue = session.createQueue("TEST.EXPIRE.REPORT");
    toSend.setJMSReplyTo(queue);

    return toSend;
});

JMS_IBM_Report_Expiration 14680064 : https://www.ibm.com/support/knowledgecenter/en/SS7K4U_8.0.0/com.ibm.websphere.javadoc.doc/web/apidocs/constant-values.html#com.ibm.websphere.sib.api.jms.ApiJmsConstants.MQRO_EXPIRATION_WITH_FULL_DATA

JAR , MQ .

+3

Source: https://habr.com/ru/post/1681617/

More articles:


All Articles