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