Class AmqpItemWriter<T>

All Implemented Interfaces:

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.

This writer is thread-safe as long as the delegate AmqpTemplate implementation is thread-safe.

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>
      items - of items to be written. Must not be null.
      Exception - if there are errors. The framework will catch the exception and convert or rethrow it as appropriate.