---
schema_version: "1"
id: 61e743bc81e5414cbc2865fadd75fe79ee37c8d1ac8705b3c387837ffd78b6e1
title: Salesforce Pub/Sub Connector 1.0 の例
collection: mulesoft
version: current
locale: ja-jp
portal_url: https://docs.salesforce.com/mulesoft/current/ja-jp/salesforce-pubsub-connector/1.0/salesforce-pubsub-connector-examples.md
canonical_url: https://docs.mulesoft.com/jp/salesforce-pubsub-connector/1.0/salesforce-pubsub-connector-examples
source_site: docs.mulesoft.com
content_type: documentation
content_hash: 157f40b6f4a1c8a232bcd49d86df099dc87187b9e75ed092dc10e3db510b0392
description: MuleSoft Documentation Site
release: "1.0"
latest: true
---
# Salesforce Pub/Sub Connector 1.0 の例

Salesforce Pub/Sub Connector の Mule フローの例を示します。

- [イベントのパブリッシュ](#publish-an-event)
- [チャネルのサブスクライブ](#subscribe-to-a-channel)

## [](#始める前に)始める前に

これらの例では以下が必要です。

- Java 8、11、または 17
- Anypoint Studio 7.5 以降
- Mule Runtime Engine (Mule) 4.3.0 以降
- DataWeave

## [](#接続の設定)接続の設定

接続を保護するには、接続項目の値を指定する必要があります。次の手順を実行します。

- [接続の設定ファイルを作成する](#create-config-file)​。
- [接続のグローバル要素を設定する](#configure-conn)​。
- [プロパティファイルのグローバル要素を設定する](#configure-global)​。

### [](#create-config-file)接続の設定ファイルを作成する

接続のプロパティが含まれる設定ファイルを作成します。

1. `/src/main/resources/`​ フォルダー内に ​`mule-app.properties`​ という名前のファイルを作成します。
2. `mule-app.properties`​ ファイルに、次のような接続の一連のプロパティを作成します。括弧で囲まれたテキスト (括弧を含む) を各自の設定の適切な値に置き換えます。
    
    m4-config.username=<username within Salesforce Pub/Sub system>
    m4-config.password=<password for the username within Salesforce Pub/Sub system>
    m4-config.securityToken=<security token within Salesforce Pub/Sub system>
    m4-config.url=<endpoint representing your development environment>
    
    使用するプロパティは、選択した接続設定によって異なる場合があります。

プロパティファイルの作成についての詳細は、​[「プロパティプレースホルダーの設定」](https://docs.mulesoft.com/mule-runtime/latest/mule-app-properties-to-configure)​を参照してください。

### [](#configure-conn)接続のグローバル要素を設定する

接続のグローバル要素を設定します。

1. 新しい Mule プロジェクトを作成します。
2. **\[Mule Palette (Mule パレット)\]**​ ビューで、​**\[Search in Exchange (Exchange 内を検索)\]**​ をクリックして​`「Salesforce Pub/Sub」`​と入力します。
3. **\[Salesforce Pub/Sub Connector\]**​ を ​**\[Selected modules (選択済みモジュール)\]**​ セクションに追加し、​**\[Finish (完了)\]**​ をクリックします。
4. **\[Global Elements (グローバル要素)\]**​ タブをクリックし、​**\[Create (作成)\]**​ をクリックします。
5. **\[Connector Configuration (コネクタ設定)\] > \[Salesforce Pub/Sub Config (Salesforce Pub/Sub 設定)\]**​ を選択し、​**\[OK\]**​ をクリックします。
6. 値を入力して、\[Basic Authentication (基本認証)\]、\[OAuth v2.0\]、\[OAuth JWT\]、\[OAuth Username Password (OAuth ユーザー名/パスワード)\]、\[OAuth SAML\] のいずれかを設定します。
7. **\[Test Connection (接続をテスト)\]**​ ボタンをクリックして、Salesforce Pub/Sub API と接続されていることを確認します。ポップアップに成功メッセージが表示されます。
8. **\[OK\]**​ をクリックします。
9. **\[Global Element Configuration (グローバル要素設定)\]**​ で HTTPS リスナー設定を開きます。
10. **\[TLS\]**​ タブをクリックし、​**\[TLS Configuration (TLS 設定)\] > \[Edit inline (インライン編集)\]**​ を選択します。
11. 生成されたキーストアの詳細を使用して ​**\[Key Store Configuration (キーストア設定)\]**​ を指定し、この設定で HTTPS を有効にします。
12. **\[OK\]**​ をクリックします。

### [](#configure-global)プロパティファイルのグローバル要素を設定する

`mule-app.properties`​ ファイルのグローバル要素を設定して、Mule がその場所を認識できるようにします。

1. **\[Global Elements (グローバル要素)\]**​ タブをクリックし、​**\[Create (作成)\]**​ をクリックします。
2. **\[Choose Global Type (グローバル種別の選択)\]**​ ダイアログで、​**\[Configuration properties (設定プロパティ)\]**​ を選択し、​**\[OK\]**​ をクリックします。
3. **\[File (ファイル)\]**​ 項目に「​`mule.app.properties`​」と入力します。
4. **\[OK\]**​ をクリックします。

## [](#publish-an-event)イベントのパブリッシュ

この例の Mule フローは、イベントをパブリッシュし、以下の操作を使用します。

- **HTTP Listener**​  
    HTTP 要求からデータを受け入れます。
- **Transform Message**​  
    データを Java で出力します。
- **Publish event**​  
    イベントの特定のリストを指定されたイベントトピックにパブリッシュします。大規模プラットフォームイベント (リアルタイムイベントモニタリングイベントを含む) と変更データキャプチャイベントのみが許可されます。
    
    次の値を入力します。
    
    <table class="tableblock frame-all grid-all stretch">
<colgroup>
<col style="width: 30%;">
<col style="width: 70%;">
</colgroup>
<thead>
<tr>
<th class="tableblock halign-left valign-top">項目</th>
<th class="tableblock halign-left valign-top">値</th>
</tr>
</thead>
<tbody>
<tr>
<td class="tableblock halign-left valign-top"><p class="tableblock"><strong>Topic (トピック)</strong></p></td>
<td class="tableblock halign-left valign-top"><div class="content"><div class="paragraph">
<p>メッセージのパブリッシュに使用されるトピックの名前 (​<code>/event/gRPCMunitTestDoNotDelete__e</code>​)</p>
</div></div></td>
</tr>
<tr>
<td class="tableblock halign-left valign-top"><p class="tableblock"><strong>Job id (ジョブ ID)</strong></p></td>
<td class="tableblock halign-left valign-top"><div class="content"><div class="paragraph">
<p><code>payload</code></p>
</div></div></td>
</tr>
</tbody>
</table>

![Publish イベント操作の Studio フロー](/mulesoft/current/ja-jp/salesforce-pubsub-connector/1.0/_images/publish-an-event.png)

### [](#この例の-xml)この例の XML

この例のフローをすばやく Mule アプリケーションに読み込むには、次のコードを Studio XML エディターに貼り付けます。

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

<mule xmlns:ee="http://www.mulesoft.org/schema/mule/ee/core"
	  xmlns:http="http://www.mulesoft.org/schema/mule/http" xmlns:salesforce-pub-sub="http://www.mulesoft.org/schema/mule/salesforce-pub-sub" xmlns="http://www.mulesoft.org/schema/mule/core" xmlns:doc="http://www.mulesoft.org/schema/mule/documentation" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd
http://www.mulesoft.org/schema/mule/salesforce-pub-sub http://www.mulesoft.org/schema/mule/salesforce-pub-sub/current/mule-salesforce-pub-sub.xsd
http://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd
http://www.mulesoft.org/schema/mule/ee/core http://www.mulesoft.org/schema/mule/ee/core/current/mule-ee.xsd">

	<configuration-properties file="mule-app.properties"/>

	<salesforce-pub-sub:pubsub-config name="Salesforce_PubSub_Config" >
		<salesforce-pub-sub:basic-connection username="${m4-config.username}" password="${m4-config.password}" securityToken="${m4-config.securityToken}" url="${m4-config.url}"/>
	</salesforce-pub-sub:pubsub-config>

	<http:listener-config name="HTTP_Listener_config" doc:name="HTTP Listener config" doc:id="3805c5f1-0f01-476a-a619-a03f34dadfdd" >
		<http:listener-connection host="0.0.0.0" port="8081" />
	</http:listener-config>
<flow name="mule-salesforce-pubsub-connector-publish-event-demo" doc:id="9e2df8f5-1b47-4a76-ac62-941c989cd93b" >
  <http:listener doc:name="Listener" doc:id="6e06a214-3112-40ef-8720-f730121aa5e0" config-ref="HTTP_Listener_config" path="/publish-event"/>
  <ee:transform>
    <ee:message>
      <ee:set-payload><![CDATA[%dw 2.0
        output application/java
        ---
        [{
          CreatedDate: 12334455,
          CreatedById: "123",
          Desc__c: "Something"
        },{
          CreatedDate: 12334456,
          CreatedById: "1234",
          Desc__c: "Something2"
        }
        ]]]>
      </ee:set-payload>
    </ee:message>
  </ee:transform>

  <salesforce-pub-sub:publish-event config-ref="Salesforce_PubSub_Config" topic="/event/gRPCMunitTestDoNotDelete__e"/>
</flow>
</mule>
```

## [](#subscribe-to-a-channel)チャネルのサブスクライブ

この例の Mule フローはチャネルにサブスクライブし、以下の操作を使用します。

- **Subscribe channel listener**​  
    ストリーミングチャネルをサブスクライブします。このソースでは、サブスクライブ後に発生した新規イベントについてチャネル関連の通知設定が提供されます。
    
    <table><tbody><tr><td class="icon"><i class="fa icon-note" title="Note"></i></td><td class="content">チャネルのサブスクリプションを作成する前に、チャネルを Salesforce にパブリッシュする必要があります。</td></tr></tbody></table>
    
    次の値を入力します。
    
    <table class="tableblock frame-all grid-all stretch">
<colgroup>
<col style="width: 30%;">
<col style="width: 70%;">
</colgroup>
<thead>
<tr>
<th class="tableblock halign-left valign-top">項目</th>
<th class="tableblock halign-left valign-top">値</th>
</tr>
</thead>
<tbody>
<tr>
<td class="tableblock halign-left valign-top"><p class="tableblock"><strong>Channel name (チャネル名)</strong></p></td>
<td class="tableblock halign-left valign-top"><div class="content"><div class="paragraph">
<p>サブスクライブするストリーミングチャネルの名前 (​<code>/event/gRPCMunitTestDoNotDelete__e</code>​)</p>
</div></div></td>
</tr>
<tr>
<td class="tableblock halign-left valign-top"><p class="tableblock"><strong>Replay option (再生オプション)</strong></p></td>
<td class="tableblock halign-left valign-top"><div class="content"><div class="paragraph">
<p>いずれかの特定の実装 (​<code>[Earliest (最古)]</code>​ など)。​<strong>[Replay option (再生オプション)]</strong>​ の ​<code>[Replay id from object store (オブジェクトストアの再生 ID)]</code>​ を使用する方法についての詳細は、​<a href="https://docs.mulesoft.com/jp/salesforce-pubsub-connector/1.0/salesforce-pubsub-connector-studio#store-objectstore" class="xref page">「オブジェクトストアの再生 ID を保存する」</a>​を参照してください。</p>
</div></div></td>
</tr>
<tr>
<td class="tableblock halign-left valign-top"><p class="tableblock"><strong>Batch events size (バッチイベントサイズ)</strong></p></td>
<td class="tableblock halign-left valign-top"><div class="content"><div class="paragraph">
<p>サーバーバッチに含まれるイベントの総数。値が小さいと、メモリフットプリントが小さくなり、サーバーコールが増えます。値が大きいと、メモリフットプリントが大きくなり、API コールが減ります。フローで既存のイベントをコンシュームすると、コネクタによってイベントの新しいバッチが要求されます (例: <code>1000</code>​)。</p>
</div></div></td>
</tr>
</tbody>
</table>
- **Logger**​  
    **Subscribe channel listener**​ ソースからの HTTP 応答を表示します。

![Subscribe channel listener ソースの Studio フロー](/mulesoft/current/ja-jp/salesforce-pubsub-connector/1.0/_images/subscribe-to-a-channel.png)

### [](#この例の-xml-2)この例の XML

この例のフローをすばやく Mule アプリケーションに読み込むには、次のコードを Studio XML エディターに貼り付けます。

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

<mule xmlns:ee="http://www.mulesoft.org/schema/mule/ee/core"
	  xmlns:http="http://www.mulesoft.org/schema/mule/http" xmlns:salesforce-pub-sub="http://www.mulesoft.org/schema/mule/salesforce-pub-sub" xmlns="http://www.mulesoft.org/schema/mule/core" xmlns:doc="http://www.mulesoft.org/schema/mule/documentation" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd
http://www.mulesoft.org/schema/mule/salesforce-pub-sub http://www.mulesoft.org/schema/mule/salesforce-pub-sub/current/mule-salesforce-pub-sub.xsd
http://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd
http://www.mulesoft.org/schema/mule/ee/core http://www.mulesoft.org/schema/mule/ee/core/current/mule-ee.xsd">

	<configuration-properties file="mule-app.properties"/>

	<salesforce-pub-sub:pubsub-config name="Salesforce_PubSub_Config" >
		<salesforce-pub-sub:basic-connection username="${m4-config.username}" password="${m4-config.password}" securityToken="${m4-config.securityToken}" url="${m4-config.url}"/>
	</salesforce-pub-sub:pubsub-config>

	<http:listener-config name="HTTP_Listener_config" doc:name="HTTP Listener config" doc:id="3805c5f1-0f01-476a-a619-a03f34dadfdd" >
		<http:listener-connection host="0.0.0.0" port="8081" />
	</http:listener-config>

	<flow name="mule-salesforce-pubsub-connector-subscribe-channel-demo" doc:id="4faf2bf8-e2af-43bc-bba8-d336761800dd" >
		<salesforce-pub-sub:subscribe-channel-listener channelName="/event/gRPCMunitTestDoNotDelete__e" config-ref="Salesforce_PubSub_Config" eventBatchSize="1000">
			<salesforce-pub-sub:replay-option >
				<salesforce-pub-sub:earliest />
			</salesforce-pub-sub:replay-option>
		</salesforce-pub-sub:subscribe-channel-listener>
		<logger level="INFO" doc:name="Logger" doc:id="21652e14-de84-4752-a9b9-871dc346befb" message="#[payload]"/>
	</flow>
</mule>
```

## [](#関連情報)関連情報

- [Anypoint Connector の概要](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors)
- [MuleSoft ヘルプセンター](https://help.mulesoft.com)