42.5. エンドポイントオプション

bucketName (common)

必須 のバケット名。

String

autoCreateBucket (common)

バケット名が存在しない場合のバケットの自動作成の設定。

true

boolean

customHttpClient (common)

認証済みアクセス用のカスタム HTTP クライアントを設定します。

OkHttpClient

endpoint (common)

エンドポイントには、URL、ドメイン名、IPv4 アドレス、または IPv6 アドレスを指定できます。

String

minioClient (common)

レジストリー内の Minio Client オブジェクトへの Autowired 参照。

MinioClient

objectLock (common)

バケットの新規作成時に設定します。

false

boolean

policy (common)

メソッドで設定するこのキューのポリシー。

String

proxyPort (common)

TCP/IP ポート番号。HTTP と HTTPS のデフォルトとして 80 と 443 が使用されます。

Integer

region (common)

Minio クライアントが動作する必要がある地域。このパラメーターを使用する場合、設定はリージョンの小文字の名前 (ap-east-1 など) を想定します。Region.EU_WEST_1.id() という名前を使用する必要があります。

String

secure (common)

minio サービスへのセキュアな接続を使用するかどうかを示すフラグ。

false

boolean

serverSideEncryption (common)

サーバー側の暗号化。

ServerSideEncryption

serverSideEncryptionCustomerKey (common)

オブジェクトのコピー/移動中のソースオブジェクトのサーバー側暗号化。

ServerSideEncryptionCustomerKey

autoCloseBody (consumer)

このオプションが true で、includeBody が true の場合、エクスチェンジの完了時に MinioObject.close() メソッドが呼び出されます。このオプションは includeBody オプションと密接に関係しています。includeBody を true に設定し、autocloseBody を false に設定した場合、MinioObject ストリームを閉じるのは呼び出し元次第です。autocloseBody を true に設定すると、MinioObject ストリームが自動的に閉じられます。

true

boolean

bypassGovernanceMode (consumer)

特定のオブジェクトを削除するときに GovernanceMode をバイパスする場合は、このフラグを設定します。

false

boolean

deleteAfterRead (consumer)

オブジェクトが取得された後、Minio からオブジェクトを削除します。削除は、エクスチェンジがコミットされた場合にのみ実行されます。ロールバックが発生すると、オブジェクトは削除されません。このオプションが false の場合、同じオブジェクトがポーリングで繰り返し取得されます。そのため、ルートで Idempotent Consumer EIP を使用して重複を除外する必要があります。MinioConstants#BUCKET_NAME および MinioConstants#OBJECT_NAME ヘッダー、または MinioConstants#OBJECT_NAME ヘッダーのみを使用してフィルタリングできます。

true

boolean

delimiter (consumer)

関心のあるオブジェクトのみを使用するために ListObjectsRequest で使われる区切り文字。

String

destinationBucketName (consumer)

ソースバケット名。

String

destinationObjectName (consumer)

ソースオブジェクト名。

String

includeBody (consumer)

true の場合、エクスチェンジ本文はファイルの内容へのストリームに設定されます。false の場合、ヘッダーには Minio オブジェクトのメタデータが設定されますが、本文は null になります。このオプションは、autocloseBody オプションと密接に関係します。includeBody を true に設定し、autocloseBody を false に設定した場合、MinioObject ストリームを閉じるのは呼び出し元次第です。autocloseBody を true に設定すると、MinioObject ストリームが自動的に閉じられます。

true

boolean

includeFolders (consumer)

インクルードフォルダーを設定するために ListObjectsRequest で使用されるフラグ。

false

boolean

includeUserMetadata (consumer)

ユーザーメタデータを持つオブジェクトを取得するために ListObjectsRequest で使用されるフラグ。

false

boolean

includeVersions (consumer)

バージョン管理されたオブジェクトを取得するために ListObjectsRequest で使用されるフラグ。

false

boolean

length (consumer)

オフセットからのオブジェクトデータのバイト数。

long

matchETag (consumer)

get オブジェクトの一致 ETag パラメーターを設定します。

String

maxConnections (consumer)

minio クライアント設定で maxConnections パラメーターを設定します。

60

int

maxMessagesPerPoll (consumer)

各ポーリングのポーリング制限としてメッセージの最大数を取得します。各ポーリングのポーリング制限としてメッセージの最大数を取得します。デフォルト値は 10 です。0 または負の値を使用すると、無制限として設定されます。

10

int

modifiedSince (consumer)

get オブジェクトの modified since パラメーターを設定します。

ZonedDateTime

moveAfterRead (consumer)

オブジェクトの取得後にバケットから別のバケットに移動します。操作を実行するには、destinationBucket オプションを設定する必要があります。copy bucket 操作は、エクスチェンジがコミットされた場合にのみ実行されます。ロールバックが発生した場合、オブジェクトは移動しません。

false

boolean

notMatchETag (consumer)

get オブジェクトの一致しない ETag パラメーターを設定します。

String

objectName (consumer)

指定されたオブジェクト名でバケットからオブジェクトを取得します。

String

offset (consumer)

オブジェクトデータの開始バイト位置。

long

prefix (consumer)

オブジェクト名は接頭辞で始まります。

String

recursive (consumer)

ディレクトリー構造エミュレーションよりも再帰的にリストします。

false

boolean

sendEmptyMessageWhenIdle (consumer)

ポーリング consumer がファイルをポーリングしなかった場合、このオプションを有効にして、代わりに空のメッセージ (ボディーなし) を送信できます。

false

boolean

startAfter (consumer)

このオブジェクト名の後にバケット内のオブジェクトをリストします。

String

unModifiedSince (consumer)

オブジェクトを取得するためのパラメーターを un modified since に設定します。

ZonedDateTime

useVersion1 (consumer)

true の場合、REST API のバージョン 1 が使用されます。

false

boolean

versionId (consumer)

オブジェクトを削除するときに、オブジェクトの特定の version_ID を設定します。

String

bridgeErrorHandler (consumer (advanced))

コンシューマーの Camel ルーティングエラーハンドラーへのブリッジを許可します。よって、コンシューマーが受信メッセージなどの取得を試行している間に発生した例外は、メッセージとして処理され、ルーティングエラーハンドラーによって処理されます。デフォルトでは、consumer は org.apache.camel.spi.ExceptionHandler を使用して例外に対応し、WARN または ERROR レベルでログに記録され、無視されます。

false

boolean

exceptionHandler (consumer (advanced))

consumer によるカスタム ExceptionHandler の使用を許可します。bridgeErrorHandler オプションが有効な場合は、このオプションは使用されないことに注意してください。デフォルトでは、consumer は例外に対応し、WARN または ERROR レベルでログに記録され、無視されます。

ExceptionHandler

exchangePattern (consumer (advanced))

consumer がエクスチェンジを作成する際に交換パターンを設定します。

列挙値:

ExchangePattern

pollStrategy (consumer (advanced))

プラグ可能な org.apache.camel.PollingConsumerPollingStrategy を使用すると、エクスチェンジが作成され、Camel でルーティングされる前に、通常はポーリング操作中に発生するエラー処理を制御するカスタム実装が提供できます。

PollingConsumerPollStrategy

deleteAfterWrite (producer)

Minio ファイルがアップロードされた後、ファイルオブジェクトを削除します。

false

boolean

keyName (producer)

endpoint パラメーター経由でバケットの要素のキー名を設定します。

String

operation (producer)

ユーザーがアップロードだけをしたくない場合に行う操作。

列挙値:

MinioOperations

pojoRequest (producer)

POJO リクエストをボディーとして使用するかどうか。

false

boolean

storageClass (producer)

リクエストで設定するストレージクラス。

String

lazyStartProducer (producer (advanced))

最初のメッセージでプロデューサーをレイジーに起動すべきかどうか。レイジーに起動することで、起動時に producer が失敗し、それによりルートが失敗する可能性がある状況で、CamelContext およびルートの起動を許可します。レイジーな起動を延期すると、Camel のルーティングエラーハンドラー経由でメッセージのルーティング中に起動の失敗を処理できます。最初のメッセージが処理されるときに、producer の作成および起動に若干時間がかかり、合計処理時間が長くなる可能性があることに注意してください。

false

boolean

backoffErrorThreshold (scheduler)

backoffMultipler が開始する前に発生する必要がある後続のエラーポーリング (エラーによって失敗した) の数。

int

backoffIdleThreshold (scheduler)

backoffMultipler が開始する前に発生する必要がある後続のアイドルポーリングの数。

int

backoffMultiplier (scheduler)

後続のアイドル状態/エラーが連続して発生した場合に、スケジュールされたポーリング consumer のバックオフを許可します。乗数は、実際に次の試行が行われる前にスキップされるポーリングの数です。このオプションが使用されている場合は、backoffIdleThreshold や backoffErrorThreshold も設定する必要があります。

int

delay (scheduler)

次のポーリングまでの時間 (ミリ秒単位)。

500

long

greedy (scheduler)

greedy が有効で、以前の実行が 1 つ以上のメッセージをポーリングした場合、ScheduledPollConsumer は即座に再度実行されます。

false

boolean

initialDelay (scheduler)

最初のポーリングが開始されるまでの時間 (ミリ秒単位)。

1000

long

repeatCount (scheduler)

実行の最大数を指定します。そのため、これを 1 に設定するとスケジューラーは 1 度だけ実行されます。これを 5 に設定した場合、5 回だけ実行されます。0 または負の値を設定すると、無制限に実行されます。

0

long

runLoggingLevel (scheduler)

consumer はポーリング時に開始/完了のログ行を記録します。このオプションを使用すると、ログレベルを設定できます。

列挙値:

TRACE

LoggingLevel

scheduledExecutorService (scheduler)

consumer に使用するカスタム/共有スレッドプールを設定できます。デフォルトでは、各 consumer に独自の単一スレッドのスレッドプールがあります。

ScheduledExecutorService

scheduler (scheduler)

camel-spring または camel-quartz コンポーネントから cron スケジューラーを使用します。スケジューラーにビルドされた値 spring または quartz を使用。

none

Object

schedulerProperties (scheduler)

カスタムスケジューラーまたは Quartz や Spring ベースのスケジューラーを使用する場合に、追加のプロパティーを設定します。

Map

startScheduler (scheduler)

スケジューラーを自動起動するかどうか。

true

boolean

timeUnit (scheduler)

initialDelay および delay オプションの時間単位。

列挙値:

MILLISECONDS

TimeUnit

useFixedDelay (scheduler)

固定遅延または固定レートを使用するかどうかを制御します。詳細は、JDK の ScheduledExecutorService を参照してください。

true

boolean

accessKey (security)

Amazon AWS シークレットアクセスキーまたは Minio アクセスキー。設定されていない場合、camel は匿名アクセスのためにサービスに接続します。

String

secretKey (security)

Amazon AWS アクセスキー ID または Minio シークレットキー。設定されていない場合、camel は匿名アクセスのためにサービスに接続します。

String