Red Hat Summit Red Hat Summit지원콘솔개발자평가판 시작연락처

11.5. 사용법

예를 들어 storageAccount 스토리지 계정의 대기열 메시지Queue 에서 메시지 콘텐츠를 가져오려면 다음 스니펫을 사용합니다. 

from("azure-storage-queue://storageAccount/messageQueue?accessKey=yourAccessKey").
to("file://queuedirectory");
Copy to Clipboard Toggle word wrap

11.5.1. 구성 요소 프로듀서에서 평가한 메시지 헤더
링크 복사

Expand
header변수 이름유형작업설명

CamelAzureStorageQueueSegmentOptions

QueueConstants.QUEUES_SEGMENT_OPTIONS

QueuesSegmentOptions

listQueues

큐 나열 옵션

CamelAzureStorageQueueTimeout

QueueConstants.TIMEOUT

기간

All

\{@link RuntimeException}을 초과하는 선택적 타임아웃 값입니다.

CamelAzureStorageQueueMetadata

QueueConstants.METADATA

Map<String,String>

createQueue

큐와 연결할 메타데이터

CamelAzureStorageQueueTimeToLive

QueueConstants.TIME_TO_LIVE

기간

sendMessage

메시지가 큐에 유지되는 기간입니다. 설정되지 않으면 값이 7일로 설정되어 있으면 -1이 전달되면 메시지가 만료되지 않습니다. 이름은 -1 또는 양의 숫자여야 합니다.

CamelAzureStorageQueueVisibilityTimeout

QueueConstants.VISIBILITY_TIMEOUT

기간

sendMessage, receiveMessages, updateMessage

큐에서 메시지가 표시되지 않는 기간의 제한 시간입니다. 설정되지 않으면 기본값은 0으로 설정되고 메시지가 즉시 표시됩니다. 제한 시간은 0초에서 7일 사이여야 합니다.

CamelAzureStorageQueueCreateQueue

QueueConstants.CREATE_QUEUE

boolean

sendMessage

가 true 로 설정되면 메시지를 큐로 보낼 때 큐가 자동으로 생성됩니다.

CamelAzureStorageQueuePopReceipt

QueueConstants.POP_RECEIPT

문자열

deleteMessage, updateMessage

메시지 삭제 또는 업데이트와 일치해야 하는 고유 식별자입니다.

CamelAzureStorageQueueMessageId

QueueConstants.MESSAGE_ID

문자열

deleteMessage, updateMessage

삭제하거나 업데이트할 메시지의 ID입니다.

CamelAzureStorageQueueMaxMessages

QueueConstants.MAX_MESSAGES

정수

receiveMessages,peekMessages

요청된 모든 메시지보다 큐에 메시지가 있는 경우 가져올 최대 메시지 수가 반환됩니다. 비어 있는 메시지 1개만 검색하면 허용되는 범위는 1~32개의 메시지입니다.

CamelAzureStorageQueueOperation

QueueConstants.QUEUE_OPERATION

QueueOperationDefinition

All

실행할 생산자 작업을 지정합니다. 생산자 작업과 관련된 이 페이지의 문서를 참조하십시오.

CamelAzureStorageQueueName

QueueConstants.QUEUE_NAME

문자열

All

큐 이름을 재정의합니다.

11.5.2. 구성 요소 프로듀서 또는 소비자가 설정한 메시지 헤더
링크 복사

Expand
header변수 이름유형설명

CamelAzureStorageQueueMessageId

QueueConstants.MESSAGE_ID

문자열

큐로 전송되는 메시지의 ID입니다.

CamelAzureStorageQueueInsertionTime

QueueConstants.INSERTION_TIME

OffsetDateTime

Message가 Queue에 삽입된 시간입니다.

CamelAzureStorageQueueExpirationTime

QueueConstants.EXPIRATION_TIME

OffsetDateTime

메시지가 만료되고 자동으로 삭제되는 시간입니다.

CamelAzureStorageQueuePopReceipt

QueueConstants.POP_RECEIPT

문자열

이 값은 메시지를 삭제/업데이트하는 데 필요합니다. 이 팝업을 사용하여 삭제가 실패하면 다른 클라이언트가 메시지를 큐에 추가했습니다.

CamelAzureStorageQueueTimeNextVisible

QueueConstants.TIME_NEXT_VISIBLE

OffsetDateTime

메시지가 Queue에 다시 표시될 시간입니다.

CamelAzureStorageQueueDequeueCount

QueueConstants.DEQUEUE_COUNT

long

메시지가 큐에 없는 횟수입니다.

CamelAzureStorageQueueRawHttpHeaders

QueueConstants.RAW_HTTP_HEADERS

HttpHeaders

사용자가 사용할 수 있는 구문이 아닌 httpHeaders를 반환합니다.

11.5.3. 고급 Azure 스토리지 큐 구성
링크 복사

Camel 애플리케이션이 방화벽 뒤에서 실행 중이거나 QueueServiceClient 인스턴스 구성을 더 많이 제어해야 하는 경우 자체 인스턴스를 생성할 수 있습니다. 

StorageSharedKeyCredential credential = new StorageSharedKeyCredential("yourAccountName", "yourAccessKey");
String uri = String.format("https://%s.queue.core.windows.net", "yourAccountName");

QueueServiceClient client = new QueueServiceClientBuilder()
                          .endpoint(uri)
                          .credential(credential)
                          .buildClient();
// This is camel context
context.getRegistry().bind("client", client);
Copy to Clipboard Toggle word wrap

그런 다음 Camel azure-storage-queue 구성 요소 구성에서 이 인스턴스를 참조합니다. 

from("azure-storage-queue://cameldev/queue1?serviceClient=#client")
.to("file://outputFolder?fileName=output.txt&fileExist=Append");
Copy to Clipboard Toggle word wrap

11.5.4. 레지스트리에서 QueueServiceClient 클라이언트 자동 검색
링크 복사

이 구성 요소는 QueueServiceClient console이 레지스트리에 있는지 감지할 수 있습니다. 해당 유형의 유일한 인스턴스인 경우 이 인스턴스가 클라이언트로 사용되며 위의 예제와 같이 uri 매개변수로 정의할 필요가 없습니다. 이 기능은 끝점을 더 스마트하게 구성하는 데 매우 유용할 수 있습니다.

11.5.5. Azure Storage Queue Producer 작업
링크 복사

Camel Azure Storage Queue 구성 요소는 생산자 측에서 다양한 작업을 제공합니다.

서비스 수준에서의 작업

이러한 작업의 경우 accountName 이 필요합니다.

Expand
작업설명

listQueues

지정된 마커부터 필터를 전달하는 스토리지 계정의 큐를 나열합니다.

큐 수준의 작업

이러한 작업의 경우 accountName 및 queueName 이 필요합니다.

Expand
작업설명

createQueue

새 큐를 생성합니다.

deleteQueue

큐를 영구적으로 삭제합니다.

clearQueue

큐의 모든 메시지를 삭제합니다.

sendMessage

Default Producer Operation 은 지정된 Time-to-Live 및 큐에서 메시지가 표시되지 않는 시간 초과 기간을 사용하여 메시지를 보냅니다. 메시지 텍스트는 교환 메시지 본문에서 평가됩니다. 기본적으로 큐가 없으면 먼저 빈 큐가 생성됩니다. 이 설정을 비활성화하려면 config createQueue 또는 header CamelAzureStorageQueueCreateQueue 를 false 로 설정합니다.

deleteMessage

큐에서 지정된 메시지를 삭제합니다.

receiveMessages

대기열에서 최대 메시지 수를 검색하고 시간 초과 기간 동안 다른 작업에서 숨깁니다. 그러나 안정성 이유로 인해 큐에서 메시지를 큐에 추가하지 않습니다.

peekMessages

큐 앞에서 최대 메시지 수까지 메시지를 읽습니다.

updateMessage

큐의 특정 메시지를 새 메시지로 업데이트하고 가시성 타임아웃을 재설정합니다. 메시지 텍스트는 교환 메시지 본문에서 평가됩니다.

이러한 작업을 camel 애플리케이션에 사용하는 방법을 알아보려면 이 페이지의 예제 섹션을 참조하십시오.

11.5.6. 소비자 예
링크 복사

하나의 일괄 처리에서 최대 5개의 메시지가 있는 파일 구성 요소로 큐를 사용하려면 다음과 같이 수행할 수 있습니다. 

from("azure-storage-queue://cameldev/queue1?serviceClient=#client&maxMessages=5")
.to("file://outputFolder?fileName=output.txt&fileExist=Append");
Copy to Clipboard Toggle word wrap

11.5.7. 생산자 작업 예
링크 복사

  • listQueues: 
from("direct:start")
    .process(exchange -> {
      // set the header you want the producer to evaluate, refer to the previous
      // section to learn about the headers that can be set
      // e.g, to only returns list of queues with 'awesome' prefix:
      exchange.getIn().setHeader(QueueConstants.QUEUES_SEGMENT_OPTIONS, new QueuesSegmentOptions().setPrefix("awesome"));
     })
    .to("azure-storage-queue://cameldev?serviceClient=#client&operation=listQueues")
    .log("${body}")
    .to("mock:result");
Copy to Clipboard Toggle word wrap
  • createQueue: 
from("direct:start")
    .process(exchange -> {
      // set the header you want the producer to evaluate, refer to the previous
      // section to learn about the headers that can be set
      // e.g:
      exchange.getIn().setHeader(QueueConstants.QUEUE_NAME, "overrideName");
     })
    .to("azure-storage-queue://cameldev/test?serviceClient=#client&operation=createQueue");
Copy to Clipboard Toggle word wrap
  • deleteQueue: 
from("direct:start")
    .process(exchange -> {
      // set the header you want the producer to evaluate, refer to the previous
      // section to learn about the headers that can be set
      // e.g:
      exchange.getIn().setHeader(QueueConstants.QUEUE_NAME, "overrideName");
     })
    .to("azure-storage-queue://cameldev/test?serviceClient=#client&operation=deleteQueue");
Copy to Clipboard Toggle word wrap
  • clearQueue: 
from("direct:start")
    .process(exchange -> {
      // set the header you want the producer to evaluate, refer to the previous
      // section to learn about the headers that can be set
      // e.g:
      exchange.getIn().setHeader(QueueConstants.QUEUE_NAME, "overrideName");
     })
    .to("azure-storage-queue://cameldev/test?serviceClient=#client&operation=clearQueue");
Copy to Clipboard Toggle word wrap
  • sendMessage: 
from("direct:start")
    .process(exchange -> {
      // set the header you want the producer to evaluate, refer to the previous
      // section to learn about the headers that can be set
      // e.g:
      exchange.getIn().setBody("message to send");
      // we set a visibility of 1min
      exchange.getIn().setHeader(QueueConstants.VISIBILITY_TIMEOUT, Duration.ofMinutes(1));
     })
    .to("azure-storage-queue://cameldev/test?serviceClient=#client");
Copy to Clipboard Toggle word wrap
  • deleteMessage: 
from("direct:start")
    .process(exchange -> {
      // set the header you want the producer to evaluate, refer to the previous
      // section to learn about the headers that can be set
      // e.g:
      // Mandatory header:
      exchange.getIn().setHeader(QueueConstants.MESSAGE_ID, "1");
      // Mandatory header:
      exchange.getIn().setHeader(QueueConstants.POP_RECEIPT, "PAAAAHEEERXXX-1");
     })
    .to("azure-storage-queue://cameldev/test?serviceClient=#client&operation=deleteMessage");
Copy to Clipboard Toggle word wrap
  • receiveMessages: 
from("direct:start")
    .to("azure-storage-queue://cameldev/test?serviceClient=#client&operation=receiveMessages")
    .process(exchange -> {
        final List<QueueMessageItem> messageItems = exchange.getMessage().getBody(List.class);
        messageItems.forEach(messageItem -> System.out.println(messageItem.getMessageText()));
    })
   .to("mock:result");
Copy to Clipboard Toggle word wrap
  • peekMessages: 
from("direct:start")
    .to("azure-storage-queue://cameldev/test?serviceClient=#client&operation=peekMessages")
    .process(exchange -> {
        final List<PeekedMessageItem> messageItems = exchange.getMessage().getBody(List.class);
        messageItems.forEach(messageItem -> System.out.println(messageItem.getMessageText()));
    })
   .to("mock:result");
Copy to Clipboard Toggle word wrap
  • updateMessage: 
from("direct:start")
   .process(exchange -> {
       // set the header you want the producer to evaluate, refer to the previous
       // section to learn about the headers that can be set
       // e.g:
       exchange.getIn().setBody("new message text");
       // Mandatory header:
       exchange.getIn().setHeader(QueueConstants.MESSAGE_ID, "1");
       // Mandatory header:
       exchange.getIn().setHeader(QueueConstants.POP_RECEIPT, "PAAAAHEEERXXX-1");
       // Mandatory header:
       exchange.getIn().setHeader(QueueConstants.VISIBILITY_TIMEOUT, Duration.ofMinutes(1));
    })
    .to("azure-storage-queue://cameldev/test?serviceClient=#client&operation=updateMessage");
Copy to Clipboard Toggle word wrap

11.5.8. 개발 노트(Important)
링크 복사

이 구성 요소를 개발할 때 통합 테스트를 실행하려면 Azure accessKey를 가져와야 합니다. Azure 클라이언트가 마이너 버전 업그레이드에서도 문제를 해결할 수 있으므로 모든 변경 사항을 사용하여 통합 테스트를 실행해야 합니다.In addition to the mocked unit tests you will need to run the integration tests with every change you make or even client upgrade as the Azure client can break things even on minor versions upgrade. 통합 테스트를 실행하려면 이 구성 요소 디렉터리에서 다음 maven 명령을 실행합니다. 

mvn verify -PfullTests -DaccountName=myacc -DaccessKey=mykey
Copy to Clipboard Toggle word wrap

accountName 은 Azure 계정 이름이고 accessKey 는 Azure Portal에서 생성되는 액세스 키입니다.

맨 위로 이동
Red Hat logoGithubredditYoutubeTwitter

자세한 정보

평가판, 구매 및 판매

커뮤니티

Red Hat 문서 정보

Red Hat을 사용하는 고객은 신뢰할 수 있는 콘텐츠가 포함된 제품과 서비스를 통해 혁신하고 목표를 달성할 수 있습니다. 최신 업데이트를 확인하세요.

보다 포괄적 수용을 위한 오픈 소스 용어 교체

Red Hat은 코드, 문서, 웹 속성에서 문제가 있는 언어를 교체하기 위해 최선을 다하고 있습니다. 자세한 내용은 다음을 참조하세요.Red Hat 블로그.

Red Hat 소개

Red Hat은 기업이 핵심 데이터 센터에서 네트워크 에지에 이르기까지 플랫폼과 환경 전반에서 더 쉽게 작업할 수 있도록 강화된 솔루션을 제공합니다.

Theme

© 2025 Red Hat