У меня есть требование как:
Сообщения в очереди, скажем, A, должны использоваться двумя разными приложениями. Я пытаюсь реализовать MDB для прослушивания этой очереди и публикации этого сообщения в другой теме, откуда приложения могут использовать.
- Является ли это возможным?
- Доступен ли он как некоторая конфигурация в jboss.. Я заново изобретаю велосипед?
- Любая помощь в этом для достижения..
Код:
@MessageDriven(activationConfig = {
@ActivationConfigProperty(propertyName = "destinationLookup", propertyValue = "queue/test.queue"),
@ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue") })
public class MyListener implements MessageListener {
private JmsTemplate jmsTemplate;
public MyListener(JmsTemplate jmsTemplate) {
this.jmsTemplate = jmsTemplate;
}
public void onMessage(Message message) {
System.out.println("Message received");
// TextMessage textMessage = (TextMessage) message;
publishMessage(message);
System.out.println("Message re-published");
}
Заранее спасибо.