81.4. 예제

예를 들어 일련의 메시지가 큐로 전송된 다음 메시지를 손실하지 않고 큐에서 소비되는지 테스트하려면 다음을 수행합니다.

// send the dataset to a queue
from("dataset:foo").to("activemq:SomeQueue");

// now lets test that the messages are consumed correctly
from("activemq:SomeQueue").to("dataset:foo");

// send the dataset to a queue
from("dataset:foo").to("activemq:SomeQueue");

// now lets test that the messages are consumed correctly
from("activemq:SomeQueue").to("dataset:foo");

위의 레지스트리는 메시지를 만드는 데 사용되는 foo retries 인스턴스를 찾기 위해 레지스트리를 찾습니다.

그런 다음 아래에 설명된 바와 같이 SimpleDataSet 을 사용하여 데이터 세트가 얼마나 큰지와 메시지가 어떻게 나타나는지 구성하는 것과 같은 Cryostat 구현을 만듭니다.Then you create a Cryostat implementation, such as using the SimpleDataSet as described below, configuring things like, how big the data set is and what the messages look like etc.