spring-jms

    0

    1답변

    IBM MQ에 대해 구성된 DefaultMessageListenerContainer가 있습니다. sessionTransacted 속성이 true로 설정됩니다. 리스너 내에서 JMSTemplate을 사용하여 다른 MQ 서비스를 호출하지만 sessionTransacted가 true로 설정되어 JMSTemplate 호출이 끝까지 통과되지 않아 응답을받지 못합니다

    0

    1답변

    //이 (나는 그것의 잘 공공 무효 sendMessage 첨부를 작업 서버로 메시지를 보내고 곳에서 메시지를 보낼 것입니다 com.google.protobuf.Message 차단됩니다 sendMessage 첨부) { try { createJmsTemplate(); createJmsTemplateReciever(); JmsMessa

    0

    1답변

    ActiveMQ 큐에서 메시지를 수신하기 위해 Spring의 DefaultMessageListenerContainer을 사용하고 있습니다. 이 응용 프로그램은이 큐에 대한 메시지의 유일한 생성자입니다. 응용 프로그램이 클러스터되어 있으므로 두 개의 인스턴스 (instance1, instance2)가 생성되어 instance1에서 메시지를 생성하고 대기열로

    0

    1답변

    Spring은 @JMSListener 주석을 제공하여 특정 대기열의 메시지를 수신합니다. implement JmsListenerConfigurer 대신에 MessageListener을 등록 할 수도 있습니다. 두 경우 모두 큐의 이름은 응용 프로그램이 시작될 때 코드에서 하드 코딩하거나 속성을 통해 알 수 있어야합니다. 시작한 지 얼마 안되어 응용 프로그램

    0

    1답변

    봄 JMS의 DefaultMessageListenerContainer 클래스에는 원하는 변환기를 제공 할 수있는 setter 메서드 setMessageConverter(...)이 있습니다. 우리가 직접 @JmsListener(destination = "myDestination") public void processOrder(MyConvertedType d

    0

    1답변

    버전 5.13.3 사용 - 우리는 db 서버에 activeMQ의 로컬 인스턴스를 생성하여 SQL 서버 데이터베이스에서 대기열로 http 메시지를 전송할 수 있습니다. http 메시지를 받으면 http 메시지 본문에있는 몇 가지 속성을 사용하여 원격 activemq 클러스터로 전송할 새 json 메시지를 작성하려고합니다 (클러스터에 5 개의 인스턴스가있을 것

    1

    1답변

    활성 JMS 브로커를 시작할 때 연결하는 Spring JMS 애플리케이션이 있습니다. JMS 응용 프로그램이 초기화 될 때 대기열에서 소모되기 시작할 때 초기 지연을 설정하는 방법이 있는지 알고 싶습니다. 우리는 봄 4.1.2.RELEASE를 사용하고, 우리는 5.8 감사합니다, 을 활성 MQ를 사용하는 후안

    2

    1답변

    이니셜 라이저를 사용하여 스프링 부트 프로젝트를 만들었으며 처음 메시지를 만들려고했지만 어디서부터 시작해야할지 모르겠습니다. 나는 JEE를 사용하는 동일한 프로세스에 익숙하므로 팩토리, 송신자 및 소비자를 생성해야한다고 생각합니다. 누군가 나를 도울 수 있습니까?

    0

    2답변

    IBM MQ에서 메시지를 읽는 시스템이 있습니다. 이 대기열에서 가끔 데이터가 손상됩니다. 메시지가 다음에 읽 혔을 때 실패하면 청취자는 진행하기 전에 5 분을 기다립니다. 메시지가 3 번 실패하면 백 오프 대기열에 보관됩니다. JMSContainerFacotry는 최대 10 개의 병렬을 실행하도록 설정됩니다. 즉, 큰 메시지의 손상된 메시지를 받으면이 메

    0

    1답변

    Usecase : http 엔드 포인트에서 메시지를 선택하여 jms 엔드 포인트로 라우트하고 싶습니다. 내 경로의 구성은 다음과 같습니다 from("jetty:http://0.0.0.0:9080/quote") .convertBodyTo(String.class) .to("stream:out") .to(InOut, "wmq