类 AmqpItemReader<T>

  • 所有已实现的接口:
    ItemReader<T>

    public class AmqpItemReader<T>
    extends java.lang.Object
    implements ItemReader<T>

    AMQP ItemReader implementation using an AmqpTemplate to receive and/or convert messages.

    作者:
    Chris Schaefer, Mahmoud Ben Hassine
    • 构造器概要

      构造器 
      构造器说明
      AmqpItemReader​(org.springframework.amqp.core.AmqpTemplate amqpTemplate)
      Initialize the AmqpItemReader.
    • 方法概要

      所有方法 实例方法 具体方法 
      修饰符和类型方法说明
      Tread()
      Reads a piece of input data and advance to the next one.
      voidsetItemType​(java.lang.Class<? extends T> itemType)
      Establish the itemType for the reader.
      • 从类继承的方法 java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • 构造器详细资料

      • AmqpItemReader

        public AmqpItemReader​(org.springframework.amqp.core.AmqpTemplate amqpTemplate)
        Initialize the AmqpItemReader.
        参数:
        amqpTemplate - the template to be used. Must not be null.
    • 方法详细资料

      • read

        public T read()
        从接口复制的说明: ItemReader
        Reads a piece of input data and advance to the next one. Implementations must return null at the end of the input data set. In a transactional setting, caller might get the same item twice from successive calls (or otherwise), if the first call was in a transaction that rolled back.
        指定者:
        read 在接口中 ItemReader<T>
        返回:
        T the item to be processed or null if the data source is exhausted
      • setItemType

        public void setItemType​(java.lang.Class<? extends T> itemType)
        Establish the itemType for the reader.
        参数:
        itemType - class type that will be returned by the reader.