Sometimes, we got this exception if we try to send messages (i.e producer.send(message)) to the server core queue, and this happens only in few seconds just after the session starts (i.e session.start()). How to solve this issue?
Best Regards~
----------------------------
EDIT:
If I enforce the thread to sleep for period of time (say 5 seconds) just after the session starts (i.e session.start(); Thread.sleep(5000);), then the exception is not raised up anymore!
I just synchronized the access to the producer and everything works fine!
synchronized(producer)
{
producer.send(message);
}