spring-amqp

0열

3답변

CloudFoundry에서 Rabbitmq 서비스를 연결하기 위해 스프링 클라우드 스프링 서비스 커넥터를 사용합니다. public class CloudConfig extends AbstractCloudConfig { @Bean public ConnectionFactory rabbitFactory() { return c

0열

1답변

RabbitMQ Exchange 및 대기열이 자동으로 생성되지 않음

rabbitmq 서버에 메시지를 푸시하는 새 스프링 애플리케이션을 만들었습니다. 내 rabbitMQConfig 자바 파일은 다음과 같다 : 여기 @Configuration public class RabbitMQConfig { private static final Logger LOGGER = LoggerFactory.getLogger(Rabbit

0열

1답변

토끼 리스너 Rabbitmq 노드가 다운되면 항상 소비자를 실행하거나 중지

사용할 수 RabbitMq 서버는 Rabbitmq Exchange를 일부 메시지를 생산 및 토끼와 QUEUENAME에 메시지 기지 Listener.but 큐 스피에는 메시지 항상 점점없는 경우 있음을 소모하고 때 <bean id="rabbitListenerContainerFactory" class="org.springframework.amqp.rabbit.

0열

1답변

RabbitMQ와 Spring을 위해 동적으로 대기열과 독점 소비자/수신기를 등록하는 방법은 무엇입니까?

해결해야 할 다음과 같은 문제가 있습니다. RabbitMQ 메시징을 사용하여 간단한 지연된 다시 시도 메커니즘을 구현하려고합니다. 나는 메시지 전달의 지연을 가져 오는 기반 시설을 가지고있다. 런타임에 지연된 재시도 메커니즘을 활용하고자하는 관심있는 참가자가 많을 수 있습니다. 참석자는 2 개의 세부 정보와 메시지 만 제공하려고합니다. 1. T 초간의 지연

1열

1답변

Spring-Kafka Consumer KafkaListener가 GenericMessage를 Java 객체로 변환 할 수 없습니다.

다음 두 단계를 사용하여 CentOS7 인스턴스의 Confluent-3.3.0 플랫폼에서 실행중인 kafka-rest 서비스를 통해 'InventoryEvent'사용자 정의 Java 유형의 이벤트를 게시합니다. 카프카 받침대 curl -X POST -H "Content-Type:application/vnd.kafka.json.v2+json" --data '

0열

2답변

setMessageListener를 사용하여 리스너 서비스 등록

나는 스프링 AMQP 응용 프로그램을 사용하고 싶지만 리스너 서비스를 등록하는 방법을 알 수없는 것 같습니다. 이것은 내 주석 기반 구성 파일입니다. package com.jerry.configuration; import org.springframework.amqp.core.AmqpAdmin; import org.springframework.amqp.

0열

1답변

Spring Amqp Hibernate 대 Rabbit Transaction Manager

트랜잭션 SimpleMessageListenerContainer를 사용하는 spring-amqp 소비자가 있습니다. 컨테이너에 설정된 TransactionManager는 RabbitTransactionManager입니다. 내 MessageListener는 @Transactional 주석이있는 서비스 메소드를 호출합니다. 봄에는 필자가 저장소와 서비스에 사용

0열

1답변

RabbitMQ는 유형별로 청취자를 구분합니다.

토끼 MQ에 메시지를 나타내는 POJO가 있습니다. 메시지의 유형에 대한 책임이 정수 (그래서 그것의 여부를 update, remove, add과)이 있습니다 : public class Message { private String field1; private String field2; private Integer type;

1열

1답변

런타임시 @RabbitListener를 생성하는 가장 쉬운 방법

런타임시 이것을 구성하는 가장 쉬운 방법은 무엇입니까? @RabbitListener(bindings = @QueueBinding( value = @Queue(value = "providedAtRuntime", durable = "true"), exchange = @Exchange(value = "providedAtRuntime", ignor

0열

2답변

RabbitTemplate.send()는 RabbitMQ에 대한 메시지 전달을 보장합니까?

Spring AMQP를 사용하여 rabbitTemplate.send(message) 메소드를 호출하면 (org.springframework.amqp.rabbit.core.RabbitTemplate 클래스에서) 메시지가 전달되고 RabbitMQ 클러스터에 복제되었는지 확인할 수 있습니까?