类 RemoteChunkingMasterStepBuilder<I,​O>

构造器详细资料

• RemoteChunkingMasterStepBuilder

  public RemoteChunkingMasterStepBuilder​(java.lang.String stepName)

  Create a new RemoteChunkingMasterStepBuilder.

  参数:

  stepName - name of the master step

方法详细资料

• inputChannel

  public RemoteChunkingMasterStepBuilder<I,​O> inputChannel​(org.springframework.messaging.PollableChannel inputChannel)

  Set the input channel on which replies from workers will be received. The provided input channel will be set as a reply channel on the ChunkMessageChannelItemWriter created by this builder.

  参数:

  inputChannel - the input channel

  返回:

  this builder instance for fluent chaining

  另请参阅:

  ChunkMessageChannelItemWriter.setReplyChannel(org.springframework.messaging.PollableChannel)

• outputChannel

  public RemoteChunkingMasterStepBuilder<I,​O> outputChannel​(org.springframework.messaging.MessageChannel outputChannel)

  Set the output channel on which requests to workers will be sent. By using this setter, a default messaging template will be created and the output channel will be set as its default channel.

  Use either this setter or messagingTemplate(MessagingTemplate) to provide a fully configured messaging template.

  参数:

  outputChannel - the output channel.

  返回:

  this builder instance for fluent chaining

  另请参阅:

  messagingTemplate(MessagingTemplate)

• messagingTemplate

  public RemoteChunkingMasterStepBuilder<I,​O> messagingTemplate​(org.springframework.integration.core.MessagingTemplate messagingTemplate)

  Set the MessagingTemplate to use to send data to workers. The default channel of the messaging template must be set.

  Use either this setter to provide a fully configured messaging template or provide an output channel through outputChannel(MessageChannel) and a default messaging template will be created.

  参数:

  messagingTemplate - the messaging template to use

  返回:

  this builder instance for fluent chaining

  另请参阅:

  outputChannel(MessageChannel)

• maxWaitTimeouts

  public RemoteChunkingMasterStepBuilder<I,​O> maxWaitTimeouts​(int maxWaitTimeouts)

  The maximum number of times to wait at the end of a step for a non-null result from the remote workers. This is a multiplier on the receive timeout set separately on the gateway. The ideal value is a compromise between allowing slow workers time to finish, and responsiveness if there is a dead worker. Defaults to 40.

  参数:

  maxWaitTimeouts - the maximum number of wait timeouts

  另请参阅:

  ChunkMessageChannelItemWriter.setMaxWaitTimeouts(int)

• throttleLimit

  public RemoteChunkingMasterStepBuilder<I,​O> throttleLimit​(long throttleLimit)

  Public setter for the throttle limit. This limits the number of pending requests for chunk processing to avoid overwhelming the receivers.

  参数:

  throttleLimit - the throttle limit to set

  另请参阅:

  ChunkMessageChannelItemWriter.setThrottleLimit(long)

• build

  public TaskletStep build()

  Build a master TaskletStep.

  覆盖:

  build 在类中 FaultTolerantStepBuilder<I,​O>

  返回:

  the configured master step

  另请参阅:

  RemoteChunkHandlerFactoryBean

• reader

  public RemoteChunkingMasterStepBuilder<I,​O> reader​(ItemReader<? extends I> reader)

  从类复制的说明: SimpleStepBuilder
  An item reader that provides a stream of items. Will be automatically registered as a AbstractTaskletStepBuilder.stream(ItemStream) or listener if it implements the corresponding interface. By default assumed to be non-transactional.

  覆盖:

  reader 在类中 SimpleStepBuilder<I,​O>

  参数:

  reader - an item reader

  返回:

  this for fluent chaining

  另请参阅:

  SimpleStepBuilder.readerTransactionalQueue

• repository

  public RemoteChunkingMasterStepBuilder<I,​O> repository​(JobRepository jobRepository)

  覆盖:

  repository 在类中 StepBuilderHelper<AbstractTaskletStepBuilder<SimpleStepBuilder<I,​O>>>

• transactionManager

  public RemoteChunkingMasterStepBuilder<I,​O> transactionManager​(org.springframework.transaction.PlatformTransactionManager transactionManager)

  覆盖:

  transactionManager 在类中 StepBuilderHelper<AbstractTaskletStepBuilder<SimpleStepBuilder<I,​O>>>

• listener

  public RemoteChunkingMasterStepBuilder<I,​O> listener​(java.lang.Object listener)

  从类复制的说明: FaultTolerantStepBuilder
  Registers objects using the annotation based listener configuration.

  覆盖:

  listener 在类中 FaultTolerantStepBuilder<I,​O>

  参数:

  listener - the object that has a method configured with listener annotation

  返回:

  this for fluent chaining

• listener

  public RemoteChunkingMasterStepBuilder<I,​O> listener​(SkipListener<? super I,​? super O> listener)

  从类复制的说明: FaultTolerantStepBuilder
  Register a skip listener.

  覆盖:

  listener 在类中 FaultTolerantStepBuilder<I,​O>

  参数:

  listener - the listener to register

  返回:

  this for fluent chaining

• listener

  public RemoteChunkingMasterStepBuilder<I,​O> listener​(ChunkListener listener)

  从类复制的说明: AbstractTaskletStepBuilder
  Register a chunk listener.

  覆盖:

  listener 在类中 FaultTolerantStepBuilder<I,​O>

  参数:

  listener - the listener to register

  返回:

  this for fluent chaining

• transactionAttribute

  public RemoteChunkingMasterStepBuilder<I,​O> transactionAttribute​(org.springframework.transaction.interceptor.TransactionAttribute transactionAttribute)

  从类复制的说明: AbstractTaskletStepBuilder
  Sets the transaction attributes for the tasklet execution. Defaults to the default values for the transaction manager, but can be manipulated to provide longer timeouts for instance.

  覆盖:

  transactionAttribute 在类中 FaultTolerantStepBuilder<I,​O>

  参数:

  transactionAttribute - a transaction attribute set

  返回:

  this for fluent chaining

• listener

  public RemoteChunkingMasterStepBuilder<I,​O> listener​(org.springframework.retry.RetryListener listener)

  从类复制的说明: FaultTolerantStepBuilder
  Register a retry listener.

  覆盖:

  listener 在类中 FaultTolerantStepBuilder<I,​O>

  参数:

  listener - the listener to register

  返回:

  this for fluent chaining

• keyGenerator

  public RemoteChunkingMasterStepBuilder<I,​O> keyGenerator​(KeyGenerator keyGenerator)

  从类复制的说明: FaultTolerantStepBuilder
  Sets the key generator for identifying retried items. Retry across transaction boundaries requires items to be identified when they are encountered again. The default strategy is to use the items themselves, relying on their own implementation to ensure that they can be identified. Often a key generator is not necessary as long as the items have reliable hash code and equals implementations, or the reader is not transactional (the default) and the item processor either is itself not transactional (not the default) or does not create new items.

  覆盖:

  keyGenerator 在类中 FaultTolerantStepBuilder<I,​O>

  参数:

  keyGenerator - a key generator for the stateful retry

  返回:

  this for fluent chaining

• retryLimit

  public RemoteChunkingMasterStepBuilder<I,​O> retryLimit​(int retryLimit)

  从类复制的说明: FaultTolerantStepBuilder
  The maximum number of times to try a failed item. Zero and one both translate to try only once and do not retry. Ignored if an explicit FaultTolerantStepBuilder.retryPolicy is set.

  覆盖:

  retryLimit 在类中 FaultTolerantStepBuilder<I,​O>

  参数:

  retryLimit - the retry limit (default 0)

  返回:

  this for fluent chaining

• retryPolicy

  public RemoteChunkingMasterStepBuilder<I,​O> retryPolicy​(org.springframework.retry.RetryPolicy retryPolicy)

  从类复制的说明: FaultTolerantStepBuilder
  Provide an explicit retry policy instead of using the FaultTolerantStepBuilder.retryLimit(int) and retryable exceptions provided elsewhere. Can be used to retry different exceptions a different number of times, for instance.

  覆盖:

  retryPolicy 在类中 FaultTolerantStepBuilder<I,​O>

  参数:

  retryPolicy - a retry policy

  返回:

  this for fluent chaining

• backOffPolicy

  public RemoteChunkingMasterStepBuilder<I,​O> backOffPolicy​(org.springframework.retry.backoff.BackOffPolicy backOffPolicy)

  从类复制的说明: FaultTolerantStepBuilder
  Provide a backoff policy to prevent items being retried immediately (e.g. in case the failure was caused by a remote resource failure that might take some time to be resolved). Ignored if an explicit FaultTolerantStepBuilder.retryPolicy is set.

  覆盖:

  backOffPolicy 在类中 FaultTolerantStepBuilder<I,​O>

  参数:

  backOffPolicy - the back off policy to use (default no backoff)

  返回:

  this for fluent chaining

• retryContextCache

  public RemoteChunkingMasterStepBuilder<I,​O> retryContextCache​(org.springframework.retry.policy.RetryContextCache retryContextCache)

  从类复制的说明: FaultTolerantStepBuilder
  Provide an explicit retry context cache. Retry is stateful across transactions in the case of failures in item processing or writing, so some information about the context for subsequent retries has to be stored.

  覆盖:

  retryContextCache 在类中 FaultTolerantStepBuilder<I,​O>

  参数:

  retryContextCache - cache for retry contexts in between transactions (default to standard in-memory implementation)

  返回:

  this for fluent chaining

• skipLimit

  public RemoteChunkingMasterStepBuilder<I,​O> skipLimit​(int skipLimit)

  从类复制的说明: FaultTolerantStepBuilder
  Sets the maximum number of failed items to skip before the step fails. Ignored if an explicit FaultTolerantStepBuilder.skipPolicy(SkipPolicy) is provided.

  覆盖:

  skipLimit 在类中 FaultTolerantStepBuilder<I,​O>

  参数:

  skipLimit - the skip limit to set

  返回:

  this for fluent chaining

• noSkip

  public RemoteChunkingMasterStepBuilder<I,​O> noSkip​(java.lang.Class<? extends java.lang.Throwable> type)

  从类复制的说明: FaultTolerantStepBuilder
  Explicitly prevent certain exceptions (and subclasses) from being skipped.

  覆盖:

  noSkip 在类中 FaultTolerantStepBuilder<I,​O>

  参数:

  type - the non-skippable exception

  返回:

  this for fluent chaining

• skip

  public RemoteChunkingMasterStepBuilder<I,​O> skip​(java.lang.Class<? extends java.lang.Throwable> type)

  从类复制的说明: FaultTolerantStepBuilder
  Explicitly request certain exceptions (and subclasses) to be skipped. These exceptions (and their subclasses) might be thrown during any phase of the chunk processing (read, process, write) but separate counts are made of skips on read, process and write inside the step execution.

  覆盖:

  skip 在类中 FaultTolerantStepBuilder<I,​O>

  参数:

  type - the exception type.

  返回:

  this for fluent chaining

• skipPolicy

  public RemoteChunkingMasterStepBuilder<I,​O> skipPolicy​(SkipPolicy skipPolicy)

  从类复制的说明: FaultTolerantStepBuilder
  Provide an explicit policy for managing skips. A skip policy determines which exceptions are skippable and how many times.

  覆盖:

  skipPolicy 在类中 FaultTolerantStepBuilder<I,​O>

  参数:

  skipPolicy - the skip policy

  返回:

  this for fluent chaining

• noRollback

  public RemoteChunkingMasterStepBuilder<I,​O> noRollback​(java.lang.Class<? extends java.lang.Throwable> type)

  从类复制的说明: FaultTolerantStepBuilder
  Mark this exception as ignorable during item read or processing operations. Processing continues with no additional callbacks (use skips instead if you need to be notified). Ignored during write because there is no guarantee of skip and retry without rollback.

  覆盖:

  noRollback 在类中 FaultTolerantStepBuilder<I,​O>

  参数:

  type - the exception to mark as no rollback

  返回:

  this for fluent chaining

• noRetry

  public RemoteChunkingMasterStepBuilder<I,​O> noRetry​(java.lang.Class<? extends java.lang.Throwable> type)

  从类复制的说明: FaultTolerantStepBuilder
  Explicitly ask for an exception (and subclasses) to be excluded from retry.

  覆盖:

  noRetry 在类中 FaultTolerantStepBuilder<I,​O>

  参数:

  type - the exception to exclude from retry

  返回:

  this for fluent chaining

• retry

  public RemoteChunkingMasterStepBuilder<I,​O> retry​(java.lang.Class<? extends java.lang.Throwable> type)

  从类复制的说明: FaultTolerantStepBuilder
  Explicitly ask for an exception (and subclasses) to be retried.

  覆盖:

  retry 在类中 FaultTolerantStepBuilder<I,​O>

  参数:

  type - the exception to retry

  返回:

  this for fluent chaining

• stream

  public RemoteChunkingMasterStepBuilder<I,​O> stream​(ItemStream stream)

  从类复制的说明: AbstractTaskletStepBuilder
  Register a stream for callbacks that manage restart data.

  覆盖:

  stream 在类中 FaultTolerantStepBuilder<I,​O>

  参数:

  stream - the stream to register

  返回:

  this for fluent chaining

• chunk

  public RemoteChunkingMasterStepBuilder<I,​O> chunk​(int chunkSize)

  从类复制的说明: SimpleStepBuilder
  Sets the chunk size or commit interval for this step. This is the maximum number of items that will be read before processing starts in a single transaction. Not compatible with SimpleStepBuilder.completionPolicy .

  覆盖:

  chunk 在类中 SimpleStepBuilder<I,​O>

  参数:

  chunkSize - the chunk size (a.k.a commit interval)

  返回:

  this for fluent chaining

• chunk

  public RemoteChunkingMasterStepBuilder<I,​O> chunk​(CompletionPolicy completionPolicy)

  从类复制的说明: SimpleStepBuilder
  Sets a completion policy for the chunk processing. Items are read until this policy determines that a chunk is complete, giving more control than with just the chunk size (or commit interval).

  覆盖:

  chunk 在类中 SimpleStepBuilder<I,​O>

  参数:

  completionPolicy - a completion policy for the chunk

  返回:

  this for fluent chaining

• writer

  public RemoteChunkingMasterStepBuilder<I,​O> writer​(ItemWriter<? super O> writer)
                                                    throws java.lang.UnsupportedOperationException

  This method will throw a UnsupportedOperationException since the item writer of the master step in a remote chunking setup will be automatically set to an instance of ChunkMessageChannelItemWriter. When building a master step for remote chunking, no item writer must be provided.

  覆盖:

  writer 在类中 SimpleStepBuilder<I,​O>

  参数:

  writer - an item writer

  返回:

  this for fluent chaining

  抛出:

  java.lang.UnsupportedOperationException - if an item writer is provided

  另请参阅:

  ChunkMessageChannelItemWriter, RemoteChunkHandlerFactoryBean.setChunkWriter(ItemWriter)

• readerIsTransactionalQueue

  public RemoteChunkingMasterStepBuilder<I,​O> readerIsTransactionalQueue()

  从类复制的说明: SimpleStepBuilder
  Sets a flag to say that the reader is transactional (usually a queue), which is to say that failed items might be rolled back and re-presented in a subsequent transaction. Default is false, meaning that the items are read outside a transaction and possibly cached.

  覆盖:

  readerIsTransactionalQueue 在类中 SimpleStepBuilder<I,​O>

  返回:

  this for fluent chaining

• listener

  public RemoteChunkingMasterStepBuilder<I,​O> listener​(ItemReadListener<? super I> listener)

  从类复制的说明: SimpleStepBuilder
  Register an item reader listener.

  覆盖:

  listener 在类中 SimpleStepBuilder<I,​O>

  参数:

  listener - the listener to register

  返回:

  this for fluent chaining

• listener

  public RemoteChunkingMasterStepBuilder<I,​O> listener​(ItemWriteListener<? super O> listener)

  从类复制的说明: SimpleStepBuilder
  Register an item writer listener.

  覆盖:

  listener 在类中 SimpleStepBuilder<I,​O>

  参数:

  listener - the listener to register

  返回:

  this for fluent chaining

• chunkOperations

  public RemoteChunkingMasterStepBuilder<I,​O> chunkOperations​(RepeatOperations repeatTemplate)

  从类复制的说明: SimpleStepBuilder
  Instead of a chunk size or completion policy you can provide a complete repeat operations instance that handles the iteration over the item reader.

  覆盖:

  chunkOperations 在类中 SimpleStepBuilder<I,​O>

  参数:

  repeatTemplate - a complete repeat template for the chunk

  返回:

  this for fluent chaining

• exceptionHandler

  public RemoteChunkingMasterStepBuilder<I,​O> exceptionHandler​(ExceptionHandler exceptionHandler)

  从类复制的说明: AbstractTaskletStepBuilder
  Sets the exception handler to use in the case of tasklet failures. Default is to rethrow everything.

  覆盖:

  exceptionHandler 在类中 AbstractTaskletStepBuilder<SimpleStepBuilder<I,​O>>

  参数:

  exceptionHandler - the exception handler

  返回:

  this for fluent chaining

• stepOperations

  public RemoteChunkingMasterStepBuilder<I,​O> stepOperations​(RepeatOperations repeatTemplate)

  从类复制的说明: AbstractTaskletStepBuilder
  Sets the repeat template used for iterating the tasklet execution. By default it will terminate only when the tasklet returns FINISHED (or null).

  覆盖:

  stepOperations 在类中 AbstractTaskletStepBuilder<SimpleStepBuilder<I,​O>>

  参数:

  repeatTemplate - a repeat template with rules for iterating

  返回:

  this for fluent chaining

• startLimit

  public RemoteChunkingMasterStepBuilder<I,​O> startLimit​(int startLimit)

  覆盖:

  startLimit 在类中 StepBuilderHelper<AbstractTaskletStepBuilder<SimpleStepBuilder<I,​O>>>

• listener

  public RemoteChunkingMasterStepBuilder<I,​O> listener​(StepExecutionListener listener)

  覆盖:

  listener 在类中 StepBuilderHelper<AbstractTaskletStepBuilder<SimpleStepBuilder<I,​O>>>

• allowStartIfComplete

  public RemoteChunkingMasterStepBuilder<I,​O> allowStartIfComplete​(boolean allowStartIfComplete)

  覆盖:

  allowStartIfComplete 在类中 StepBuilderHelper<AbstractTaskletStepBuilder<SimpleStepBuilder<I,​O>>>

• processor

  public RemoteChunkingMasterStepBuilder<I,​O> processor​(ItemProcessor<? super I,​? extends O> itemProcessor)

  从类复制的说明: SimpleStepBuilder
  An item processor that processes or transforms a stream of items. Will be automatically registered as a AbstractTaskletStepBuilder.stream(ItemStream) or listener if it implements the corresponding interface.

  覆盖:

  processor 在类中 SimpleStepBuilder<I,​O>

  参数:

  itemProcessor - an item processor

  返回:

  this for fluent chaining