[Spring JMS] WebSphere MQ : setInhibitGet, setAllowGet
Bonjour,
J'utilise Spring JMS avec Websphere MQ.
Tout fonctionne très bien avec des méthodes comme (j'ai enlevé tous les contrôles) :
Code:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20
| private JmsTemplate jmsTemplate;
public String receive(String queueName) {
Message msg = jmsTemplate.receive(queueName);
TextMessage textMessage = (TextMessage) msg;
if (msg != null) {
return textMessage.getText();
}
return null;
}
public String receiveNoWait(String queueName) {
jmsTemplate.setReceiveTimeout(JmsTemplate.RECEIVE_TIMEOUT_NO_WAIT);
Message msg = jmsTemplate.receive(queueName);
TextMessage textMessage = (TextMessage) msg;
if (msg != null) {
return textMessage.getText();
}
return null;
} |
Auparavant, j'avais implémenté tout ça sans Spring, directement avec les librairies IBM :
Code:
1 2
| import com.ibm.mq.MQQueue;
import com.ibm.mq.MQQueueManager; |
Or il me manque dans JMS certaines implémentations dont j'ai besoin comme :
Code:
1 2 3 4 5 6 7
| public void setInhibitGet(MQQueue queue) throws Exception {
queue.setInhibitGet(MQConstants.MQQA_GET_INHIBITED);
}
public void setAllowGet(MQQueue queue) throws Exception {
queue.setInhibitGet(MQConstants.MQQA_GET_ALLOWED);
} |
qui me permettent d'inhiber ou d'autoriser la lecture dans la queue.
Comment puis-je faire avec Spring JMS ?
Merci.