--- schema_version: "1" id: 42390f297e259fdd2a785180f06782b60b078662d9688ddebcd6bcf4f09ec9c2 title: Google Pub/Sub Connector 1.0 リファレンス collection: mulesoft version: current locale: ja-jp portal_url: https://docs.salesforce.com/mulesoft/current/ja-jp/google-pubsub-connector/1.0/google-pubsub-connector-reference.md canonical_url: https://docs.mulesoft.com/jp/google-pubsub-connector/1.0/google-pubsub-connector-reference source_site: docs.mulesoft.com content_type: documentation content_hash: 6d1337e6ff69412e721a37c41a8cbd6104bb317e5140ce2011aa66df803df17c description: MuleSoft Documentation Site release: "1.0" latest: true --- # Google Pub/Sub Connector 1.0 リファレンス ## [](#設定)設定 * * * ### [](#Config)Configuration (設定) #### [](#パラメーター)パラメーター

名前	型	説明	必須
Name (名前)	String (文字列)	この設定の名前。コネクタはこの名前の設定を参照します。	x
Connection (接続)	PubSub Connection (PubSub 接続)	この設定の接続種別。	x
Default Project Id (デフォルトのプロジェクト ID)	String (文字列)	プロジェクトのグローバル一意識別子。操作で使用されます。config レベルで上書きできます。
Default Subscription Name (デフォルトのサブスクリプション名)	String (文字列)	プロジェクトのデフォルトのサブスクリプション。操作で使用されます。config レベルで上書きできます。
Default Topic Name (デフォルトのトピック名)	String (文字列)	プロジェクトのデフォルトのトピック。操作で使用されます。config レベルで上書きできます。
Name (名前)	String (文字列)	この設定の参照に使用される ID。	x
Expiration Policy (有効期限ポリシー)	Expiration Policy (有効期限ポリシー)	動的設定インスタンスがアイドル状態を続けられる最小時間を設定します。この時間が経過すると、Mule Runtime で期限切れに相当するとみなされます。

名前

型

説明

デフォルト値

必須

Name (名前)

String (文字列)

この設定の名前。コネクタはこの名前の設定を参照します。

Connection (接続)

PubSub Connection (PubSub 接続)

この設定の接続種別。

Default Project Id (デフォルトのプロジェクト ID)

String (文字列)

プロジェクトのグローバル一意識別子。操作で使用されます。config レベルで上書きできます。

Default Subscription Name (デフォルトのサブスクリプション名)

String (文字列)

プロジェクトのデフォルトのサブスクリプション。操作で使用されます。config レベルで上書きできます。

Default Topic Name (デフォルトのトピック名)

String (文字列)

プロジェクトのデフォルトのトピック。操作で使用されます。config レベルで上書きできます。

Name (名前)

String (文字列)

この設定の参照に使用される ID。

Expiration Policy (有効期限ポリシー)

動的設定インスタンスがアイドル状態を続けられる最小時間を設定します。この時間が経過すると、Mule Runtime で期限切れに相当するとみなされます。

#### [](#接続種別)接続種別 ##### [](#Config_Connection)PubSub Connection (PubSub 接続) ###### [](#パラメーター-2)パラメーター

名前型説明デフォルト値必須

名前	型	説明	デフォルト値	必須
Private key ID (非公開キー ID)	String (文字列)	サービスアカウントの非公開キーの ID。PubSub で作成されるサービスログイン情報の一部です。		x
Client ID (クライアント ID)	String (文字列)	サービスアカウントのクライアントの ID。PubSub で作成されるサービスログイン情報の一部です。		x
Client email (クライアントメール)	String (文字列)	サービスアカウントのクライアントメール。PubSub で作成されるサービスログイン情報の一部です。		x
Private key (非公開キー)	String (文字列)	サービスアカウントの非公開キー。PubSub で作成されるサービスログイン情報の一部です。		x
Message Count Batch Size (メッセージ数バッチサイズ)	Number (数値)	バッチ内のメッセージの最大数。メッセージの最大数に達すると、要素がバッチにまとめられて送信されます。	10
Request Size Threshold (要求サイズしきい値)	Number (数値)	バッチ内のメッセージの最大メモリサイズ。最大メモリサイズに達すると、要素がバッチにまとめられて送信されます。	1
Request Size Threshold Unit (要求サイズしきい値単位)	Enumeration (列挙)。次のいずれかになります。 BYTE (バイト) KB MB GB	[Request Size Threshold (要求サイズしきい値)] 項目のデータ単位。	KB
Publish Delay Threshold (パブリッシュ遅延しきい値)	Number (数値)	バッチに使用される最大遅延しきい値。最大時間が経過すると (最初の要素が追加された時点から計測)、要素がバッチにまとめられて送信されます。高すぎる値に設定しないでください (特に時間単位が `MILLISECONDS` の場合)。値が高すぎると、コールが終わらないように思えるほど時間がかかります。	10
Publish Delay Threshold Time Unit (パブリッシュ遅延しきい値単位)	Enumeration (列挙)。次のいずれかになります。 NANOSECONDS (ナノ秒) MICROSECONDS (マイクロ秒) MILLISECONDS (ミリ秒) SECONDS (秒) MINUTES (分) HOURS (時間) DAYS (日)	[Publish Delay Threshold (パブリッシュ遅延しきい値)] 項目の時間単位。	MILLISECONDS (ミリ秒)
Enable batching (バッチを有効化)	Boolean (ブール)	パブリッシュ要求のバッチを有効にするか無効化するかのフラグ。	false
Limit Exceeded Behavior (制限を超過した動作)	Enumeration (列挙)。次のいずれかになります。 THROW_EXCEPTION BLOCK IGNORE	`IGNORE` に設定しない場合は、[Max Outstanding Request Size (最大未処理要求サイズ)] と [Max Outstanding Element Count (最大未処理要素数)] の制限を指定して、フロー制御でパブリッシュ動作を制御できます。 `THROW_EXCEPTION` 未処理要素 (Ack() も Nack() も実行されなかったメッセージ) のメモリサイズまたは数が指定された制限を超えると、パブリッシャーは `FlowControlException` をスローします。 `BLOCK` 未処理要素 (Ack() も Nack() も実行されされなかったメッセージ) のメモリサイズまたは数が指定された制限を超えると、パブリッシャーはそれ以降メッセージをパブリッシュしません。 `IGNORE` パブリッシャーは指定された制限を考慮せず、メッセージのパブリッシュ率を制御しません。	Max Outstanding Request Size (最大未処理要求サイズ)	Number (数値)
要求によって累積されたメモリの最大量。これを超えるとフロー制御が適用されます。	100		Max Outstanding Request Size Unit (最大未処理要求サイズ単位)	Enumeration (列挙)。次のいずれかになります。 BYTE (バイト) KB MB GB
[Max Outstanding Request Size (最大未処理要求サイズ)] 項目のデータ単位。	MB		Max Outstanding Element Count (最大未処理要素数)	Number (数値)
メモリに保持される未処理要素の最大数。これを超えるとフロー制御が適用されます。	100		Reconnection (再接続)	Reconnection (再接続)

Private key ID (非公開キー ID)

String (文字列)

サービスアカウントの非公開キーの ID。PubSub で作成されるサービスログイン情報の一部です。

Client ID (クライアント ID)

String (文字列)

サービスアカウントのクライアントの ID。PubSub で作成されるサービスログイン情報の一部です。

Client email (クライアントメール)

String (文字列)

サービスアカウントのクライアントメール。PubSub で作成されるサービスログイン情報の一部です。

Private key (非公開キー)

String (文字列)

サービスアカウントの非公開キー。PubSub で作成されるサービスログイン情報の一部です。

Message Count Batch Size (メッセージ数バッチサイズ)

Number (数値)

バッチ内のメッセージの最大数。メッセージの最大数に達すると、要素がバッチにまとめられて送信されます。

Request Size Threshold (要求サイズしきい値)

Number (数値)

バッチ内のメッセージの最大メモリサイズ。最大メモリサイズに達すると、要素がバッチにまとめられて送信されます。

Request Size Threshold Unit (要求サイズしきい値単位)

Enumeration (列挙)。次のいずれかになります。

BYTE (バイト)
KB
MB
GB

[Request Size Threshold (要求サイズしきい値)] 項目のデータ単位。

Publish Delay Threshold (パブリッシュ遅延しきい値)

Number (数値)

バッチに使用される最大遅延しきい値。最大時間が経過すると (最初の要素が追加された時点から計測)、要素がバッチにまとめられて送信されます。高すぎる値に設定しないでください (特に時間単位が MILLISECONDS の場合)。値が高すぎると、コールが終わらないように思えるほど時間がかかります。

Publish Delay Threshold Time Unit (パブリッシュ遅延しきい値単位)

Enumeration (列挙)。次のいずれかになります。

NANOSECONDS (ナノ秒)
MICROSECONDS (マイクロ秒)
MILLISECONDS (ミリ秒)
SECONDS (秒)
MINUTES (分)
HOURS (時間)
DAYS (日)

[Publish Delay Threshold (パブリッシュ遅延しきい値)] 項目の時間単位。

MILLISECONDS (ミリ秒)

Enable batching (バッチを有効化)

Boolean (ブール)

パブリッシュ要求のバッチを有効にするか無効化するかのフラグ。

false

Limit Exceeded Behavior (制限を超過した動作)

Enumeration (列挙)。次のいずれかになります。

THROW_EXCEPTION
BLOCK
IGNORE

IGNORE に設定しない場合は、[Max Outstanding Request Size (最大未処理要求サイズ)] と [Max Outstanding Element Count (最大未処理要素数)] の制限を指定して、フロー制御でパブリッシュ動作を制御できます。

THROW_EXCEPTION

未処理要素 (Ack() も Nack() も実行されなかったメッセージ) のメモリサイズまたは数が指定された制限を超えると、パブリッシャーは FlowControlException をスローします。
BLOCK

未処理要素 (Ack() も Nack() も実行されされなかったメッセージ) のメモリサイズまたは数が指定された制限を超えると、パブリッシャーはそれ以降メッセージをパブリッシュしません。
IGNORE

パブリッシャーは指定された制限を考慮せず、メッセージのパブリッシュ率を制御しません。

Max Outstanding Request Size (最大未処理要求サイズ)

Number (数値)

要求によって累積されたメモリの最大量。これを超えるとフロー制御が適用されます。

100

Max Outstanding Request Size Unit (最大未処理要求サイズ単位)

Enumeration (列挙)。次のいずれかになります。

BYTE (バイト)
KB
MB
GB

[Max Outstanding Request Size (最大未処理要求サイズ)] 項目のデータ単位。

Max Outstanding Element Count (最大未処理要素数)

Number (数値)

メモリに保持される未処理要素の最大数。これを超えるとフロー制御が適用されます。

100

Reconnection (再接続)

## [](#サポートされている操作)サポートされている操作 - [Create Snapshot](#CreateSnapshot) - [Delete Snapshot](#DeleteSnapshot) - [Get Snapshot](#GetSnapshot) - [Get Snapshot List](#GetSnapshotList) - [Patch Snapshot](#PatchSnapshot) - [Publish Message](#PublishMessage) - [Seek Messages](#SeekMessages) ## [](#関連付けられたソース)関連付けられたソース - [On message listener](#MessageListener) ## [](#操作)操作 ## [](#CreateSnapshot)Create Snapshot `` 要求されたサブスクリプションからスナップショットを作成します。スナップショットを Seek 操作で使用して、メッセージの肯定応答を一括管理します。この操作では、既存のサブスクリプションのメッセージの肯定応答状態をスナップショットで取得された状態に設定できます。 ### [](#パラメーター-3)パラメーター

名前	型	説明	デフォルト値	必須
Configuration (設定)	String (文字列)	使用する設定の名前。		x
Snapshot Name (スナップショット名)	String (文字列)	スナップショットのプロジェクト全体で一意の識別子。		x
Labels (ラベル)	Object (オブジェクト)	ユーザーが Google Cloud リソースを整理するために役立つキー-値ペア。リソースにラベルを付けることで、ラベルに基づいてリソースが絞り込まれます。
Config Ref (設定参照)	ConfigurationProvider	このコンポーネントを実行するために使用する設定の名前。		x
Project ID (プロジェクト ID)	String (文字列)	プロジェクトのグローバル一意識別子。
Subscription Name (サブスクリプション名)	String (文字列)	サブスクリプションのプロジェクト全体で一意の識別子。
Target Variable (対象変数)	String (文字列)	操作の出力を保存する変数の名前。
Target Value (対象値)	String (文字列)	操作の出力を評価する式。式の結果は [Target Variable (対象変数)] 項目に保存されます。	#[payload]
Reconnection Strategy (再接続戦略)	Reconnect (再接続) Reconnect Forever (繰り返し再接続)	接続エラーが発生した場合の再試行戦略。

名前

型

説明

デフォルト値

必須

Configuration (設定)

String (文字列)

使用する設定の名前。

Snapshot Name (スナップショット名)

String (文字列)

スナップショットのプロジェクト全体で一意の識別子。

Labels (ラベル)

Object (オブジェクト)

ユーザーが Google Cloud リソースを整理するために役立つキー-値ペア。リソースにラベルを付けることで、ラベルに基づいてリソースが絞り込まれます。

Config Ref (設定参照)

ConfigurationProvider

このコンポーネントを実行するために使用する設定の名前。

Project ID (プロジェクト ID)

String (文字列)

プロジェクトのグローバル一意識別子。

Subscription Name (サブスクリプション名)

String (文字列)

サブスクリプションのプロジェクト全体で一意の識別子。

Target Variable (対象変数)

String (文字列)

操作の出力を保存する変数の名前。

Target Value (対象値)

String (文字列)

操作の出力を評価する式。式の結果は [Target Variable (対象変数)] 項目に保存されます。

#[payload]

Reconnection Strategy (再接続戦略)

Reconnect (再接続)
Reconnect Forever (繰り返し再接続)

接続エラーが発生した場合の再試行戦略。

### [](#出力)出力

型	Snapshot (スナップショット)

### [](#次の設定の場合)次の設定の場合 - [Configuration (設定)](#Config) ### [](#スロー)スロー - PUBSUB:ALREADY\_EXISTS - PUBSUB:BAD\_GATEWAY - PUBSUB:CANCELLED - PUBSUB:CONNECTIVITY - PUBSUB:DEADLINE\_EXCEEDED - PUBSUB:FAILED\_PRECONDITION - PUBSUB:INVALID\_ARGUMENT - PUBSUB:NOT\_FOUND - PUBSUB:PERMISSION\_DENIED - PUBSUB:RETRY\_EXHAUSTED - PUBSUB:UNAVAILABLE ## [](#DeleteSnapshot)Delete Snapshot `` 既存のスナップショットを削除します。 ### [](#パラメーター-4)パラメーター

名前	型	説明	必須
Configuration (設定)	String (文字列)	使用する設定の名前。	x
Config Ref (設定参照)	ConfigurationProvider	このコンポーネントを実行するために使用する設定の名前。	x
Project ID (プロジェクト ID)	String (文字列)	プロジェクトのグローバル一意識別子。
Snapshot Name (スナップショット名)	String (文字列)	スナップショットのプロジェクト全体で一意の識別子。	x
Reconnection Strategy (再接続戦略)	Reconnect (再接続) Reconnect Forever (繰り返し再接続)	接続エラーが発生した場合の再試行戦略。

名前

型

説明

デフォルト値

必須

Configuration (設定)

String (文字列)

使用する設定の名前。

Config Ref (設定参照)

ConfigurationProvider

このコンポーネントを実行するために使用する設定の名前。

Project ID (プロジェクト ID)

String (文字列)

プロジェクトのグローバル一意識別子。

Snapshot Name (スナップショット名)

String (文字列)

スナップショットのプロジェクト全体で一意の識別子。

Reconnection Strategy (再接続戦略)

Reconnect (再接続)
Reconnect Forever (繰り返し再接続)

接続エラーが発生した場合の再試行戦略。

### [](#次の設定の場合-2)次の設定の場合 - [Configuration (設定)](#Config) ### [](#スロー-2)スロー - PUBSUB:BAD\_GATEWAY - PUBSUB:CANCELLED - PUBSUB:CONNECTIVITY - PUBSUB:DEADLINE\_EXCEEDED - PUBSUB:FAILED\_PRECONDITION - PUBSUB:INVALID\_ARGUMENT - PUBSUB:NOT\_FOUND - PUBSUB:PERMISSION\_DENIED - PUBSUB:RETRY\_EXHAUSTED - PUBSUB:UNAVAILABLE ## [](#GetSnapshot)Get Snapshot `` スナップショットを取得します。 ### [](#パラメーター-5)パラメーター

名前	型	説明	デフォルト値	必須
Configuration (設定)	String (文字列)	使用する設定の名前。		x
Config Ref (設定参照)	ConfigurationProvider	このコンポーネントを実行するために使用する設定の名前。		x
Project ID (プロジェクト ID)	String (文字列)	プロジェクトのグローバル一意識別子。
Snapshot Name (スナップショット名)	String (文字列)	スナップショットのプロジェクト全体で一意の識別子。		x
Target Variable (対象変数)	String (文字列)	操作の出力を保存する変数の名前。
Target Value (対象値)	String (文字列)	操作の出力を評価する式。式の結果は [Target Variable (対象変数)] 項目に保存されます。	#[payload]
Reconnection Strategy (再接続戦略)	Reconnect (再接続) Reconnect Forever (繰り返し再接続)	接続エラーが発生した場合の再試行戦略。

名前

型

説明

デフォルト値

必須

Configuration (設定)

String (文字列)

使用する設定の名前。

Config Ref (設定参照)

ConfigurationProvider

このコンポーネントを実行するために使用する設定の名前。

Project ID (プロジェクト ID)

String (文字列)

プロジェクトのグローバル一意識別子。

Snapshot Name (スナップショット名)

String (文字列)

スナップショットのプロジェクト全体で一意の識別子。

Target Variable (対象変数)

String (文字列)

操作の出力を保存する変数の名前。

Target Value (対象値)

String (文字列)

操作の出力を評価する式。式の結果は [Target Variable (対象変数)] 項目に保存されます。

#[payload]

Reconnection Strategy (再接続戦略)

Reconnect (再接続)
Reconnect Forever (繰り返し再接続)

接続エラーが発生した場合の再試行戦略。

### [](#出力-2)出力

型	Snapshot (スナップショット)

### [](#次の設定の場合-3)次の設定の場合 - [Configuration (設定)](#Config) ### [](#スロー-3)スロー - PUBSUB:BAD\_GATEWAY - PUBSUB:CANCELLED - PUBSUB:CONNECTIVITY - PUBSUB:DEADLINE\_EXCEEDED - PUBSUB:FAILED\_PRECONDITION - PUBSUB:INVALID\_ARGUMENT - PUBSUB:NOT\_FOUND - PUBSUB:PERMISSION\_DENIED - PUBSUB:RETRY\_EXHAUSTED - PUBSUB:UNAVAILABLE ## [](#GetSnapshotList)Get Snapshot List `` 選択されたプロジェクトから既存のスナップショットのリストを取得します。 ### [](#パラメーター-6)パラメーター

名前	型	説明	デフォルト値	必須
Configuration (設定)	String (文字列)	使用する設定の名前。		x
Project Id (プロジェクト ID)	String (文字列)	プロジェクトのグローバル一意識別子。
Config Ref (設定参照)	ConfigurationProvider	このコンポーネントを実行するために使用する設定の名前。		x
Streaming Strategy (ストリーミング戦略)	Repeatable In Memory Iterable (反復可能なメモリ内イテラブル) Repeatable File Store Iterable (反復可能なファイルストアイテラブル) non-repeatable-iterable	Mule によるストリームの処理方法を設定します。デフォルトでは、反復可能ストリームが使用されます。
Target Variable (対象変数)	String (文字列)	操作の出力を保存する変数の名前。
Target Value (対象値)	String (文字列)	操作の出力を評価する式。式の結果は [Target Variable (対象変数)] 項目に保存されます。	#[payload]
Reconnection Strategy (再接続戦略)	Reconnect (再接続) Reconnect Forever (繰り返し再接続)	接続エラーが発生した場合の再試行戦略。

名前

型

説明

デフォルト値

必須

Configuration (設定)

String (文字列)

使用する設定の名前。

Project Id (プロジェクト ID)

String (文字列)

プロジェクトのグローバル一意識別子。

Config Ref (設定参照)

ConfigurationProvider

このコンポーネントを実行するために使用する設定の名前。

Streaming Strategy (ストリーミング戦略)

Repeatable In Memory Iterable (反復可能なメモリ内イテラブル)
Repeatable File Store Iterable (反復可能なファイルストアイテラブル)
non-repeatable-iterable

Mule によるストリームの処理方法を設定します。デフォルトでは、反復可能ストリームが使用されます。

Target Variable (対象変数)

String (文字列)

操作の出力を保存する変数の名前。

Target Value (対象値)

String (文字列)

操作の出力を評価する式。式の結果は [Target Variable (対象変数)] 項目に保存されます。

#[payload]

Reconnection Strategy (再接続戦略)

Reconnect (再接続)
Reconnect Forever (繰り返し再接続)

接続エラーが発生した場合の再試行戦略。

### [](#出力-3)出力

型	Snapshot (スナップショット) の配列

### [](#次の設定の場合-4)次の設定の場合 - [Configuration (設定)](#Config) ### [](#スロー-4)スロー - PUBSUB:BAD\_GATEWAY - PUBSUB:CANCELLED - PUBSUB:DEADLINE\_EXCEEDED - PUBSUB:FAILED\_PRECONDITION - PUBSUB:INVALID\_ARGUMENT - PUBSUB:NOT\_FOUND - PUBSUB:PERMISSION\_DENIED - PUBSUB:UNAVAILABLE ## [](#PatchSnapshot)Patch Snapshot `` 既存のスナップショットを更新します。スナップショットの名前とトピックは可変項目ではないため更新できません。 ### [](#パラメーター-7)パラメーター

名前	型	説明	デフォルト値	必須
Configuration (設定)	String (文字列)	使用する設定の名前。		x
Snapshot (スナップショット)	Snapshot (スナップショット)	更新された項目 (ラベルまたは有効期限 (時間)) があるスナップショットオブジェクト。	#[payload]
Update Mask (更新マスク)	String (文字列)	指定されたスナップショット内の更新対象項目を示します。必ず空白以外を指定します。これは項目の完全修飾名のカンマ区切りリストです。		x
Config Ref (設定参照)	ConfigurationProvider	このコンポーネントを実行するために使用する設定の名前。		x
Target Variable (対象変数)	String (文字列)	操作の出力を保存する変数の名前。
Target Value (対象値)	String (文字列)	操作の出力を評価する式。式の結果は [Target Variable (対象変数)] 項目に保存されます。	#[payload]
Reconnection Strategy (再接続戦略)	Reconnect (再接続) Reconnect Forever (繰り返し再接続)	接続エラーが発生した場合の再試行戦略。

名前

型

説明

デフォルト値

必須

Configuration (設定)

String (文字列)

使用する設定の名前。

Snapshot (スナップショット)

更新された項目 (ラベルまたは有効期限 (時間)) があるスナップショットオブジェクト。

#[payload]

Update Mask (更新マスク)

String (文字列)

指定されたスナップショット内の更新対象項目を示します。必ず空白以外を指定します。これは項目の完全修飾名のカンマ区切りリストです。

Config Ref (設定参照)

ConfigurationProvider

このコンポーネントを実行するために使用する設定の名前。

Target Variable (対象変数)

String (文字列)

操作の出力を保存する変数の名前。

Target Value (対象値)

String (文字列)

操作の出力を評価する式。式の結果は [Target Variable (対象変数)] 項目に保存されます。

#[payload]

Reconnection Strategy (再接続戦略)

Reconnect (再接続)
Reconnect Forever (繰り返し再接続)

接続エラーが発生した場合の再試行戦略。

### [](#出力-4)出力

型	Snapshot (スナップショット)

### [](#次の設定の場合-5)次の設定の場合 - [Configuration (設定)](#Config) ### [](#スロー-5)スロー - PUBSUB:BAD\_GATEWAY - PUBSUB:CANCELLED - PUBSUB:CONNECTIVITY - PUBSUB:DEADLINE\_EXCEEDED - PUBSUB:FAILED\_PRECONDITION - PUBSUB:INVALID\_ARGUMENT - PUBSUB:NOT\_FOUND - PUBSUB:PERMISSION\_DENIED - PUBSUB:RETRY\_EXHAUSTED - PUBSUB:UNAVAILABLE ## [](#PublishMessage)Publish Message `` 1 つのメッセージをパブリッシュします。この操作は非ブロックです。バッチが有効な場合、バッチのいずれかの制限に達するまでメッセージはローカルにのみ保存されます。この操作により高スループットになることがあります。**\[Ordering Key (順序キー)\]** 項目を使用すると、コールされた順序でメッセージが処理されることは (特にスレッド環境では) 保証されません。順序を厳格に維持する必要がある場合は、ソースフロー設定の **\[Max Concurrency (最大同時実行)\]** を `1` に設定し、順序が重要な **Publish** コールが含まれる各ループに遅延を追加します。この操作は、トピックでの送信メッセージの一意の識別子である `messageId` を返します。 ### [](#パラメーター-8)パラメーター

名前	型	説明	デフォルト値	必須
Configuration (設定)	String (文字列)	使用する設定の名前。		x
Ordering Key (順序キー)	String (文字列)	指定すると、サブスクライバーによってメッセージの順序付けが有効化されている場合に、パブリッシュ順序を守る必要がある関連メッセージがこの項目で識別されます。
Config Ref (設定参照)	ConfigurationProvider	このコンポーネントを実行するために使用する設定の名前。		x
Project ID (プロジェクト ID)	String (文字列)	プロジェクトのグローバル一意識別子。
Topic Name (トピック名)	String (文字列)	トピックのプロジェクト全体で一意の識別子。
Message (メッセージ)	Binary (バイナリ)	トピックにパブリッシュされたメッセージコンテンツ。空ではない場合、メッセージには少なくとも 1 つの属性が含まれている必要があります。
Attributes (属性)	Object (オブジェクト)	このメッセージの属性。空の場合、メッセージには空ではないデータが含まれている必要があります。サブスクリプションでメッセージを絞り込むために使用できます。
Target Variable (対象変数)	String (文字列)	操作の出力を保存する変数の名前。
Target Value (対象値)	String (文字列)	操作の出力を評価する式。式の結果は [Target Variable (対象変数)] 項目に保存されます。	#[payload]
Reconnection Strategy (再接続戦略)	Reconnect (再接続) Reconnect Forever (繰り返し再接続)	接続エラーが発生した場合の再試行戦略。

名前

型

説明

デフォルト値

必須

Configuration (設定)

String (文字列)

使用する設定の名前。

Ordering Key (順序キー)

String (文字列)

指定すると、サブスクライバーによってメッセージの順序付けが有効化されている場合に、パブリッシュ順序を守る必要がある関連メッセージがこの項目で識別されます。

Config Ref (設定参照)

ConfigurationProvider

このコンポーネントを実行するために使用する設定の名前。

Project ID (プロジェクト ID)

String (文字列)

プロジェクトのグローバル一意識別子。

Topic Name (トピック名)

String (文字列)

トピックのプロジェクト全体で一意の識別子。

Message (メッセージ)

Binary (バイナリ)

トピックにパブリッシュされたメッセージコンテンツ。空ではない場合、メッセージには少なくとも 1 つの属性が含まれている必要があります。

Attributes (属性)

Object (オブジェクト)

このメッセージの属性。空の場合、メッセージには空ではないデータが含まれている必要があります。サブスクリプションでメッセージを絞り込むために使用できます。

Target Variable (対象変数)

String (文字列)

操作の出力を保存する変数の名前。

Target Value (対象値)

String (文字列)

操作の出力を評価する式。式の結果は [Target Variable (対象変数)] 項目に保存されます。

#[payload]

Reconnection Strategy (再接続戦略)

Reconnect (再接続)
Reconnect Forever (繰り返し再接続)

接続エラーが発生した場合の再試行戦略。

### [](#出力-5)出力

型	String (文字列)

### [](#次の設定の場合-6)次の設定の場合 - [Configuration (設定)](#Config) ### [](#スロー-6)スロー - PUBSUB:BAD\_GATEWAY - PUBSUB:CANCELLED - PUBSUB:CONNECTIVITY - PUBSUB:DEADLINE\_EXCEEDED - PUBSUB:FAILED\_PRECONDITION - PUBSUB:INVALID\_ARGUMENT - PUBSUB:MAX\_OUTSTANDING\_BATCH\_SIZE\_REACHED - PUBSUB:MAX\_OUTSTANDING\_ELEMENT\_COUNT\_REACHED - PUBSUB:NOT\_FOUND - PUBSUB:PERMISSION\_DENIED - PUBSUB:RETRY\_EXHAUSTED - PUBSUB:UNAVAILABLE ## [](#SeekMessages)Seek Messages `` 指定されたシーク対象に基づき、特定のスナップショットまたは時点のメッセージを一括して肯定応答または未応答として処理できます。時点にシークすると、その時点までに Pub/Sub で受信されたすべてのメッセージが肯定応答とマークされ、その時点より後に受信されたすべてのメッセージが未応答とマークされます。過去の時点にシークして以前肯定応答されたメッセージを再生および再処理したり、将来の時点にシークしてメッセージをパージしたりできます。スナップショットにシークすると、スナップショット内にある、シーク要求を実行するサブスクリプションの検索条件と一致するメッセージのみを再配信できます。スナップショットが作成されると、そのスナップショットには作成時点でソースサブスクリプションにある未応答のメッセージすべてと、それ以降にトピックにパブリッシュされたメッセージすべてが保持されます。スナップショットを使用してトピックの任意のサブスクリプションにシークすることで、これらの未応答のメッセージを再生できます。サブスクリプションと検索条件を使用してスナップショットにシークすると、Pub/Sub サービスによって、スナップショット内にある、シーク要求を実行するサブスクリプションの検索条件と一致するメッセージのみが再配信されます。 ### [](#パラメーター-9)パラメーター

名前	型	説明	必須
Configuration (設定)	String (文字列)	使用する設定の名前。	x
Config Ref (設定参照)	ConfigurationProvider	このコンポーネントを実行するために使用する設定の名前。	x
Project ID (プロジェクト ID)	String (文字列)	プロジェクトのグローバル一意識別子。
Subscription Name (サブスクリプション名)	String (文字列)	サブスクリプションのプロジェクト全体で一意の識別子。
Snapshot Name (スナップショット名)	String (文字列)	シーク先のスナップショット。スナップショットのトピックは指定されたサブスクリプションのトピックと同じである必要があります。
Timestamp (タイムスタンプ)	DateTime	シーク先の特定の時間。この時間より前にパブリッシュされてサブスクリプション内に保持されているメッセージは肯定応答としてマークされ、この時間より後にパブリッシュされ、サブスクリプション内に保持されているメッセージは未応答としてマークされます。この操作はサブスクリプション内に保持されているメッセージ ([Message Retention Duration (メッセージ保持期間)] と [Retain Acked Messages (肯定応答メッセージを保持)] の組み合わせで設定) にのみ影響を与えます。たとえば、この時間がメッセージ保持期間よりも前の時点 (またはシステムが認識しているサブスクリプション作成時間よりも前の時点) に対応する場合、保持されているメッセージのみが未応答とマークされ、すでに消去されたメッセージは復元されません。タイムスタンプは RFC3339 UTC Zulu 形式で分解能はナノ秒、小数部は最大 9 桁です (2014-10-02T15:01:23Z、2014-10-02T15:01:23.045123456Z など)。
Reconnection Strategy (再接続戦略)	Reconnect (再接続) Reconnect Forever (繰り返し再接続)	接続エラーが発生した場合の再試行戦略。

名前

型

説明

デフォルト値

必須

Configuration (設定)

String (文字列)

使用する設定の名前。

Config Ref (設定参照)

ConfigurationProvider

このコンポーネントを実行するために使用する設定の名前。

Project ID (プロジェクト ID)

String (文字列)

プロジェクトのグローバル一意識別子。

Subscription Name (サブスクリプション名)

String (文字列)

サブスクリプションのプロジェクト全体で一意の識別子。

Snapshot Name (スナップショット名)

String (文字列)

シーク先のスナップショット。スナップショットのトピックは指定されたサブスクリプションのトピックと同じである必要があります。

Timestamp (タイムスタンプ)

DateTime

シーク先の特定の時間。この時間より前にパブリッシュされてサブスクリプション内に保持されているメッセージは肯定応答としてマークされ、この時間より後にパブリッシュされ、サブスクリプション内に保持されているメッセージは未応答としてマークされます。

この操作はサブスクリプション内に保持されているメッセージ ([Message Retention Duration (メッセージ保持期間)] と [Retain Acked Messages (肯定応答メッセージを保持)] の組み合わせで設定) にのみ影響を与えます。たとえば、この時間がメッセージ保持期間よりも前の時点 (またはシステムが認識しているサブスクリプション作成時間よりも前の時点) に対応する場合、保持されているメッセージのみが未応答とマークされ、すでに消去されたメッセージは復元されません。

タイムスタンプは RFC3339 UTC Zulu 形式で分解能はナノ秒、小数部は最大 9 桁です (2014-10-02T15:01:23Z、2014-10-02T15:01:23.045123456Z など)。

Reconnection Strategy (再接続戦略)

Reconnect (再接続)
Reconnect Forever (繰り返し再接続)

接続エラーが発生した場合の再試行戦略。

### [](#次の設定の場合-7)次の設定の場合 - [Configuration (設定)](#Config) ### [](#スロー-7)スロー - PUBSUB:BAD\_GATEWAY - PUBSUB:CANCELLED - PUBSUB:CONNECTIVITY - PUBSUB:DEADLINE\_EXCEEDED - PUBSUB:FAILED\_PRECONDITION - PUBSUB:INVALID\_ARGUMENT - PUBSUB:NOT\_FOUND - PUBSUB:PERMISSION\_DENIED - PUBSUB:RETRY\_EXHAUSTED - PUBSUB:UNAVAILABLE ## [](#ソース)ソース ## [](#MessageListener)On message listener `` 1 つのサブスクライバーからのメッセージをコンシュームする非同期メッセージリスナー。 ### [](#パラメーター-10)パラメーター

名前型説明デフォルト値必須

名前	型	説明	デフォルト値	必須
Configuration (設定)	String (文字列)	使用する設定の名前。		x
Consumer count (コンシューマー数)	Number (数値)	メッセージを処理するために指定された Executors サービスの量を提供します。	5
Config Ref (設定参照)	ConfigurationProvider	このコンポーネントを実行するために使用する設定の名前。		x
Primary Node Only (プライマリノードのみ)	Boolean (ブール)	クラスターでの Mule インスタンスの実行時、このソースをプライマリノード上でのみ実行するかどうかを決定します。
Streaming Strategy (ストリーミング戦略)	Repeatable In Memory Stream (反復可能なメモリ内ストリーム) Repeatable File Store Stream (反復可能なファイルストアストリーム) non-repeatable-stream	Mule によるストリームの処理方法を設定します。デフォルトでは、反復可能ストリームが使用されます。
Redelivery Policy (再配信ポリシー)	Redelivery Policy (再配信ポリシー)	同じメッセージの再配信を処理するためのポリシーを定義します。
Project ID (プロジェクト ID)	String (文字列)	プロジェクトのグローバル一意識別子。
Subscription Name (サブスクリプション名)	String (文字列)	サブスクリプションのプロジェクト全体で一意の識別子。
Limit Exceeded Behavior (制限を超過した動作)	Enumeration (列挙)。次のいずれかになります。 THROW_EXCEPTION BLOCK IGNORE	`IGNORE` に設定しない場合は、[Max Outstanding Request Size (最大未処理要求サイズ)] と [Max Outstanding Element Count (最大未処理要素数)] の制限を指定して、フロー制御でパブリッシュ動作を制御できます。 `THROW_EXCEPTION` 未処理要素 (Ack() も Nack() も実行されなかったメッセージ) のメモリサイズまたは数が指定された制限を超えると、受信者は `FlowControlException` をスローします。 `BLOCK` 未処理要素 (Ack() も Nack() も実行されされなかったメッセージ) のメモリサイズまたは数が指定された制限を超えると、受信者はそれ以降メッセージを受信しません。 `IGNORE` 受信者は指定された制限を考慮せず、メッセージ配信率を制御しません。	Max Outstanding Request Size (最大未処理要求サイズ)	Number (数値)
要求によって累積されたメモリの最大量。これを超えるとフロー制御が適用されます。	100		Max Outstanding Request Size Unit (最大未処理要求サイズ単位)	Enumeration (列挙)。次のいずれかになります。 BYTE (バイト) KB MB GB
[Max Outstanding Request Size (最大未処理要求サイズ)] 項目のデータ単位。	MB		Max Outstanding Element Count (最大未処理要素数)	Number (数値)
メモリに保持される未処理要素の最大数。これを超えるとフロー制御が適用されます。	100		Reconnection Strategy (再接続戦略)	Reconnect (再接続) Reconnect Forever (繰り返し再接続)

Configuration (設定)

String (文字列)

使用する設定の名前。

Consumer count (コンシューマー数)

Number (数値)

メッセージを処理するために指定された Executors サービスの量を提供します。

Config Ref (設定参照)

ConfigurationProvider

このコンポーネントを実行するために使用する設定の名前。

Primary Node Only (プライマリノードのみ)

Boolean (ブール)

クラスターでの Mule インスタンスの実行時、このソースをプライマリノード上でのみ実行するかどうかを決定します。

Streaming Strategy (ストリーミング戦略)

Repeatable In Memory Stream (反復可能なメモリ内ストリーム)
Repeatable File Store Stream (反復可能なファイルストアストリーム)
non-repeatable-stream

Mule によるストリームの処理方法を設定します。デフォルトでは、反復可能ストリームが使用されます。

Redelivery Policy (再配信ポリシー)

同じメッセージの再配信を処理するためのポリシーを定義します。

Project ID (プロジェクト ID)

String (文字列)

プロジェクトのグローバル一意識別子。

Subscription Name (サブスクリプション名)

String (文字列)

サブスクリプションのプロジェクト全体で一意の識別子。

Limit Exceeded Behavior (制限を超過した動作)

Enumeration (列挙)。次のいずれかになります。

THROW_EXCEPTION
BLOCK
IGNORE

THROW_EXCEPTION

未処理要素 (Ack() も Nack() も実行されなかったメッセージ) のメモリサイズまたは数が指定された制限を超えると、受信者は FlowControlException をスローします。
BLOCK

未処理要素 (Ack() も Nack() も実行されされなかったメッセージ) のメモリサイズまたは数が指定された制限を超えると、受信者はそれ以降メッセージを受信しません。
IGNORE

受信者は指定された制限を考慮せず、メッセージ配信率を制御しません。

Max Outstanding Request Size (最大未処理要求サイズ)

Number (数値)

要求によって累積されたメモリの最大量。これを超えるとフロー制御が適用されます。

100

Max Outstanding Request Size Unit (最大未処理要求サイズ単位)

Enumeration (列挙)。次のいずれかになります。

BYTE (バイト)
KB
MB
GB

[Max Outstanding Request Size (最大未処理要求サイズ)] 項目のデータ単位。

Max Outstanding Element Count (最大未処理要素数)

Number (数値)

メモリに保持される未処理要素の最大数。これを超えるとフロー制御が適用されます。

100

Reconnection Strategy (再接続戦略)

Reconnect (再接続)
Reconnect Forever (繰り返し再接続)

### [](#出力-6)出力

型

Any (任意)

Attributes Type (属性型)

Object (オブジェクト)

### [](#次の設定の場合-8)次の設定の場合 - [Configuration (設定)](#Config) ## [](#型)型 ### [](#Reconnection)Reconnection (再接続) 操作の再接続戦略を設定します。

項目型説明デフォルト値必須

項目	型	説明	デフォルト値	必須
Fails Deployment (デプロイに失敗)	Boolean (ブール)	アプリケーションのデプロイ時に、関連する再接続戦略をすべて実行した後、接続テストに合格しない場合の処理: `true` デプロイの失敗を許可します。 `false` 接続テストの結果を無視します。
Reconnection Strategy (再接続戦略)	Reconnect (再接続) Reconnect Forever (繰り返し再接続)	使用する再接続戦略。

Fails Deployment (デプロイに失敗)

Boolean (ブール)

アプリケーションのデプロイ時に、関連する再接続戦略をすべて実行した後、接続テストに合格しない場合の処理:

true

デプロイの失敗を許可します。
false

接続テストの結果を無視します。

Reconnection Strategy (再接続戦略)

Reconnect (再接続)
Reconnect Forever (繰り返し再接続)

使用する再接続戦略。

### [](#Reconnect)Reconnect (再接続) 標準再接続戦略を設定し、再接続の頻度と、コネクタソースまたは操作で実行できる再接続の試行回数を指定します。

項目型説明デフォルト値必須

項目	型	説明
Frequency (頻度)	Number (数値)	再接続を試行する頻度 (ミリ秒)。
Blocking	Boolean (ブール)	`false` の場合、再接続戦略が個別の非ブロックスレッドで実行されます。
Count (数)	Number (数値)	Mule アプリケーションで実行できる再接続の試行回数。

Frequency (頻度)

Number (数値)

再接続を試行する頻度 (ミリ秒)。

Blocking

Boolean (ブール)

false の場合、再接続戦略が個別の非ブロックスレッドで実行されます。

Count (数)

Number (数値)

Mule アプリケーションで実行できる再接続の試行回数。

### [](#ReconnectForever)Reconnect Forever (繰り返し再接続) Mule アプリケーションが実行されている間はコネクタソースや操作によって指定された頻度で再接続が試行される Forever 再接続戦略を設定します。

項目型説明デフォルト値必須

項目	型	説明	デフォルト値	必須
Frequency (頻度)	Number (数値)	再接続を試行する頻度 (ミリ秒)。
Blocking	Boolean (ブール)	`false` の場合、再接続戦略が個別の非ブロックスレッドで実行されます。

Frequency (頻度)

Number (数値)

再接続を試行する頻度 (ミリ秒)。

Blocking

Boolean (ブール)

false の場合、再接続戦略が個別の非ブロックスレッドで実行されます。

### [](#ExpirationPolicy)Expiration Policy (有効期限ポリシー)

項目	型	説明	デフォルト値	必須
Max Idle Time (最大アイドル時間)	Number (数値)	動的設定インスタンスがアイドル状態を続けられる最大時間を設定します。この時間が経過すると、Mule Runtime で期限切れに相当するとみなされます。
Time Unit (時間単位)	Enumeration (列挙)。次のいずれかになります。 NANOSECONDS (ナノ秒) MICROSECONDS (マイクロ秒) MILLISECONDS (ミリ秒) SECONDS (秒) MINUTES (分) HOURS (時間) DAYS (日)	[Max Idle Time (最大アイドル時間)] 項目の時間単位。

項目

型

説明

デフォルト値

必須

Max Idle Time (最大アイドル時間)

Number (数値)

動的設定インスタンスがアイドル状態を続けられる最大時間を設定します。この時間が経過すると、Mule Runtime で期限切れに相当するとみなされます。

Time Unit (時間単位)

Enumeration (列挙)。次のいずれかになります。

NANOSECONDS (ナノ秒)
MICROSECONDS (マイクロ秒)
MILLISECONDS (ミリ秒)
SECONDS (秒)
MINUTES (分)
HOURS (時間)
DAYS (日)

[Max Idle Time (最大アイドル時間)] 項目の時間単位。

### [](#RepeatableInMemoryStream)Repeatable In Memory Stream (反復可能なメモリ内ストリーム) データが最大バッファサイズを超えた場合に要求が失敗するメモリ内ストリーミング戦略を設定します。ユースケースで最適なバッファサイズは、必ずパフォーマンステストを実施して決めてください。

項目型説明デフォルト値必須

項目	型	説明
Initial Buffer Size (初期バッファサイズ)	Number (数値)	データストリームに割り当てるメモリの初期容量。ストリーミングされたデータがこの値を超える場合は、[Buffer Size Increment (バッファサイズ増分)] の単位で [Max In Memory Size (最大メモリ内サイズ)] 値を上限としてバッファが拡張されます。
Buffer Size Increment (バッファサイズ増分)	Number (数値)	バッファサイズが初期サイズを超えた場合に、拡張する量。値を `0` またはそれ以下に設定すると、バッファは拡張されません。
Max Buffer Size (最大バッファサイズ)	Number (数値)	バッファの最大サイズ。バッファサイズがこの値を超える場合、`STREAM_MAXIMUM_SIZE_EXCEEDED` エラーが発生します。`0` 以下の値は無制限を意味します。
Buffer Unit (バッファ単位)	Enumeration (列挙)。次のいずれかになります。 BYTE (バイト) KB MB GB	[Initial Buffer Size (初期バッファサイズ)] 項目、[Buffer Size Increment (バッファサイズ増分)] 項目、[Buffer Unit (バッファ単位)] 項目の単位。

Initial Buffer Size (初期バッファサイズ)

Number (数値)

データストリームに割り当てるメモリの初期容量。ストリーミングされたデータがこの値を超える場合は、[Buffer Size Increment (バッファサイズ増分)] の単位で [Max In Memory Size (最大メモリ内サイズ)] 値を上限としてバッファが拡張されます。

Buffer Size Increment (バッファサイズ増分)

Number (数値)

バッファサイズが初期サイズを超えた場合に、拡張する量。値を 0 またはそれ以下に設定すると、バッファは拡張されません。

Max Buffer Size (最大バッファサイズ)

Number (数値)

バッファの最大サイズ。バッファサイズがこの値を超える場合、STREAM_MAXIMUM_SIZE_EXCEEDED エラーが発生します。0 以下の値は無制限を意味します。

Buffer Unit (バッファ単位)

Enumeration (列挙)。次のいずれかになります。

BYTE (バイト)
KB
MB
GB

[Initial Buffer Size (初期バッファサイズ)] 項目、[Buffer Size Increment (バッファサイズ増分)] 項目、[Buffer Unit (バッファ単位)] 項目の単位。

### [](#RepeatableFileStoreStream)Repeatable File Store Stream (反復可能なファイルストアストリーム) 反復可能なファイルストアストリーミング戦略を設定します。この戦略では、ストリームコンテンツの一部がメモリ内に格納されます。ストリームのコンテンツが、設定されたバッファサイズよりも大きい場合、Mule はバッファのコンテンツをディスクにバックアップしてからメモリをクリアします。

項目	型	説明	デフォルト値	必須
In Memory Size (メモリ内サイズ)	Number (数値)	ストリームのデータで使用できるメモリの最大量。メモリ量がこの値を超えると、コンテンツはディスクにバッファされます。パフォーマンスを最適化する方法は、次のとおりです。バッファサイズを大きくすると、Mule がバッファをディスクに書き込む回数を減らせます。これによってパフォーマンスが高まりますが、より多くのメモリが必要になるため、アプリケーションが処理できる同時要求数が制限されます。バッファサイズを小さくすると、メモリの負荷は低減しますが、応答時間が長くなります。
Buffer Unit (バッファ単位)	Enumeration (列挙)。次のいずれかになります。 BYTE (バイト) KB MB GB	[In Memory Size (メモリ内サイズ)] 項目の単位。

項目

型

説明

デフォルト値

必須

In Memory Size (メモリ内サイズ)

Number (数値)

ストリームのデータで使用できるメモリの最大量。メモリ量がこの値を超えると、コンテンツはディスクにバッファされます。パフォーマンスを最適化する方法は、次のとおりです。

バッファサイズを大きくすると、Mule がバッファをディスクに書き込む回数を減らせます。これによってパフォーマンスが高まりますが、より多くのメモリが必要になるため、アプリケーションが処理できる同時要求数が制限されます。
バッファサイズを小さくすると、メモリの負荷は低減しますが、応答時間が長くなります。

Buffer Unit (バッファ単位)

Enumeration (列挙)。次のいずれかになります。

BYTE (バイト)
KB
MB
GB

[In Memory Size (メモリ内サイズ)] 項目の単位。

### [](#RedeliveryPolicy)Redelivery Policy (再配信ポリシー) エラーを生成する要求を実行するための再配信ポリシーを設定します。再配信ポリシーは、フロー内のあらゆる提供元に追加できます。

項目型説明デフォルト値必須

項目	型	説明
Max Redelivery Count (最大再配信数)	Number (数値)	再配信される要求の最大処理失敗回数。この回数を超えると、REDELIVERY_EXHAUSTED エラーが返されます。
Message Digest Algorithm (メッセージダイジェストアルゴリズム)	String (文字列)	[Use Secure Hash (セキュアハッシュを使用)] 項目が `true` の場合に使用するセキュアハッシュアルゴリズム。メッセージのペイロードが Java オブジェクトの場合、Mule ではこの値が無視され、ペイロードの `hashCode()` が返した値が返されます。
Message Identifier (メッセージ識別子)	Redelivery Policy Message Identifier (再配信ポリシーメッセージ識別子)	メッセージを識別するために使用する戦略を定義します。
Object Store (オブジェクトストア)	ObjectStore	各メッセージの再配信カウンターが保存されるオブジェクトストアを設定します。

Max Redelivery Count (最大再配信数)

Number (数値)

再配信される要求の最大処理失敗回数。この回数を超えると、REDELIVERY_EXHAUSTED エラーが返されます。

Message Digest Algorithm (メッセージダイジェストアルゴリズム)

String (文字列)

[Use Secure Hash (セキュアハッシュを使用)] 項目が true の場合に使用するセキュアハッシュアルゴリズム。メッセージのペイロードが Java オブジェクトの場合、Mule ではこの値が無視され、ペイロードの hashCode() が返した値が返されます。

Message Identifier (メッセージ識別子)

Redelivery Policy Message Identifier (再配信ポリシーメッセージ識別子)

メッセージを識別するために使用する戦略を定義します。

Object Store (オブジェクトストア)

ObjectStore

各メッセージの再配信カウンターが保存されるオブジェクトストアを設定します。

### [](#RedeliveryPolicyMessageIdentifier)Redelivery Policy Message Identifier (再配信ポリシーメッセージ識別子) 再配信されたメッセージを識別する方法と、メッセージがいつ再配信されたのかを見つける方法を設定します。

項目型説明デフォルト値必須

項目	型	説明	デフォルト値	必須
Use Secure Hash (セキュアハッシュを使用)	Boolean (ブール)	`true` の場合、Mule では再配信されたメッセージの識別にセキュアハッシュアルゴリズムを使用します。
Id Expression (ID 式)	String (文字列)	メッセージがいつ再配信されたのかを判断する 1 つ以上の式。このプロパティは、[Use Secure Hash (セキュアハッシュを使用)] 項目が `false` の場合にのみ設定できます。

Use Secure Hash (セキュアハッシュを使用)

Boolean (ブール)

true の場合、Mule では再配信されたメッセージの識別にセキュアハッシュアルゴリズムを使用します。

Id Expression (ID 式)

String (文字列)

メッセージがいつ再配信されたのかを判断する 1 つ以上の式。このプロパティは、[Use Secure Hash (セキュアハッシュを使用)] 項目が false の場合にのみ設定できます。

### [](#Snapshot)Snapshot (スナップショット) スナップショットリソース。スナップショットを Seek 操作で使用して、メッセージの肯定応答を一括管理できます。この種別では、既存のサブスクリプションのメッセージの肯定応答状態をスナップショットで取得された状態に設定できます。

項目	型	説明
Name (名前)	String (文字列)	スナップショットの名前。
Topic (トピック)	String (文字列)	トピックの名前。スナップショットはこのトピックからメッセージを保持します。
Expire Time (有効期限 (時間))	DateTime	スナップショットの存続が保証される時間の長さ。新規作成されるスナップショットの有効期間は、ソースサブスクリプションのバックログ内にある最も未応答のメッセージに基づきますが、スナップショットは最長 7 日間存続できます。サブスクリプションに 3 日前から存続する最も古い未応答のメッセージがあるとします。このサブスクリプションからスナップショットが作成されると、その有効期間は 4 日間になります。作成後 1 時間未満で期限切れになるスナップショットの作成はサービスで拒否されます。タイムスタンプは RFC3339 UTC Zulu 形式で分解能はナノ秒、小数部は最大 9 桁です (2014-10-02T15:01:23Z、2014-10-02T15:01:23.045123456Z など)。
Labels (ラベル)	Any (任意)	キー-値ペアのリスト ({ "name": "wrench", "mass": "1.3kg", "count": "3" } など) が含まれるオブジェクト

項目

型

説明

デフォルト値

必須

Name (名前)

String (文字列)

スナップショットの名前。

Topic (トピック)

String (文字列)

トピックの名前。スナップショットはこのトピックからメッセージを保持します。

Expire Time (有効期限 (時間))

DateTime

スナップショットの存続が保証される時間の長さ。新規作成されるスナップショットの有効期間は、ソースサブスクリプションのバックログ内にある最も未応答のメッセージに基づきますが、スナップショットは最長 7 日間存続できます。

サブスクリプションに 3 日前から存続する最も古い未応答のメッセージがあるとします。このサブスクリプションからスナップショットが作成されると、その有効期間は 4 日間になります。作成後 1 時間未満で期限切れになるスナップショットの作成はサービスで拒否されます。

タイムスタンプは RFC3339 UTC Zulu 形式で分解能はナノ秒、小数部は最大 9 桁です (2014-10-02T15:01:23Z、2014-10-02T15:01:23.045123456Z など)。

Labels (ラベル)

Any (任意)

キー-値ペアのリスト ({ "name": "wrench", "mass": "1.3kg", "count": "3" } など) が含まれるオブジェクト

### [](#RepeatableInMemoryIterable)Repeatable In Memory Iterable (反復可能なメモリ内イテラブル)

項目	型	説明	デフォルト値
Initial Buffer Size (初期バッファサイズ)	Number (数値)	ストリームを使用し、ランダムアクセスを提供するために、最初にメモリ内に保持するインスタンスの数。ストリームのデータ量がこのバッファサイズを超える場合は、[Buffer Size Increment (バッファサイズ増分)] 項目に従って、[Max In Memory Size (最大メモリ内サイズ)] を上限としてバッファが拡張されます。	100
Buffer Size Increment (バッファサイズ増分)	Number (数値)	バッファサイズが初期サイズを超えた場合に、どれだけ拡張するか。値を 0 以下に設定すると、バッファが拡張されません。つまり、バッファがフルになると、STREAM_MAXIMUM_SIZE_EXCEEDED エラーが発生します。	100
Max Buffer Size (最大バッファサイズ)	Number (数値)	使用するメモリの最大量。これを超えると、STREAM_MAXIMUM_SIZE_EXCEEDED エラーが発生します。0 以下の値は無制限を意味します。

項目

型

説明

デフォルト値

必須

Initial Buffer Size (初期バッファサイズ)

Number (数値)

ストリームを使用し、ランダムアクセスを提供するために、最初にメモリ内に保持するインスタンスの数。ストリームのデータ量がこのバッファサイズを超える場合は、[Buffer Size Increment (バッファサイズ増分)] 項目に従って、[Max In Memory Size (最大メモリ内サイズ)] を上限としてバッファが拡張されます。

100

Buffer Size Increment (バッファサイズ増分)

Number (数値)

バッファサイズが初期サイズを超えた場合に、どれだけ拡張するか。値を 0 以下に設定すると、バッファが拡張されません。つまり、バッファがフルになると、STREAM_MAXIMUM_SIZE_EXCEEDED エラーが発生します。

100

Max Buffer Size (最大バッファサイズ)

Number (数値)

使用するメモリの最大量。これを超えると、STREAM_MAXIMUM_SIZE_EXCEEDED エラーが発生します。0 以下の値は無制限を意味します。

### [](#RepeatableFileStoreIterable)Repeatable File Store Iterable (反復可能なファイルストアイテラブル)

項目	型	説明	デフォルト値	必須
In Memory Objects (メモリ内オブジェクト)	Number (数値)	メモリ内に保持されるインスタンスの最大数。これ以上の量が必要な場合、ディスク上のコンテンツがバッファされます。
Buffer Unit (バッファ単位)	Enumeration (列挙)。次のいずれかになります。 BYTE (バイト) KB MB GB	[In Memory Objects (メモリ内オブジェクト)] 項目の単位。

項目

型

説明

デフォルト値

必須

In Memory Objects (メモリ内オブジェクト)

Number (数値)

メモリ内に保持されるインスタンスの最大数。これ以上の量が必要な場合、ディスク上のコンテンツがバッファされます。

Buffer Unit (バッファ単位)

Enumeration (列挙)。次のいずれかになります。

BYTE (バイト)
KB
MB
GB

[In Memory Objects (メモリ内オブジェクト)] 項目の単位。

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