Package org.oddjob.beanbus.destinations

Class UnPack<T>

java.lang.Object
org.oddjob.beanbus.destinations.UnPack<T>
Type Parameters:
T - The type of bean being batched.
All Implemented Interfaces:
Consumer<Iterable<T>>, BusFilter<Iterable<T>,T>, Outbound<T>
public class UnPack<T> extends Object implements BusFilter<Iterable<T>,T>
Author:
Rob

Description

Takes an Iterable and Unpacks it.

Example

Un Batching 2 Lists. 

<oddjob>

    <job>

        <bus:bus id="bean-bus" xmlns:bus="oddjob:beanbus">

            <of>

                <bus:driver>

                    <values>

                        <list>

                            <values>

                                <list>

                                    <values>

                                        <value value="Apple"/>

                                        <value value="Orange"/>

                                    </values>

                                </list>

                                <list>

                                    <values>

                                        <value value="Pear"/>

                                        <value value="Kiwi"/>

                                        <value value="Banana"/>

                                    </values>

                                </list>

                            </values>

                        </list>

                    </values>

                </bus:driver>

                <bean id="unbatch" class="org.oddjob.beanbus.destinations.UnPack"/>

                <bus:collect id="results"/>

            </of>

        </bus:bus>

    </job>

</oddjob>

  • Constructor Details

    • UnPack

      public UnPack()

  • Method Details

    • reset

      public void reset()

    • accept

      public void accept(Iterable<T> beans)
      Specified by:
      accept in interface Consumer<T>

    • getCount

      public int getCount()

    • getTo

      public Consumer<? super T> getTo()

    • setTo

      public void setTo(Consumer<? super T> next)
      Description copied from interface: Outbound
      Set the out bound destination.
      Specified by:
      setTo in interface Outbound<T>
      Parameters:
      next -

    • getName

      public String getName()

    • setName

      public void setName(String name)

    • toString

      public String toString()
      Overrides:
      toString in class Object