In the previous posts, Spring RabbitMQ applications had produced/consumed String messages. Today, JavaSampleApproach will guide how to send/receive Java object messages with RabbitMQ server.
Related posts:
– RabbitMq – How to create Spring RabbitMq Publish/Subcribe pattern with SpringBoot
– RabbitMQ – How to create Spring RabbitMQ Producer/Consumer applications with SpringBoot
– SpringBoot RabbitMQ Topic Exchange
– SpringBoot RabbitMq Headers Exchange
I. Technologies
– Java 8
– Maven 3.6.1
– Spring Tool Suite: Version 3.8.4.RELEASE
– Spring Boot: 1.5.4.RELEASE
– RabbitMQ
II. RabbitMq – Produce/consume Java object messages
In the tutorial, we create 2 SpringBoot applications {Producer, Consumer} for sending/receiving Java object messages to/from RabbitMQ:
>>> See more at: RabbitMQ – How to create Spring RabbitMQ Producer/Consumer applications with SpringBoot
1. Message Converter
We create a simple Java model:
public class Company {
private String name;
public Company(){}
public Company(String name){
this.name = name;
}
public void setName(String name){
this.name = name;
}
public String getName(){
return this.name;
}
}Then send a Company object to RabbitMQ by segment code:
Company company = new Company("Apple");
amqpTemplate.convertAndSend(exchange, "", company);
And receiving it from Consumer by segment code:
@RabbitListener(queues="${jsa.rabbitmq.queue}")
public void recievedMessage(Company company) {
System.out.println("Recieved Message: " + company);
}
-> Got Exception:
Bean [com.javasampleapproach.rabbitmq.consumer.Consumer@704f1591]
at org.springframework.amqp.rabbit.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:135) ~[spring-rabbit-1.7.3.RELEASE.jar:na]
...
Caused by: org.springframework.messaging.handler.annotation.support.MethodArgumentNotValidException: Could not resolve method parameter at index 0 in public void com.javasampleapproach.rabbitmq.consumer.Consumer.recievedMessage(com.javasampleapproach.rabbitmq.model.Company): 1 error(s): [Error in object 'company': codes []; arguments []; default message [Payload value must not be empty]]
at org.springframework.messaging.handler.annotation.support.PayloadArgumentResolver.resolveArgument(PayloadArgumentResolver.java:119) ~[spring-messaging-4.3.9.RELEASE.jar:4.3.9.RELEASE]
How to resolve it? -> We need a MessageConverter for Producer and Consumer:
@Bean
public MessageConverter jsonMessageConverter(){
return new Jackson2JsonMessageConverter();
}
– Producer: set MessageConverter for rabbitTemplate
public AmqpTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
final RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
rabbitTemplate.setMessageConverter(jsonMessageConverter());
return rabbitTemplate;
}
– Consumer: set MessageConverter for listenerContainerFactory
SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
factory.setMessageConverter(jsonMessageConverter());
2. Bi-Directional Java object messages
Now we change models with more complex structure – Bi-Directional relationship:
– Company:
public class Company {
private String name;
private List products;
public Company(){
}
...
– Product
public class Product {
private String name;
private Company company;
public Product(){
}
...
Init a Company object as below:
Product iphone7 = new Product("Iphone 7");
Product iPadPro = new Product("IPadPro");
List appleProducts = new ArrayList(Arrays.asList(iphone7, iPadPro));
Company apple = new Company("Apple", appleProducts);
iphone7.setCompany(apple);
iPadPro.setCompany(apple);
Then send a message to RabbitMQ again:
producer.produce(apple);
-> We got an Infinite recursion (StackOverflowError) exception:
Caused by: org.springframework.amqp.support.converter.MessageConversionException: Failed to convert Message content
at org.springframework.amqp.support.converter.Jackson2JsonMessageConverter.createMessage(Jackson2JsonMessageConverter.java:212)
...
Caused by: com.fasterxml.jackson.databind.JsonMappingException: Infinite recursion (StackOverflowError) (through reference chain: com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"]->com.javasampleapproach.rabbitmq.model.Company["products"]->java.util.ArrayList[0]->com.javasampleapproach.rabbitmq.model.Product["company"])
at com.fasterxml.jackson.databind.ser.std.BeanSerializerBase.serializeFields(BeanSerializerBase.java:706)
at com.fasterxml.jackson.databind.ser.BeanSerializer.serialize(BeanSerializer.java:155)
Why? -> Beacause of the Bidirectional-Relationships between Company object and Product objects.
>>> See more at: Json Infinite Recursion problem
-> Solution:
We have can refer solutions at How to resolve Json Infinite Recursion problem when working with Jackson.
For preserving Bidirectional-Relationships when deserialize Json strings to Java objects, we can choose a solution with @JsonIdentityInfo, details as below code:
– Company
@JsonIdentityInfo(generator=ObjectIdGenerators.IntSequenceGenerator.class,property="@id", scope = Company.class)
public class Company {
private String name;
private List products;
public Company(){
}
– Produce
@JsonIdentityInfo(generator=ObjectIdGenerators.IntSequenceGenerator.class,property="@id", scope = Product.class)
public class Product {
private String name;
private Company company;
public Product(){
}
III. Practice
We create 2 SpringBoot projects {Producer, Consumer}:
Step to do:
– Create SpringBoot projects
– Create Java models
– Create RabbitMq configuration
– Implement RabbitMq producer/consumer
– Implement sending client
– Run and check results
1. Create SpringBoot projects
Create 2 SpringBoot projects {Producer, Consumer}, then add dependency:
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
<dependency>
<groupId>org.json</groupId>
<artifactId>json</artifactId>
</dependency>2. Create Java models
– Company:
package com.javasampleapproach.rabbitmq.model;
import java.util.List;
import org.json.JSONArray;
import org.json.JSONException;
import org.json.JSONObject;
import com.fasterxml.jackson.annotation.JsonIdentityInfo;
import com.fasterxml.jackson.annotation.ObjectIdGenerators;
@JsonIdentityInfo(generator=ObjectIdGenerators.IntSequenceGenerator.class,property="@id", scope = Company.class)
public class Company {
private String name;
private List products;
public Company(){
}
public Company(String name, List products){
this.name = name;
this.products = products;
}
// name
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
// products
public void setProducts(List products){
this.products = products;
}
public List getProducts(){
return this.products;
}
/**
*
* Show Detail View
*/
public String toString(){
JSONObject jsonInfo = new JSONObject();
try {
jsonInfo.put("name", this.name);
JSONArray productArray = new JSONArray();
if (this.products != null) {
this.products.forEach(product -> {
JSONObject subJson = new JSONObject();
try {
subJson.put("name", product.getName());
} catch (JSONException e) {}
productArray.put(subJson);
});
}
jsonInfo.put("products", productArray);
} catch (JSONException e1) {}
return jsonInfo.toString();
}
} – Product
package com.javasampleapproach.rabbitmq.model;
import com.fasterxml.jackson.annotation.JsonIdentityInfo;
import com.fasterxml.jackson.annotation.ObjectIdGenerators;
@JsonIdentityInfo(generator=ObjectIdGenerators.IntSequenceGenerator.class,property="@id", scope = Product.class)
public class Product {
private String name;
private Company company;
public Product(){
}
public Product(String name){
this.name = name;
}
public Product(String name, Company company){
this.name = name;
this.company = company;
}
// name
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
// products
public void setCompany(Company company){
this.company = company;
}
public Company getCompany(){
return this.company;
}
}3. Create RabbitMq Configuration
For each projects, open application.properties file, configure spring.rabbitmq.*:
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
jsa.rabbitmq.queue=jsa.queue
logging.file=jsa-app.log
For logging in file, under /src/main/resources folder, create a logback-spring.xml file:
<?xml version="1.0" encoding="UTF-8"?>
<configuration>
<include resource="org/springframework/boot/logging/logback/defaults.xml" />
<property name="LOG_FILE" value="${LOG_FILE:-${LOG_PATH:-${LOG_TEMP:-${java.io.tmpdir:-/tmp}}/}spring.log}"/>
<include resource="org/springframework/boot/logging/logback/file-appender.xml" />
<root level="INFO">
<appender-ref ref="FILE" />
</root>
</configuration>3.1 Producer Config
– Create a RabbitMqConfig:
package com.javasampleapproach.rabbitmq.config;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.DirectExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
import org.springframework.amqp.support.converter.MessageConverter;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class RabbitMqConfig {
@Value("${jsa.rabbitmq.queue}")
String queueName;
@Value("${jsa.rabbitmq.exchange}")
String exchange;
@Value("${jsa.rabbitmq.routingkey}")
private String routingkey;
@Bean
Queue queue() {
return new Queue(queueName, false);
}
@Bean
DirectExchange exchange() {
return new DirectExchange(exchange);
}
@Bean
Binding binding(Queue queue, DirectExchange exchange) {
return BindingBuilder.bind(queue).to(exchange).with(routingkey);
}
@Bean
public MessageConverter jsonMessageConverter(){
return new Jackson2JsonMessageConverter();
}
public AmqpTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
final RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
rabbitTemplate.setMessageConverter(jsonMessageConverter());
return rabbitTemplate;
}
}
Note: we create 3 bean {Queue, DirectExchange, Binding} for automatically creating a direct RabbitMq exchange, a queue and binding them together.
3.2 Consumer Config
– Create a RabbitMqConfig:
package com.javasampleapproach.rabbitmq.config;
import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
import org.springframework.amqp.support.converter.MessageConverter;
import org.springframework.boot.autoconfigure.amqp.SimpleRabbitListenerContainerFactoryConfigurer;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class RabbitMqConfig {
@Bean
public MessageConverter jsonMessageConverter(){
return new Jackson2JsonMessageConverter();
}
@Bean
public SimpleRabbitListenerContainerFactory jsaFactory(ConnectionFactory connectionFactory,
SimpleRabbitListenerContainerFactoryConfigurer configurer) {
SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
configurer.configure(factory, connectionFactory);
factory.setMessageConverter(jsonMessageConverter());
return factory;
}
}4. Implement RabbitMq Producer/Consumer
4.1 Implement Producer
package com.javasampleapproach.rabbitmq.producer;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import com.javasampleapproach.rabbitmq.model.Company;
@Component
public class Producer {
@Autowired
private AmqpTemplate amqpTemplate;
@Value("${jsa.rabbitmq.exchange}")
private String exchange;
@Value("${jsa.rabbitmq.routingkey}")
private String routingkey;
public void produce(Company company){
amqpTemplate.convertAndSend(exchange, routingkey, company);
System.out.println("Send msg = " + company);
}
}4.2 Consumer
package com.javasampleapproach.rabbitmq.consumer;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;
import com.javasampleapproach.rabbitmq.model.Company;
@Component
public class Consumer {
@RabbitListener(queues="${jsa.rabbitmq.queue}", containerFactory="jsaFactory")
public void recievedMessage(Company company) {
System.out.println("Recieved Message: " + company);
}
}
5. Implement Sending Client
In SpringBoot main class, use CommandLineRunner to implement a client for producer:
package com.javasampleapproach.rabbitmq;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import com.javasampleapproach.rabbitmq.model.Company;
import com.javasampleapproach.rabbitmq.model.Product;
import com.javasampleapproach.rabbitmq.producer.Producer;
@SpringBootApplication
public class SpringRabbitMqProducerApplication implements CommandLineRunner{
public static void main(String[] args) {
SpringApplication.run(SpringRabbitMqProducerApplication.class, args);
}
@Autowired
Producer producer;
@Override
public void run(String... args) throws Exception {
/*
* Init Java objects
*/
Product iphone7 = new Product("Iphone 7");
Product iPadPro = new Product("IPadPro");
List appleProducts = new ArrayList(Arrays.asList(iphone7, iPadPro));
Company apple = new Company("Apple", appleProducts);
iphone7.setCompany(apple);
iPadPro.setCompany(apple);
/*
* send message to RabbitMQ
*/
producer.produce(apple);
}
}
6. Run and check results
Build and run the SpringBoot projects {Producer, Consumer} with commandlines: mvn clean install, mvn spring-boot:run.
– Go to http://localhost:15672/#/exchanges/%2F/jsa.exchange
-> Checking the automatically creating and binding of RabbitMq exchange jsa.exchange and queue jsa.queue with routingKey jsa.routingkey:
– Checking console logs:
-> From Producer: ‘Send msg = {"name":"Apple","products":[{"name":"Iphone 7"},{"name":"IPadPro"}]}‘
-> From Consumer: ‘Recieved Message: {"name":"Apple","products":[{"name":"Iphone 7"},{"name":"IPadPro"}]}‘
IV. Sourcecode
SpringRabbitMqProducer
SpringRabbitMqConsumer
Hi! Great article!
Question: what if the consumer does not know details of the objects in the queue? I mean, the consumer eclipse project does not have to have the pojos synchronized with the producer project. Could the publisher and suscriber be run in the same application?
Thank you so much! Keep working on making more Spring Boot tutorial.
One of the best best tutorial blog site that i have seen ever
Hey there
Our Medical-Grade Toenail Clippers is the safest and especially recommended for those with troubles with winding nails, hard nails, two nails, nail cracks, deep nails, thickened nails etc..
Get yours: thepodiatrist.online
Thank You,
Wilmer
RabbitMQ – How to send/receive Java object messages with Spring RabbitMq | SpringBoot » ozenero
Good day
Meet your best Buds – True Wireless Earbuds with amazing sound, convenience, portability, & affordability!
Order yours now at 50% OFF with FREE Shipping: musicontrol.online
Regards,
Hattie
RabbitMQ – How to send/receive Java object messages with Spring RabbitMq | SpringBoot » ozenero
Good day
CAREDOGBEST™ – Personalized Dog Harness. All sizes from XS to XXL. Easy ON/OFF in just 2 seconds. LIFETIME WARRANTY.
Click here: caredogbest.com
Many Thanks,
Belinda
RabbitMQ – How to send/receive Java object messages with Spring RabbitMq | SpringBoot » ozenero
Good day
Body Revolution – Medico Postura™ Body Posture Corrector
Improve Your Posture INSTANTLY!
Get it while it’s still 60% OFF! FREE Worldwide Shipping!
Get yours here: medicopostura.com
All the best,
Mellisa
RabbitMQ – How to send/receive Java object messages with Spring RabbitMq | SpringBoot » ozenero
Get The Worlds Greatest Magic Sand Free Beach Mat!
Watch sand, dirt & dust disappear right before your eyes! It’s perfect for beach, picnic, camping or hiking.
Act Now And Receive A Special Discount For Our Magic Mat!
Get Yours Here: magicmat.shop
Best,
Zack
RabbitMQ – How to send/receive Java object messages with Spring RabbitMq | SpringBoot » ozenero
Color-changing swimshorts
Dive into the ocean and your swimshorts suddenly change color! These swimshorts ara AMAZING!
Hurry! 50% Off Worldwide For Limited Time Only!
Get it here: coolshorts.online
Have a great time,
Laurel
Hi there
You need a pair of Quick Dry Beach Shoes, going out shoes, going OUT OUT shoes, trainers, a spare pair of trainers in case it rains…
Act Now And Receive A Special Discount For Our Quick Dry Beach Shoes!
Get Yours Here: tonature.online
All the best,
Kandy
Morning
CAREDOGBEST™ – Personalized Dog Harness. All sizes from XS to XXL. Easy ON/OFF in just 2 seconds. LIFETIME WARRANTY.
Click here: caredogbest.com
Kind Regards,
Mireya
ozenero | Mobile & Web Programming Tutorials
Best view i have ever seen !
Good Morning
Full Body Resistance Band Kit – The best and cheapest athletic gear available on the market today.
Do a full body workout from the comfort of your home. You don’t even need a gym anymore!
Save 50% OFF + FREE Worldwide Shipping
Shop Now: ametathletics.online
Best Wishes,
Christa