31 Ağustos 2021 Salı

SpringJMS Kullanımı

Giriş
Producer ve Consumer arasındaki kullanılacak mesaj formatını belirlenir. 
- JSON seçilebilir.
Bu durumda Producer şöyledir
Gson gson = new Gson();
String jsonPerson = gson.toJson(person);

jmsTemplate.convertAndSend(destinationTopic, jsonPerson);
Bu durumda Consumer şöyledir
@JmsListener(...)
public void listen(String mensagem) {
  Person person = new Person();
  try {
    Gson gson = new Gson();
    person = gson.fromJson(mensagem, Person.class);
    ...
  }catch(Exception e){
    ...
  }
}

Producer
1. @EnableJms tanımlanır
2. ActiveMQConnectionFactory bean yaratılır
2. JmsTemplate bean yaratılır

Consumer
1. @EnableJms tanımlanır
2. ActiveMQConnectionFactory bean yaratılır
3. JmsListenerContainerFactory  bean yaratılır. Bu arayüzü gerçekleştiren sınıf DefaultJmsListenerContainerFactory 
4. @JmsListener ile mesajları işleyecek kod belirtilir.


Hiç yorum yok:

Yorum Gönder