...
public class MyClass {
@Inject
MessageQueueProvider mqProvider;
...
protected void myMethod() {
try {
var myProducer = mqProvider.getProducer();
...
}
}
Sending a message
Async Messages
producer.asyncSend(newMessage,
(message) -> messageSuccessHandler(message),
(message, exception) -> messageFailureHandler(message, exception));