consumer

6열

1답변

나는 http://camel.465427.n5.nabble.com/FTP-ConsumerTemplate-Threads-remaining-alive-td5548338.html과 매우 비슷한 문제가 있습니다. 다른 엔드 포인트에서 Camel locked threads를 어떻게 죽입니까? doneUoW를 설정 한 후에 끝점을 제거하고 ConsumerTemplat

0열

3답변

메시지 소비자 구현

메시지 소비자는 항상 듣고 있어야하며 메시지를 확인하고 소비하기 위해 자주 실행되도록 일괄 처리로 설정해야한다고 생각합니다. 기본 예제를 실행할 때 실행되는 독립형 Java 프로그램을 사용합니다. JBoss와 같은 응용 프로그램 서버를 사용하여 실제 웹 응용 프로그램에서 어떻게 구현합니까? 우리는 Spring MVC, Hibernate 및 JBoss를 사용

1열

1답변

C# 웹 서비스 사용 오류

.NET C# 프로젝트에서 아래 WSDL을 사용하여 웹 서비스를 사용하려고합니다. 나는 웹 참조 등을 추가하는 방법 (getPatients)를 호출 시도했지만 항상 오류를 반환했습니다 : (내가 전에 성공적으로 사용했던 동일) 내 코드가 괜찮다고 생각 "MyService.PatientType[] PatientService.getPatients(MyServi

2열

2답변

JMS - 하나의 대기열 및 많은 수신자 (사용자)

제 3 자에 의해 게시 된 JMS 대기열이 있습니다. 특정 컴퓨터의 소비자 한 명과 함께 다른 컴퓨터에 여러 소비자를 설치하고 해당 큐의 메시지를 확인하려고합니다. 즉, 특정 시스템의 소비자가 메시지를받지 못하면 해당 메시지를 대기열에서 제거해서는 안됩니다. 달성 가능합니까?

1열

1답변

akka 낙타 소비자의 autoAck은 무엇을 의미합니까?

akka camel의 autoAck는 true 또는 false를 반환합니다. autoAck = true 인 경우 소비자가 메시지를 소비자의 사서함에 입력했지만 소비자가 메시지를 처리하기 전에 소비자가 어떻게 처리합니까?

0열

1답변

메시지를 처리하기 전 또는 처리하기 전에 akka camel 소비자 dequeue 메시지를 수행합니까?

class MyConsumer1 extends Consumer { def endpointUri = "some protocol string" def receive = { case msg: CamelMessage ⇒ // processing msg } } MyConsumer1은 일반적인 낙타 소비자 형태입니다. 질문

7열

1답변

생산자가 소비자 일 때 생산자/소비자 패턴에서 blockingcollection을 사용하는 방법 - 어떻게 끝내나요?

나는 재귀적인 문제가있다. 소비자는 트리의 각 레벨에서 어떤 일을하고 트리를 되풀이하여 다음 단계에서 똑같은 작업을 수행해야한다. 이것을 병렬로 실행하려면 ConcurrentBag/BlockingCollection 등을 사용하고 싶습니다. 이 시나리오에서 대기열의 사용자는 대기열의 생성자이기도합니다! 내 문제는 다음과 같습니다. BlockingCollect

0열

1답변

일반 Akka 배우와 낙타 소비자 배우의 차이점은 무엇입니까?

일반 Akka 액터는 구성 및 프로그래밍 방식으로 설정할 수있는 사서함 및 디스패서 (스레드 풀)와 연결됩니다. 당신은 경로를 통해 정규 배우를 찾을 수 있습니다. 일반 액터에서 메일을 대기열에서 제외하고 메시지 등을 처리합니다. 낙타 소비자 배우에게도 동일한 작업을 수행 할 수 있습니까? 일반 배우와 낙타 소비자 배우의 차이점은 무엇입니까?

7열

2답변

BlockingCollection 다중 소비자

하나의 제작자 스레드와 여러 소비자 스레드로 다음 코드가 있습니다. 여러 소비자가 스레드로부터 안전한지 알고 있습니까? 예를 들어, 스레드 1이 소비되고 그 스레드 2가 병렬로 소비되고 스레드 1에서 사용되는 항목의 값을 변경하는 동안 어떤 기회가 있습니까? 사전에 namespace BlockingColl { public partial class For

7열

1답변

RabbitMQ 소비자 요구시?

메시지를 수신 할 때마다 소비자가 일부 작업을 수행하기를 원합니다. 소비자는 대기열에 24 시간 연중 무휴 "청취"중이거나 적절한 메시지가 수신 된 경우에만 실행되어야합니까?