툴링 튜토리얼

Red Hat CodeReady Studio를 엽니다.

CodeReady Studio를 처음 시작하면 JBoss 관점에서 열립니다.

그렇지 않으면 이전 CodeReady Studio 세션에서 사용 중인 관점에서 열립니다.

메뉴에서 File → New → Fuse Integration Project 를 선택하여 New Fuse Integration Project 마법사를 엽니다.

프로젝트 이름 필드에 ZooOrderApp 을 입력합니다.

Use default workspace location 옵션을 선택한 상태로 둡니다.

다음을 클릭하여 대상 런타임 선택 페이지를 엽니다.

Karaf에서 Karaf/Fuse 를 선택하고 런타임 시 선택한 None 을 수락합니다.

기본 Apache Camel 버전을 수락합니다.

다음을 클릭하여 고급 프로젝트 설정 페이지를 연 다음 Empty - 블루프린트 DSL 템플릿을 선택합니다.

완료를 클릭합니다.

Fuse Tooling은 Maven 리포지토리에서 다운로드를 시작합니다. 프로젝트를 빌드하는 데 필요한 모든 파일을 Project Explorer 보기에 추가합니다.

CodeReady Studio가 Fuse Integration 관점이 표시되지 않는 경우 현재로 전환할지 여부를 묻는 메시지가 표시됩니다.

예를 클릭합니다.

새 ZooOrderApp 프로젝트가 Fuse 통합 관점에서 열립니다.

ZooOrderApp 프로젝트에는 다음을 포함하여 경로를 생성하고 실행하는 데 필요한 모든 파일이 포함되어 있습니다.

사전 라우팅 컨텍스트를 보려면 편집기 보기에서 블루프린트.xml 파일을 열고 소스 탭을 클릭합니다.

편집기 기본 설정 페이지를 엽니다.

모든 구성 요소 레이블 옵션에 대해 Use ID 값을 선택합니다.

CodeReady Studio Project Explorer 보기에서 테스트 메시지를 포함할 폴더를 생성합니다.

웹 브라우저를 클릭하여 제공된 도구 자습서 리소스 Fuse-tooling-tutorials-jbds-10.3.zip 파일의 위치에 대한 웹 브라우저를 엽니다. https://github.com/FuseByExample/fuse-tooling-tutorials/archive/jbds-10.3.zip

Fuse-tooling-tutorials-jbds-10.3.zip 파일을 ZooOrderApp 프로젝트 작업 공간 외부에 있는 편리한 위치에 다운로드한 다음 압축을 풉니다. 1장. Fuse 툴링 튜토리얼 정보 에 설명된 대로 두 개의 폴더가 포함되어 있습니다.

messages 폴더에서 6개의 XML 파일을 ZooOrderApp 프로젝트의 src/data 폴더에 복사합니다.

소스 탭을 클릭합니다.

XML 파일이 편집기 보기에서 열립니다.

예를 들어 message1.xml 파일의 내용은 Bronx Zoo의 12 wom iqns의 순서를 보여줍니다.

<?xml version="1.0" encoding="UTF-8"?>

<order>
  <customer>
    <name>Bronx Zoo</name>
    <city>Bronx NY</city>
    <country>USA</country>
  </customer>
  <orderline>
    <animal>wombat</animal>
    <quantity>12</quantity>
  </orderline>
</order>

<?xml version="1.0" encoding="UTF-8"?>

<order>
  <customer>
    <name>Bronx Zoo</name>
    <city>Bronx NY</city>
    <country>USA</country>
  </customer>
  <orderline>
    <animal>wombat</animal>
    <quantity>12</quantity>
  </orderline>
</order>

Personlets 'sComponents drawer에서 캔버스로 파일 구성 요소( )를 드래그하고 Route_route1 컨테이너 노드에 놓습니다.

File 구성 요소는 Route _route1 컨테이너 노드 내의 _from 1 노드로 변경합니다.

캔버스에서 From _from1 노드를 선택합니다.

캔버스 아래에 있는 속성 보기는 편집할 노드의 속성 필드를 표시합니다.

메시지 파일의 소스 디렉터리를 지정하려면 속성 보기에서 고급 탭을 클릭합니다.

Directory Name 필드에 src/data 를 입력합니다.

path src/data 는 프로젝트의 디렉터리를 기준으로 합니다.

Consumer 탭에서 확인란을 클릭하여 Noop 옵션을 활성화합니다.

Noop 옵션을 사용하면 message#.xml 파일이 src/data 폴더에서 삭제되지 않도록 하고, idempotency를 통해 각 message#.xml 파일이 한 번만 사용되도록 할 수 있습니다.

세부 정보 탭을 선택하여 파일 노드의 세부 정보 페이지를 엽니다.

툴링은 고급 탭에서 구성한 Directory Name 및 Noop 속성으로 Uri 필드를 자동으로 채웁니다. 또한 자동 생성된 ID(_from1)로 Id 필드를 채웁니다.

자동 생성된 ID 는 그대로 둡니다.

ImageChange의Components drawer에서 다른 File 구성 요소를 드래그하여 Route_route1 컨테이너 노드에 놓습니다.

File 구성 요소는 Route_route1 컨테이너 노드 내의 To_to1 노드로 변경합니다.

캔버스에서 To_to1 노드를 선택합니다.

캔버스 아래에 있는 속성 보기는 편집할 노드의 속성 필드를 표시합니다.

세부 정보 탭에서 다음을 수행합니다.

Route_route1 컨테이너에서 _from1 노드에서 From _from1 노드를 선택하고 To_Received 노드를 통해 해당 커넥터 화살표( )를 드래그한 다음 릴리스하십시오.

캔버스 하단에서 소스 탭을 클릭하여 경로에 대한 XML을 표시합니다.

<?xml version="1.0" encoding="UTF-8"?>

<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.osgi.org/xmlns/blueprint/v1.0.0
    https://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd
    http://camel.apache.org/schema/blueprint
    http://camel.apache.org/schema/blueprint/camel-blueprint.xsd">

    <camelContext id="_context1" xmlns="http://camel.apache.org/schema/blueprint">
        <route id="_route1">
            <from id="_from1" uri="file:src/data?noop=true"/>
            <to id="_Received" uri="file:target/messages/received"/>
        </route>
    </camelContext>
</blueprint>

<?xml version="1.0" encoding="UTF-8"?>

<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.osgi.org/xmlns/blueprint/v1.0.0
    https://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd
    http://camel.apache.org/schema/blueprint
    http://camel.apache.org/schema/blueprint/camel-blueprint.xsd">

    <camelContext id="_context1" xmlns="http://camel.apache.org/schema/blueprint">
        <route id="_route1">
            <from id="_from1" uri="file:src/data?noop=true"/>
            <to id="_Received" uri="file:target/messages/received"/>
        </route>
    </camelContext>
</blueprint>

다음 중 하나:

Project Explorer 에서 ZooOrderApp/Camel Contexts/blueprint.xml :을 선택합니다.

블루프린트.xml 을 마우스 오른쪽 버튼으로 클릭한 다음 Run As → Local Camel Context (Test 제외)를 선택합니다.

콘솔 패널이 열리고 프로젝트 실행 진행 상황을 반영하는 로그 메시지가 표시됩니다. 처음에 Maven은 로컬 Maven 리포지토리를 업데이트하는 데 필요한 리소스를 다운로드합니다. Maven 다운로드 프로세스에는 몇 분이 걸릴 수 있습니다.

출력 끝에 메시지(다음과 유사)가 표시될 때까지 기다립니다. 이러한 메시지는 경로가 성공적으로 실행되었음을 나타냅니다.

...
[Blueprint Event Dispatcher: 1] BlueprintCamelContext INFO  Route: _route1 started and consuming from:Endpoint[file://src/data?noop=true]
[Blueprint Event Dispatcher: 1] BlueprintCamelContext INFO  Total 1 routes, of which 1 are started.
[Blueprint Event Dispatcher: 1]BlueprintCamelContext INFO  Apache Camel 2.21.0.redhat-3 (CamelContext: ...) started in 0.163 seconds
[Blueprint Event Dispatcher: 1] BlueprintCamelContext INFO  Apache Camel 2.21.0.redhat-3 (CamelContext: ...) started in 0.918 seconds

...
[Blueprint Event Dispatcher: 1] BlueprintCamelContext INFO  Route: _route1 started and consuming from:Endpoint[file://src/data?noop=true]
[Blueprint Event Dispatcher: 1] BlueprintCamelContext INFO  Total 1 routes, of which 1 are started.
[Blueprint Event Dispatcher: 1]BlueprintCamelContext INFO  Apache Camel 2.21.0.redhat-3 (CamelContext: ...) started in 0.163 seconds
[Blueprint Event Dispatcher: 1] BlueprintCamelContext INFO  Apache Camel 2.21.0.redhat-3 (CamelContext: ...) started in 0.918 seconds

Project Explorer 에서 target/messages/ 폴더를 찾아서 확장하여 target/messages/received 폴더에 message6.xml ~ message6 .xml 이라는 6개의 메시지 파일이 포함되어 있는지 확인합니다.

message1.xml 을 두 번 클릭하여 경로 편집기의 디자인 탭에서 연 다음 소스 탭을 선택하여 XML 코드를 확인합니다.

<?xml version="1.0" encoding="UTF-8"?>

<order>
  <customer>
    <name>Bronx Zoo</name>
    <city>Bronx NY</city>
    <country>USA</country>
  </customer>
  <orderline>
    <animal>wombat</animal>
    <quantity>12</quantity>
  </orderline>
</order>

<?xml version="1.0" encoding="UTF-8"?>

<order>
  <customer>
    <name>Bronx Zoo</name>
    <city>Bronx NY</city>
    <country>USA</country>
  </customer>
  <orderline>
    <animal>wombat</animal>
    <quantity>12</quantity>
  </orderline>
</order>

Personlets 에서 Routing drawer를 열고 선택 ( ) 패턴을 클릭한 다음 (디케이블 캔버스에서) From_from1 노드를 클릭합니다.

Route_route1 컨테이너가 확장되어 Choice_choice1 노드를 수용할 수 있습니다. 오류 아이콘은 Choice_choice1 노드에 다음에 추가하는 하위 노드가 필요함을 나타냅니다.

라우팅 서랍에서 When ( ) 패턴을 클릭한 다음 캔버스에서 Choice_choice1 노드를 클릭합니다.

Choice_choice1 컨테이너는 When_when1 노드를 수용하도록 확장됩니다.

When_when1 노드를 데코레이션하면 하나 이상의 필수 속성 값을 설정해야 함을 나타냅니다.

캔버스에서 When_when1 노드를 선택하여 속성 보기에서 해당 속성을 엽니다.

테스트 메시지가 XML로 작성되므로 xpath ( XML 쿼리 언어의 경우)를 선택합니다.

들여쓰기된 표현식 필드에 /order/orderline/quantity/text() > 10을 입력합니다.

이 표현식은 quantity 필드의 값이 10보다 큰 메시지만 경로에서 이 경로를 이동하도록 지정합니다(InvalidOrders 폴더).

나머지 속성을 각각 그대로 둡니다.

소스 탭을 클릭하여 경로에 대한 XML을 확인합니다.

캔버스에서 When_when1 노드를 클릭합니다.

When_when1 컨테이너가 확장되어 Log_log1 노드를 수용합니다.

메시지 필드에 입력: 요청된 수량이 허용되는 최대 허용 수를 초과하여 고객에게 문의합니다.

캔버스에서 Log_log1 노드를 클릭합니다.

When_when1 컨테이너가 확장되어 SetHeader_setHeader1 노드를 수용합니다.

캔버스에서 SetHeader_setHeader1 노드를 선택하여 속성 뷰에서 속성을 엽니다.On the canvas, select the SetHeader_setHeader1 node to open its properties in the Properties view:

나머지 속성은 그대로 둡니다.

캔버스에서 SetHeader_setHeader1 노드를 클릭합니다.

When_when1 컨테이너가 확장되어 To_to1 노드를 수용할 수 있습니다.

캔버스에서 To_to1 노드를 선택하여 속성 뷰에서 속성을 엽니다.On the canvas, select the To_to1 node to open its properties in the Properties view:

세부 정보 탭에서 directoryName 을 Uri 필드에 target/messages/invalidOrders 로 바꾸고 Id 필드에 _Invalid 를 입력합니다.

소스 탭을 클릭하여 경로에 대한 XML을 확인합니다.

캔버스에서 Choice_choice1 컨테이너를 클릭합니다.

Choice_choice1 컨테이너가 확장되어 otherwise_otherwise1 노드를 수용할 수 있습니다.

Id 필드에서 _otherwise1 을 _elseValid:로 변경합니다.

캔버스에서 otherwise _elseValid 노드를 클릭합니다.

otherwise -elseValid 컨테이너는 Log_log2 노드를 수용하도록 확장됩니다.

Message 필드에 This is a valid order - OK to process를 입력합니다.

나머지 속성은 그대로 둡니다.

캔버스에서 Log_log2 노드를 클릭합니다.

Otherwise_elseValid 컨테이너는 SetHeader_setHeader2 노드를 수용하도록 확장됩니다.

참고

다이어그램이 혼잡될 때 컨테이너를 축소하여 공간을 확보할 수 있습니다. 이렇게 하려면 축소할 컨테이너를 선택한 다음 버튼을 클릭합니다.

컨테이너를 다시 열려면 컨테이너를 선택한 다음 버튼을 클릭합니다.

디자인 탭에서 컨테이너를 분리하고 확장해도 라우팅 컨텍스트 파일에 영향을 미치지 않습니다. 변경되지 않은 상태로 유지됩니다.

나머지 속성은 그대로 둡니다.

캔버스에서 SetHeader_setHeader2 노드를 클릭합니다.

Otherwise_elseValid 컨테이너는 To_to1 노드를 수용하도록 확장됩니다.

URI 필드에서 directoryName 을 target/messages/validOrders 로 바꾸고 Id 필드에 _Valid 를 입력합니다.

라우팅 컨텍스트 파일을 저장합니다.

완료된 콘텐츠 기반 라우터는 다음과 같아야 합니다.

캔버스 왼쪽 하단에서 소스 탭을 클릭하여 경로에 대한 XML을 표시합니다.

<?xml version="1.0" encoding="UTF-8"?>
<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.osgi.org/xmlns/blueprint/v1.0.0
    https://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd
    http://camel.apache.org/schema/blueprint
    http://camel.apache.org/schema/blueprint/camel-blueprint.xsd">

<camelContext id="_context1" xmlns="http://camel.apache.org/schema/blueprint">
        <route id="_route1">
            <from id="_from1" uri="file:src/data?noop=true"/>
            <choice id="_choice1">
                <when id="_when1">
                    <xpath>/order/orderline/quantity/text() &gt; 10</xpath>
                    <log id="_log1" message="The quantity requested exceeds the maximum allowed - contact customer."/>
                    <setHeader headerName="Destination" id="_setHeader1">
                        <constant>Invalid</constant>
                    </setHeader>
                    <to id="_Invalid" uri="file:target/messages/invalidOrders"/>
                </when>
                <otherwise id="_elseValid">
                    <log id="_log2" message="This is a valid order - OK to process."/>
                    <setHeader headerName="Destination" id="_setHeader2">
                        <constant>ReadyForDispatcher</constant>
                    </setHeader>
                    <to id="_Valid" uri="file:target/messages/validOrders"/>
                </otherwise>
            </choice>
        </route>
    </camelContext>
</blueprint>

<?xml version="1.0" encoding="UTF-8"?>
<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.osgi.org/xmlns/blueprint/v1.0.0
    https://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd
    http://camel.apache.org/schema/blueprint
    http://camel.apache.org/schema/blueprint/camel-blueprint.xsd">

<camelContext id="_context1" xmlns="http://camel.apache.org/schema/blueprint">
        <route id="_route1">
            <from id="_from1" uri="file:src/data?noop=true"/>
            <choice id="_choice1">
                <when id="_when1">
                    <xpath>/order/orderline/quantity/text() &gt; 10</xpath>
                    <log id="_log1" message="The quantity requested exceeds the maximum allowed - contact customer."/>
                    <setHeader headerName="Destination" id="_setHeader1">
                        <constant>Invalid</constant>
                    </setHeader>
                    <to id="_Invalid" uri="file:target/messages/invalidOrders"/>
                </when>
                <otherwise id="_elseValid">
                    <log id="_log2" message="This is a valid order - OK to process."/>
                    <setHeader headerName="Destination" id="_setHeader2">
                        <constant>ReadyForDispatcher</constant>
                    </setHeader>
                    <to id="_Valid" uri="file:target/messages/validOrders"/>
                </otherwise>
            </choice>
        </route>
    </camelContext>
</blueprint>

프로젝트 루트 노드(ZooOrderApp)에서 target/messages/ 폴더를 찾아 확장합니다.

target/messages/invalidOrders 폴더에 message1.xml 및 message3.xml 이 포함되어 있는지 확인합니다.

이러한 메시지에서 quantity 요소의 값은 10을 초과합니다.

target/messages/validOrders 폴더에 유효한 주문이 포함된 4개의 메시지 파일이 포함되어 있는지 확인합니다.

캔버스에서 Route_route1 컨테이너의 오른쪽을 클릭합니다.

경로 패턴은 캔버스의 Route_route2 컨테이너 노드가 됩니다.

캔버스에서 Route_route2 컨테이너를 클릭합니다.

Route_route2 컨테이너는 직접 구성 요소( From_from2 노드)를 수용하도록 확장됩니다.

Uri 필드에서 name ( 직접:)을 OrderFulfillment 로 바꾸고 Id 필드에 _direct:OrderFulfillment 를 입력합니다.

캔버스에서 From _direct:OrderFulfillment 노드를 클릭합니다.

Route_route2 컨테이너가 확장되어 Choice_choice2 노드를 수용합니다.

속성 보기에서 Choice_choice2 노드의 속성을 그대로 둡니다.

캔버스에서 Choice_choice2 노드를 클릭합니다.

Choice_choice2 컨테이너는 When_when2 노드를 수용하도록 확장됩니다.

다음과 같이 When_when2 노드의 속성을 설정합니다.

캔버스에서 When_when/usa 컨테이너를 클릭합니다.

When_when/usa 컨테이너가 확장되어 To_to1 노드를 수용할 수 있습니다.

속성 보기에서 다음을 수행합니다.

캔버스에서 When_when/usa 노드를 클릭합니다.

When_when/usa 컨테이너가 확장되어 SetHeader_setHeader3 노드를 수용합니다.

다음과 같이 노드의 속성을 설정합니다.

캔버스에서 SetHeader 노드를 클릭합니다.

When_when/usa 컨테이너가 확장되어 Log_log3 노드를 수용합니다.

캔버스에서 Log_log3 노드를 선택하여 속성 보기에서 해당 속성을 엽니다.

속성 보기에서 다음을 수행합니다.

파일을 저장합니다.

Route_route2 의 미국 분기는 다음과 같아야 합니다.

캔버스에서 Choice_choice2 컨테이너를 클릭합니다.

Choice_choice2 컨테이너는 otherwise_otherwise1 노드를 수용하도록 확장됩니다.

캔버스에서 otherwise _else/ger 노드를 클릭합니다.

Otherwise_else/ger 컨테이너는 확장되어 SetHeader_setHeader3 노드를 수용합니다.

속성 보기에서 다음을 수행합니다.

캔버스에서 SetHeader_setHead_ger 노드 아래를 클릭합니다.

Otherwise_else/ger 컨테이너는 Log_log3 노드를 수용하도록 확장됩니다. 필요한 경우 Log_log3 노드에서 SetHeader_setHead_ger 노드로 커넥터 오류를 드래그합니다.

속성 보기에서 다음을 수행합니다.

구성 요소 서랍에서 파일 패턴( )을 선택한 다음 Log_ger 노드 아래에서 클릭합니다.

Otherwise_else/ger 컨테이너는 확장되어 To_to1 노드를 수용할 수 있습니다. 필요한 경우 SetHeader_setHead_ger 노드에서 To_to1 노드로 커넥터 오류를 드래그합니다.

속성 보기에서 다음을 수행합니다.

콘솔 출력의 끝을 확인합니다. 다음 행이 표시됩니다.

대상 대상 폴더를 확인하여 경로가 올바르게 실행되었는지 확인합니다.

캔버스에서 Choice_choice1 노드를 선택한 다음 아이콘을 클릭하여 조건 없는 Cryostat를 설정합니다.

다음 Route_Route1 노드에서 unconditional Cryostats를 설정합니다.

다음 Route_Route2 노드에서 unconditional Cryostats를 설정합니다.

message1 이 첫 번째 Cryostat에서 중지되었으므로 _route1 [blueprint.xml]의 _choice 1 변수를 감시 목록에 NodeId 및 RouteId ( Exchange 카테고리의) 및 Message Body 및 CamelFileName 을 추가합니다.

4개의 변수 각각에 대해 다음을 수행합니다.

조사 목록에 변수 Destination 을 추가합니다.

이제 Expressions 뷰에 다음 변수가 포함되어야 합니다.

MessageBody 를 마우스 오른쪽 버튼으로 클릭하여 컨텍스트 메뉴를 열고 값 변경:을 선택합니다.

수량 값을 15 에서 10 으로 변경합니다 (잘못된 주문에서 유효한 주문으로 변경하십시오).

이렇게 하면 메모리 내 값만 변경됩니다( message3.xml 파일을 편집하지 않음).

표현식 보기로 전환하고 MessageBody 변수를 선택합니다.

변수 목록 아래의 창에는 message3 의 전체 본문이 표시되어 현재 주문 항목 값을 쉽게 확인할 수 있습니다.

을 클릭하여 다음 Cryostat로 이동합니다.

To_Invalid 로 이어지는 분기를 따르는 대신message3 은 이제To_Fulfill 및 Route_route2 로 이어지는 분기를 따릅니다.

Breakpoints 뷰로 전환하고 아래에 나열된 Cryostat 옆에 있는 각 확인란의 선택을 해제합니다. _choice1. Cryostat의 확인란을 지우면 임시로 비활성화됩니다.

을 클릭하여 다음 Cryostat로 이동합니다.

디버거는 비활성화된 Cryostat를 건너뛰고 _route1 [blueprint.xml] 에서 _FulFill 로 이동합니다.

를 다시 클릭하여 다음 Cryostat로 이동합니다.

디버거는 _route2 [blueprint.xml]의 _GER 로 이동합니다.

툴 모음에서 을 클릭하여 Camel 디버거를 종료합니다.

ZooOrderApp/target/messages/ 디렉토리를 확장하여 메시지가 예상대로 전달되었는지 확인합니다.

message1 만 invalidOrders 로 전송되었으며 message3.xml 이 유효한Orders/Germany 폴더에 표시됩니다.

툴 모음 오른쪽에 있는 버튼을 클릭한 다음 목록에서 Fuse Integration 을 선택합니다.

Fuse Integration 모드가 기본 레이아웃에서 열립니다.

Cryo stat Navigator 탭을 터미널 탭의 맨 오른쪽으로 끌어 여기에 놓습니다.

이 정렬은 라우팅 컨텍스트의 노드를 그래픽으로 표시하는 데 더 많은 공간을 제공하므로 메시지가 라우팅 컨텍스트를 통과하는 경로를 시각적으로 추적할 수 있습니다.

참고

라우팅 컨텍스트 .xml 파일에 쉽게 액세스할 수 있도록, 특히 프로젝트가 여러 컨텍스트로 구성된 경우 툴링은 Project Explorer 의 Camel 컨텍스트 폴더 아래에 해당 컨텍스트를 나열합니다.

또한 라우팅 컨텍스트의 모든 경로는 컨텍스트 파일 항목 아래에 직접 아이콘으로 표시됩니다. 캔버스의 라우팅 컨텍스트에서 단일 경로를 표시하려면 Project Explorer 에서 해당 아이콘을 두 번 클릭합니다. 라우팅 컨텍스트의 모든 경로를 표시하려면 컨텍스트 파일 항목을 두 번 클릭합니다.

Run as → Local Camel Context(테스트 제외) 를 선택합니다.

Cryo stat Navigator 에서 로컬 프로세스를 확장합니다.

경로의 요소를 확장합니다.

경로 노드를 마우스 오른쪽 버튼으로 클릭한 다음 추적 시작을 선택합니다.

툴에는 Diagram View 에서 라우팅 컨텍스트의 그래픽 표현이 표시됩니다.

모든 메시지 흐름 경로를 명확하게 보려면 Diagram View 탭에 깔끔하게 맞게 노드를 드래그하여 노드를 다시 정렬해야 할 수 있습니다. Diagram View 탭이 확장될 수 있도록 Red Hat CodeReady Studio의 다른 보기 및 탭의 크기를 조정해야 할 수도 있습니다.

Project Explorer 에서 ZooOrderApp/src/data 를 확장하여 메시지 파일(message1.xml through message6.xml)에 액세스할 수 있습니다.

Drag message1.xml 을 사용하여 _context1>Endpoints>file>file>src/data?noop=true 노드에 삭제합니다.

메시지가 경로를 통과하면 툴링은 경로를 추적하여 각 단계에서 통과를 기록합니다.

패널의 메뉴 모음에서 아이콘을 클릭하고 열 구성을 선택하여 열 구성 마법사 를 엽니다.

메시지 뷰에서 항목을 선택하거나 선택 해제하여 항목을 포함하거나 제외할 수 있습니다. 개별 항목을 강조 표시하고 목록에서 위로 이동하거나 아래로 이동하여 메시지 뷰에 표시되는 columnar 순서를 다시 정렬할 수 있습니다.

열 구성 마법사에서 다음과 같이 열을 선택하고 순서를 정렬합니다.In the Configure Columns wizard, select and order the columns this way:

이러한 열과 순서는 메시지 뷰에서 다시 변경할 때까지 유지됩니다.

메시지 보기에서 (새로 고침 버튼)을 클릭하여 뷰를 message2.xml 메시지 추적으로 채웁니다.

에 메시지를 삭제할 때마다 messages View를 새로 고쳐 메시지 추적으로 채워야 합니다.

메시지 추적 중 하나를 클릭하여 속성 보기에서 이에 대한 자세한 정보를 확인합니다.

툴링은 속성 보기의 상단 절반에 메시지 추적(메시지 헤더 포함)에 대한 세부 정보와 속성 뷰의 하단 부분에 메시지 인스턴스의 내용을 표시합니다. 따라서 애플리케이션이 경로 내의 모든 단계에서 헤더를 설정하는 경우 메시지 세부 정보를 확인하여 예상대로 설정되었는지 확인할 수 있습니다.

각 메시지를 강조 표시하여 메시지 인스턴스를 진행하여 특정 메시지가 경로를 통과하는 방법과 경로의 각 단계에서 예상대로 처리되었는지 확인할 수 있습니다.

다이어그램 보기를 열어 경로의 연결된 단계가 강조 표시되었는지 확인합니다.

툴링은 Diagram View 에서 경로를 가져오고 타이밍 및 성능 메트릭(밀리초)을 사용하여 처리 단계를 종료합니다. 다이어그램에는 총 메트릭 교환 만 표시됩니다.

표시된 메트릭 위에 마우스 포인터를 이동하여 메시지 흐름에 대한 추가 지표를 표시합니다.

선택적으로, ZooOrderApp/src/data/ data/의 나머지 메시지를 _context1>Endpoints>file>src/data?noop=true 노드는 추적이 활성화된 상태로 유지되는 한 언제든지 삭제할 수 있습니다.

이후 각 드롭다운에서 (새로 고침 버튼)를 클릭하여 메시지 뷰를 새 메시지 추적으로 채워야 합니다.

완료되면 다음을 수행합니다.

이 튜토리얼을 시작하려면 다음 중 하나에서 생성된 ZooOrderApp 프로젝트가 필요합니다.

Project Explorer 의 ZooOrderApp 프로젝트의 /src/data/ 디렉터리 및 /target/messages/ 하위 디렉터리에서 추적 생성 메시지를 삭제합니다. 추적 생성 메시지는 ID- 접두사로 시작합니다. 예를 들어 그림 9.1. “추적 생성 메시지” 에는 8개의 추적 생성 메시지가 표시됩니다.

그림 9.1. 추적 생성 메시지

일괄 처리로 모든 추적 생성 메시지를 선택하고 마우스 오른쪽 버튼으로 클릭한 다음 삭제 를 선택합니다.

새 폴더 대화 상자의 프로젝트 트리 창에서 ZooOrderApp 노드를 확장하고 src 폴더를 선택합니다.

Enter에 ZooOrderApp/src 가 표시되는지 확인하거나 상위 폴더 필드를 선택합니다.

폴더 이름 에서 /test/java:을 입력합니다.

완료를 클릭합니다.

Project Explorer 에서 새 src/test/java 폴더가 src/main/resources 폴더 아래에 나타납니다.

새 /src/test/java 폴더가 빌드 경로에 포함되어 있는지 확인합니다.

마우스 오른쪽 버튼으로 클릭한 다음 새 → Camel 테스트 케이스 를 선택합니다.

테스트 중인 Camel XML 파일에서 를 클릭하여 XML 파일을 필터링하도록 구성된 파일 탐색기를 연 다음 ZooOrderApp 프로젝트의 블루프린트.xml 파일을 선택합니다.

OK를 클릭합니다. Name 필드의 기본값은 블루프린트Test 입니다.

다음을 클릭하여 Test Endpoints 페이지를 엽니다.

기본적으로 모든 끝점이 선택되며 테스트 사례에 포함됩니다.

완료를 클릭합니다.

Project Explorer 에서 ZooOrderApp 프로젝트를 확장하여 블루프린트 CryostatTest.java 파일을 노출합니다.

굵은 텍스트로 표시된 두 행을 추가합니다. 첫 번째 행을 추가하면 다음 섹션의 지시에 따라 pom.xml 파일을 업데이트할 때 해결되는 오류가 발생합니다.

package tutorial.zooapp.route;

import org.apache.camel.EndpointInject;
import org.apache.camel.Produce;
import org.apache.camel.ProducerTemplate;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.test.blueprint.CamelBlueprintTestSupport;
import org.apache.commons.io.FileUtils;
import org.junit.Test;
import java.io.File;

package tutorial.zooapp.route;

import org.apache.camel.EndpointInject;
import org.apache.camel.Produce;
import org.apache.camel.ProducerTemplate;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.test.blueprint.CamelBlueprintTestSupport;
import org.apache.commons.io.FileUtils;
import org.junit.Test;
import java.io.File;

해당 줄의 protected Object[] expectedBodies={ …​ expectedBody2</something>"}; Cryostat- Cryostat를 이러한 보호된 문자열 본문# 으로 바꿉니다.

protected String body1; protected String body2; protected String body3; protected String body4; protected String body5; protected String body6;

protected String body1; protected String body2; protected String body3; protected String body4; protected String body5; protected String body6;

공용 void testCamelRoute() 줄로 아래로 스크롤하면 Exception { )을 throw하고 그 줄 body# = FileUtils.readFileToString(new File("src/data/message#.xml"), "UTF-8") 을 바로 삽입합니다. 이러한 줄은 다음 섹션에 설명된 대로 pom.xml 파일을 업데이트할 때까지 오류를 나타냅니다.

// Valid orders body2 = FileUtils.readFileToString(new File("src/data/message2.xml"), "UTF-8"); body4 = FileUtils.readFileToString(new File("src/data/message4.xml"), "UTF-8"); body5 = FileUtils.readFileToString(new File("src/data/message5.xml"), "UTF-8"); body6 = FileUtils.readFileToString(new File("src/data/message6.xml"), "UTF-8"); // Invalid orders body1 = FileUtils.readFileToString(new File("src/data/message1.xml"), "UTF-8"); body3 = FileUtils.readFileToString(new File("src/data/message3.xml"), "UTF-8");

// Valid orders body2 = FileUtils.readFileToString(new File("src/data/message2.xml"), "UTF-8"); body4 = FileUtils.readFileToString(new File("src/data/message4.xml"), "UTF-8"); body5 = FileUtils.readFileToString(new File("src/data/message5.xml"), "UTF-8"); body6 = FileUtils.readFileToString(new File("src/data/message6.xml"), "UTF-8"); // Invalid orders body1 = FileUtils.readFileToString(new File("src/data/message1.xml"), "UTF-8"); body3 = FileUtils.readFileToString(new File("src/data/message3.xml"), "UTF-8");

outputEndpoint.expectedBodiesReceivedInAnyOrder(expectedBodies); …​inputEndpoint.sendBody(expectedBody) 로 시작하는 코드 블록을 여기에 표시된 행으로 교체합니다.

// Invalid orders outputEndpoint.expectedBodiesReceived(body1, body3); // Valid orders for USA output3Endpoint.expectedBodiesReceived(body2, body5, body6); // Valid order for Germany output4Endpoint.expectedBodiesReceived(body4);

// Invalid orders outputEndpoint.expectedBodiesReceived(body1, body3); // Valid orders for USA output3Endpoint.expectedBodiesReceived(body2, body5, body6); // Valid order for Germany output4Endpoint.expectedBodiesReceived(body4);

나머지 코드는 그대로 둡니다.

업데이트된 블루프린트 CryostatTest.java 파일에 필요한 수정 사항이 있는지 확인합니다. 다음과 같이 표시됩니다.

package tutorial.zooapp.route;

import org.apache.camel.EndpointInject;
import org.apache.camel.Produce;
import org.apache.camel.ProducerTemplate;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.test.blueprint.CamelBlueprintTestSupport;
import org.apache.commons.io.FileUtils;
import org.junit.Test;
import java.io.file;

public class BlueprintXmlTest extends CamelBlueprintTestSupport {

	// TODO Create test message bodies that work for the route(s) being tested
	// Expected message bodies
	protected String body1;
	protected String body2;
	protected String body3;
	protected String body4;
	protected String body5;
	protected String body6;
	// Templates to send to input endpoints
	@Produce(uri = "file:src/data?noop=true")
	protected ProducerTemplate inputEndpoint;
	@Produce(uri = "direct:OrderFulfillment")
	protected ProducerTemplate input2Endpoint;
	// Mock endpoints used to consume messages from the output endpoints and then perform assertions
	@EndpointInject(uri = "mock:output")
	protected MockEndpoint outputEndpoint;
	@EndpointInject(uri = "mock:output2")
	protected MockEndpoint output2Endpoint;
	@EndpointInject(uri = "mock:output3")
	protected MockEndpoint output3Endpoint;
	@EndpointInject(uri = "mock:output4")
	protected MockEndpoint output4Endpoint;

	@Test
	public void testCamelRoute() throws Exception {
		// Create routes from the output endpoints to our mock endpoints so we can assert expectations
		context.addRoutes(new RouteBuilder() {
			@Override
			public void configure() throws Exception {
				// Valid orders
				body2 = FileUtils.readFileToString(new File("src/data/message2.xml"), "UTF-8");
				body4 = FileUtils.readFileToString(new File("src/data/message4.xml"), "UTF-8");
				body5 = FileUtils.readFileToString(new File("src/data/message5.xml"), "UTF-8");
				body6 = FileUtils.readFileToString(new File("src/data/message6.xml"), "UTF-8");

				// Invalid orders
				body1 = FileUtils.readFileToString(new File("src/data/message1.xml"), "UTF-8");
				body3 = FileUtils.readFileToString(new File("src/data/message3.xml"), "UTF-8");

				from("file:target/messages/invalidOrders").to(outputEndpoint);
				from("file:target/messages/validOrders/USA").to(output3Endpoint);
				from("file:target/messages/validOrders/Germany").to(output4Endpoint);
				from("direct:OrderFulfillment").to(output2Endpoint);
			}
		});

		// Define some expectations

		// TODO Ensure expectations make sense for the route(s) we're testing
		// Invalid orders
		outputEndpoint.expectedBodiesReceived(body1, body3);

		// Valid orders for USA
		output3Endpoint.expectedBodiesReceived(body2, body5, body6);

		// Valid order for Germany
		output4Endpoint.expectedBodiesReceived(body4);

		// Validate our expectations
		assertMockEndpointsSatisfied();
	}

	@Override
	protected String getBlueprintDescriptor() {
		return "OSGI-INF/blueprint/blueprint.xml";
	}

}

package tutorial.zooapp.route;

import org.apache.camel.EndpointInject;
import org.apache.camel.Produce;
import org.apache.camel.ProducerTemplate;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.test.blueprint.CamelBlueprintTestSupport;
import org.apache.commons.io.FileUtils;
import org.junit.Test;
import java.io.file;

public class BlueprintXmlTest extends CamelBlueprintTestSupport {

	// TODO Create test message bodies that work for the route(s) being tested
	// Expected message bodies
	protected String body1;
	protected String body2;
	protected String body3;
	protected String body4;
	protected String body5;
	protected String body6;
	// Templates to send to input endpoints
	@Produce(uri = "file:src/data?noop=true")
	protected ProducerTemplate inputEndpoint;
	@Produce(uri = "direct:OrderFulfillment")
	protected ProducerTemplate input2Endpoint;
	// Mock endpoints used to consume messages from the output endpoints and then perform assertions
	@EndpointInject(uri = "mock:output")
	protected MockEndpoint outputEndpoint;
	@EndpointInject(uri = "mock:output2")
	protected MockEndpoint output2Endpoint;
	@EndpointInject(uri = "mock:output3")
	protected MockEndpoint output3Endpoint;
	@EndpointInject(uri = "mock:output4")
	protected MockEndpoint output4Endpoint;

	@Test
	public void testCamelRoute() throws Exception {
		// Create routes from the output endpoints to our mock endpoints so we can assert expectations
		context.addRoutes(new RouteBuilder() {
			@Override
			public void configure() throws Exception {
				// Valid orders
				body2 = FileUtils.readFileToString(new File("src/data/message2.xml"), "UTF-8");
				body4 = FileUtils.readFileToString(new File("src/data/message4.xml"), "UTF-8");
				body5 = FileUtils.readFileToString(new File("src/data/message5.xml"), "UTF-8");
				body6 = FileUtils.readFileToString(new File("src/data/message6.xml"), "UTF-8");

				// Invalid orders
				body1 = FileUtils.readFileToString(new File("src/data/message1.xml"), "UTF-8");
				body3 = FileUtils.readFileToString(new File("src/data/message3.xml"), "UTF-8");

				from("file:target/messages/invalidOrders").to(outputEndpoint);
				from("file:target/messages/validOrders/USA").to(output3Endpoint);
				from("file:target/messages/validOrders/Germany").to(output4Endpoint);
				from("direct:OrderFulfillment").to(output2Endpoint);
			}
		});

		// Define some expectations

		// TODO Ensure expectations make sense for the route(s) we're testing
		// Invalid orders
		outputEndpoint.expectedBodiesReceived(body1, body3);

		// Valid orders for USA
		output3Endpoint.expectedBodiesReceived(body2, body5, body6);

		// Valid order for Germany
		output4Endpoint.expectedBodiesReceived(body4);

		// Validate our expectations
		assertMockEndpointsSatisfied();
	}

	@Override
	protected String getBlueprintDescriptor() {
		return "OSGI-INF/blueprint/blueprint.xml";
	}

}

다음 행을 < dependencies> 섹션 끝에 추가합니다.

<dependency>
       <groupId>commons-io</groupId>
       <artifactId>commons-io</artifactId>
       <version>2.5</version>
       <scope>test</scope>
</dependency>

<dependency>
       <groupId>commons-io</groupId>
       <artifactId>commons-io</artifactId>
       <version>2.5</version>
       <scope>test</scope>
</dependency>

Run as → JUnit Test 를 선택합니다.

기본적으로 JUnit 뷰가 사이드바에 열립니다. (더 나은 보기를 제공하려면 콘솔 , 서버 및 속성 탭을 표시하는 오른쪽 패널로 드래그하십시오.)

테스트가 성공적으로 실행되면 다음과 같은 내용이 표시됩니다.

그림 9.2. 성공적인 JUnit 실행

테스트가 실패하면 다음과 같은 내용이 표시됩니다.

그림 9.3. 실패한 JUnit 실행

출력을 검사하고 모든 테스트 오류를 해결하기 위해 조치를 취합니다.

JUnit 패널에 표시되는 오류를 더 보려면 패널의 메뉴 모음에서 를 클릭하여 뷰를 극대화합니다.

JUnit 테스트 케이스를 다시 실행하기 전에 Project Explorer 의 ZooOrderApp 프로젝트의 /src/data 폴더에서 JUnit 생성 테스트 메시지를 삭제합니다( 그림 9.1. “추적 생성 메시지”참조).

사용 가능한 서버가 없음을 클릭합니다. 새 서버 정의 페이지를 열려면 이 링크를 클릭하여 새 서버…​ 링크를 생성합니다.

Red Hat JBoss Middleware 노드를 확장하여 사용 가능한 서버 옵션을 노출합니다.

서버의 호스트 이름(localhost) 및 서버 이름 (Fuse n.n Runtime Server)의 기본값을 수락한 다음 Next 를 클릭하여 런타임 페이지를 엽니다.

실행 환경 옆에 있는 드롭다운 메뉴에서 런타임 JRE를 선택합니다.

JavaSE-1.8을 선택합니다(권장). 필요한 경우 환경 버튼을 클릭하여 목록에서 선택합니다.

다음을 클릭하여 Fuse Server의 런타임 정의를 저장하고 Fuse 서버 구성 세부 정보 페이지를 엽니다.

SSH 포트의 기본값(8101)을 수락합니다.

런타임은 SSH 포트를 사용하여 서버의 Karaf 쉘에 연결합니다. 이 기본값이 잘못된 경우 Red Hat Fuse installDir/etc/org.apache.karaf.shell.cfg 파일을 확인하여 올바른 포트 번호를 확인할 수 있습니다.

사용자 이름에 서버에 로그인하는 데 사용되는 이름을 입력합니다.

이는 Red Hat Fuse installDir'/etc/users.properties' 파일에 저장된 사용자 이름입니다.

설정되지 않은 경우 user=password,role (예: joe=secret,Administrator) 형식을 사용하여 파일에 하나를 추가하거나 karaf jaas 명령 세트를 사용하여 설정할 수 있습니다.

암호 에서 사용자 이름에 서버에 로그인하는 데 필요한 암호를 입력합니다.

이는 Red Hat Fuse의 installDir/etc/users.properties 파일 또는 karaf jaas 명령에 설정된 암호입니다.

완료를 클릭합니다.

런타임 서버 [중지, Synchronized] 가 서버 뷰에 나타납니다.

서버 보기에서 런타임 서버를 확장합니다.

Cryostat[Disconnected] 는 Runtime Server [stopped, Synchronized] 항목 아래에 노드로 표시됩니다.

서버의 개요 페이지에서 게시 섹션을 확장하여 옵션을 노출합니다.

리소스 변경이 활성화되면 옵션이 자동으로 게시 되는지 확인합니다.

필요한 경우 게시 간격 값을 변경하여 변경 시 프로젝트 게시 속도를 높이거나 지연할 수 있습니다.

서버가 시작될 때까지 몇 초 정도 기다립니다. 수행 시 다음을 수행합니다.

서버 보기에서n .n 런타임 서버 [시작] 을 마우스 오른쪽 버튼으로 클릭한 다음 추가 및 제거를 선택하여 추가 및 제거를 선택하여 추가 및 제거 페이지를 엽니다.

서버가 시작되면 게시 변경 사항이 즉시 선택됩니다.

ZooOrderApp 을 선택하고 추가 를 클릭하여 Fuse 서버에 할당합니다.

완료를 클릭합니다.

서버 보기에는 다음이 표시되어야 합니다.

Cryostat Navigator 에서 Camel 폴더를 확장하여 ZooOrderApp 의 요소를 노출합니다.

Bundles 노드를 클릭하여 런타임 서버에 설치된 번들 목록으로 속성 보기를 채웁니다.

검색 필드에 ZooOrderApp을 입력합니다. 해당 번들이 표시됩니다.

참고

또는 터미널 보기에서 osgi:list 명령을 실행하여 서버 런타임에 설치된 생성된 번들 목록을 확인할 수 있습니다. 툴링은 osgi:list 명령으로 표시되는 OSGi 번들에 대해 다른 이름 체계를 사용합니다. 이 경우 명령은 설치된 번들 목록 끝에 표시되는 Camel 블루프린트 빠른 시작을 반환합니다.

프로젝트의 pom.xml 파일의 < build > 섹션에서 maven-bundle-plugin 항목에 나열된 번들의 심볼릭 이름과 OSGi를 찾을 수 있습니다.

추가 및 제거를 선택합니다.

서버 보기에서 Cryo stat [Connected]를 마우스 오른쪽 버튼으로 클릭한 다음 새로 고침을 클릭합니다.

Camel 트리( 연결됨) 아래에 있는 Camel 트리가 사라집니다.