Class AmqpItemWriter<T>

java.lang.Object
org.springframework.batch.item.amqp.AmqpItemWriter<T>
All Implemented Interfaces:
ItemWriter<T>

public class AmqpItemWriter<T> extends Object implements ItemWriter<T>

AMQP ItemWriter implementation using an AmqpTemplate to send messages. Messages will be sent to the nameless exchange if not specified on the provided AmqpTemplate.

Author:
Chris Schaefer, Mahmoud Ben Hassine
  • Constructor Details

    • AmqpItemWriter

      public AmqpItemWriter(org.springframework.amqp.core.AmqpTemplate amqpTemplate)
  • Method Details

    • write

      public void write(Chunk<? extends T> items) throws Exception
      Description copied from interface: ItemWriter
      Process the supplied data element. Will not be called with any null items in normal operation.
      Specified by:
      write in interface ItemWriter<T>
      Parameters:
      items - of items to be written. Must not be null.
      Throws:
      Exception - if there are errors. The framework will catch the exception and convert or rethrow it as appropriate.