クラスの使用
org.springframework.batch.integration.chunk.RemoteChunkingManagerStepBuilder
RemoteChunkingManagerStepBuilder を使用するパッケージ
org.springframework.batch.integration.chunk 内の RemoteChunkingManagerStepBuilder 使用
修飾子と型メソッド説明RemoteChunkingManagerStepBuilder.allowStartIfComplete(boolean allowStartIfComplete) RemoteChunkingManagerStepBuilder.backOffPolicy(org.springframework.retry.backoff.BackOffPolicy backOffPolicy) RemoteChunkingManagerStepBuilder.chunk(int chunkSize) RemoteChunkingManagerStepBuilder.chunk(CompletionPolicy completionPolicy) RemoteChunkingManagerStepBuilder.chunkOperations(RepeatOperations repeatTemplate) RemoteChunkingManagerStepBuilder.exceptionHandler(ExceptionHandler exceptionHandler) <I,O> RemoteChunkingManagerStepBuilder<I, O> RemoteChunkingManagerStepBuilderを作成し、そのジョブリポジトリとトランザクションマネージャーを初期化します。RemoteChunkingManagerStepBuilder.inputChannel(org.springframework.messaging.PollableChannel inputChannel) ワーカーからの応答を受信する入力チャネルを設定します。RemoteChunkingManagerStepBuilder.keyGenerator(KeyGenerator keyGenerator) RemoteChunkingManagerStepBuilder.listener(ChunkListener listener) RemoteChunkingManagerStepBuilder.listener(ItemReadListener<? super I> listener) RemoteChunkingManagerStepBuilder.listener(ItemWriteListener<? super O> listener) RemoteChunkingManagerStepBuilder.listener(SkipListener<? super I, ? super O> listener) RemoteChunkingManagerStepBuilder.listener(StepExecutionListener listener) RemoteChunkingManagerStepBuilder.listener(org.springframework.retry.RetryListener listener) RemoteChunkingManagerStepBuilder.maxWaitTimeouts(int maxWaitTimeouts) リモートワーカーからの null 以外の結果をステップの最後で待機する最大回数。RemoteChunkingManagerStepBuilder.messagingTemplate(org.springframework.integration.core.MessagingTemplate messagingTemplate) ワーカーにデータを送信するために使用するMessagingTemplateを設定します。RemoteChunkingManagerStepBuilder.noRetry(ClassSE<? extends ThrowableSE> type) RemoteChunkingManagerStepBuilder.noRollback(ClassSE<? extends ThrowableSE> type) RemoteChunkingManagerStepBuilder.noSkip(ClassSE<? extends ThrowableSE> type) RemoteChunkingManagerStepBuilder.outputChannel(org.springframework.messaging.MessageChannel outputChannel) ワーカーへのリクエストが送信される出力チャネルを設定します。RemoteChunkingManagerStepBuilder.processor(ItemProcessor<? super I, ? extends O> itemProcessor) RemoteChunkingManagerStepBuilder.reader(ItemReader<? extends I> reader) RemoteChunkingManagerStepBuilder.readerIsTransactionalQueue()RemoteChunkingManagerStepBuilder.repository(JobRepository jobRepository) 非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。RemoteChunkingManagerStepBuilder.retry(ClassSE<? extends ThrowableSE> type) RemoteChunkingManagerStepBuilder.retryContextCache(org.springframework.retry.policy.RetryContextCache retryContextCache) RemoteChunkingManagerStepBuilder.retryLimit(int retryLimit) RemoteChunkingManagerStepBuilder.retryPolicy(org.springframework.retry.RetryPolicy retryPolicy) RemoteChunkingManagerStepBuilder.skip(ClassSE<? extends ThrowableSE> type) RemoteChunkingManagerStepBuilder.skipLimit(int skipLimit) RemoteChunkingManagerStepBuilder.skipPolicy(SkipPolicy skipPolicy) RemoteChunkingManagerStepBuilder.startLimit(int startLimit) RemoteChunkingManagerStepBuilder.stepOperations(RepeatOperations repeatTemplate) RemoteChunkingManagerStepBuilder.stream(ItemStream stream) RemoteChunkingManagerStepBuilder.throttleLimit(long throttleLimit) スロットル制限のパブリック setter。RemoteChunkingManagerStepBuilder.transactionAttribute(org.springframework.transaction.interceptor.TransactionAttribute transactionAttribute) RemoteChunkingManagerStepBuilder.transactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager) RemoteChunkingManagerStepBuilder.writer(ItemWriter<? super O> writer) このメソッドはUnsupportedOperationExceptionSE をスローします。これは、リモートチャンク設定のマネージャーステップのアイテムライターが自動的にChunkMessageChannelItemWriterのインスタンスに設定されるためです。
RemoteChunkingManagerStepBuilder(String, JobRepository)を使用