            messageSource.create1().send(MessageBuilder.withPayload(msgDto).build());
            log.info("Msg to "+messageSource.OUTPUT1 +" published");
            messageSource.create2().send(MessageBuilder.withPayload(msgDto).build());
            log.info("Msg to "+messageSource.OUTPUT2+" published");
        } catch (Exception e) {
            log.error("Blad przekazania wiadomosci do kolejki");
        }
    }
