DataExporter.java

public interface DataExporter {

    void export(List<DataEventMessage> messages);

    default void export(DataEventMessage message) {
        if (message != null) {
            export(List.of(message));
        }
    }
}

JmsExporter.java

@Component
public class JmsExporter implements DataExporter {
    
    private final ObjectMapper objectMapper;

    private JmsTemplate jmsTemplate;

    private String queue;

    public JmsExporter() {
        this.objectMapper = JacksonUtil.createObjectMapper();
    }

    @Override
    public void export(final List<DataEventMessage> messages) {
        for (var message : messages) {
            try {
                jmsTemplate.convertAndSend(queue, objectMapper.writeValueAsString(message));
            } catch (JsonProcessingException jpe) {
                throw new IllegalStateException("Unable to convert message to JSON", jpe);
            }
        }
    }

    @Autowired
    public JmsExporter setJmsTemplate(final JmsTemplate jmsTemplate) {
        this.jmsTemplate = jmsTemplate;
        return this;
    }

    @Autowired
    public JmsExporter setQueue(@Value("${foo.export.queue}") final String queue) {
        this.queue = queue;
        return this;
    }
}