activemq

0열

1답변

브로커 주제가 있고 여러 개의 기본 메시지 수신기 또는 간단한 메시지 수신기를 가질 계획입니다. 모든 리스너는 동일한 코드를 실행합니다. 각 리스너 코드는 다른 것과 독립적으로 실행됩니다. 내가 물어 보려고하는 것은 동일한 방법을 사용할 때 청취자들간에 충돌이있을 경우인가? 나는 멀티 스레드 실행과 같이 작동합니다. JMS와 activemq를 중개인으로 사

1열

1답변

가상 토픽의 메시지가 소비자 큐에 의해 소비되지 않음

activemq의 큐를 사용하여 가상 토픽의 메시지를 큐에서 제거하려고합니다. 일부 메시지를 보내려고했지만 "메시지 대기열에 포함"항목 아래에 나타나지만 소비 할 수는 없습니다. 내가 만든 가상 주제 이름은 VirtualTopic.AA이고 소비자의 이름은 Consumer.client1.VirtualTopic.AA입니다. consumer.client1.Vir

-1열

1답변

ActiveMQ : 사용자가 특정 메시지 그룹을 처리하도록 선택되면 그룹화되지 않은 메시지를 가져 오지 않음

우리는 ActiveMQ (5.14.5)를 사용하고 있습니다. 우리는 단일 생산자와 동일한 대기열에있는 여러 소비자를 보유하고 있습니다. 때때로 JMSXGroupID를 설정하여 여러 메시지를 그룹화하여 단일 소비자에서 사용합니다. 이것은 예상대로 작동합니다. 병행 은 생산자가 아닌 그룹화 메시지를 보낼 계속 (즉 JMSXGroupID없이) 문제 : 우리는 소

0열

1답변

내구성이있는 여러 수신기. 그들은 동시에 일합니까?

내 구성 : @Bean public ActiveMQConnectionFactory connectionFactory(){ ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(); connectionFactory.setBrokerURL(DEFAUL

0열

1답변

Camel ActiveMQ 경로에서 Activiti 작업 다시 시작

Activiti Camel 작업에서 ActiveMQ 대기열로 메시지를 보내려고합니다. 대기열을 Camel에서받을 때 다시 시작해야합니다. 내가 이해할 때 메시지가 대기열에서 수신 될 때 Camel이 올바른 활동 작업으로 라우트되도록 식별 할 수있는 특성이 없습니다. 이와 같이 Business key is Null 예외가 발생하고 경로가 실패합니다. 나는 (

2열

1답변

스프린트 부팅의 임베디드 ActiveMQ에 대한 Active MQ RedeliveryPolicy 변경

스프링 부트와 함께 사용할 때 포함 된 ActiveMQ에 대한 재 전달 정책을 변경하는 방법은 무엇입니까? DefaultJmsListenerContainerFactory에서 FixedBackOff를 지정하려고 시도했지만 도움이되지 않았습니다. 아래는 jms factory bean을 초기화하기 위해 사용하는 코드입니다. 큐에 들어오는 메시지를 처리하는 메시지

0열

1답변

Camel ActiveMQ 소비자 연결 로그 사용 안 함

메시지를 사용하려면 Spring DSL을 사용하고 있습니다. 모두 정상적으로 작동합니다. 문제는 연결 확인 모든 5초하고 메시지를 기록합니다 "Successfully connected to ssl://hostname:port" 어떻게 연결 로그를 사용하지?

1열

1답변

Jboss fuse karaf - 활성 mq

Jboss fuse karaf (jboss-fuse-6.3) 및 activeMQ를 처음 사용했습니다. 현재 localhost : 61616에서 activeMq에 액세스하고 있는데, 내 질문에 activeMQ를 사용하는 것이 더 적합합니다 (동일한 호스트 (localhost : port)) 또는 activeMQ를 원격 서버에서 호스팅 할 수 있습니까? 더 빠

-1열

1답변

활성 MQ 메시지 대기열을 제거하는 대안?

Active MQ를 처음 사용하지만 큐가 처리되지 않고 계속 누적되는 경우가 있습니다. 제거하는 것이 좋습니다?, 재 처리를 위해 모든 메시지를 삭제하지 못하도록하는 다른 솔루션이 있습니까? 나는 정말로 대기열을 풀고 싶지 않습니다. 이것이 가능합니까?

0열

1답변

기존 큐를 CompositeQueue로 변환하는 ActiveMQ

가능한 한 최선을 설명하려고합니다. ActiveMQ 큐에서받은 데이터를 여러 위치에 저장하기 때문에 각 큐브마다 데이터를 개별적으로 처리 할 수 있도록 복합 대기열을 작성하기로 결정했습니다. 현재 실행중인 문제는 현재 프로덕션 환경에서 큐가 있음을 나타냅니다. A라는 대기열을 B 및 C라는 가상 목적지가있는 A라고도하는 복합 대기열로 변경하면 기존 대기