Examples of org.mule.routing.outbound.CollectionMessageSequence

org.mule.routing.outbound.CollectionMessageSequence
A {@link MessageSequence} that retrieves elements from a {@link Collection}. Its estimated size is initially the size of the collection, and decreases when elements are consumed using {@link #next()} @author flbulgarelli @param < T>

{
    @Override
    @SuppressWarnings("unchecked")
    protected MessageSequence<?> splitMessageIntoSequence(MuleEvent event) throws MuleException
    {
        return new CollectionMessageSequence(splitMessage(event));
    }

View Full Code Here

        {
            return new IteratorMessageSequence<Object>(((Iterator<Object>) payload));
        }
        if (payload instanceof Collection)
        {
            return new CollectionMessageSequence(new LinkedList((Collection) payload));
        }
        if (payload instanceof Iterable<?>)
        {
            return new IteratorMessageSequence<Object>(((Iterable<Object>) payload).iterator());
        }

View Full Code Here

                {
                    MuleMessage splitMessage = new DefaultMuleMessage(entry.getValue(), muleContext);
                    splitMessage.setInvocationProperty(MapSplitter.MAP_ENTRY_KEY, entry.getKey());
                    list.add(splitMessage);
                }
                return new CollectionMessageSequence(list);
            }
            return super.splitMessageIntoSequence(event);
        }

View Full Code Here

        {
            return new IteratorMessageSequence<Object>(((Iterator<Object>) payload));
        }
        if (payload instanceof Collection)
        {
            return new CollectionMessageSequence(new LinkedList((Collection) payload));
        }
        if (payload instanceof Iterable<?>)
        {
            return new IteratorMessageSequence<Object>(((Iterable<Object>) payload).iterator());
        }

View Full Code Here

{
    @Override
    @SuppressWarnings("unchecked")
    protected MessageSequence<?> splitMessageIntoSequence(MuleEvent event) throws MuleException
    {
        return new CollectionMessageSequence(splitMessage(event));
    }

View Full Code Here

TOP

Related Classes of org.mule.routing.outbound.CollectionMessageSequence

org.mule.routing.AbstractSplitter

org.mule.routing.CollectionSplitter

org.mule.routing.Foreach$CollectionMapSplitter

org.mule.util.collection.EventToMessageSequenceSplittingStrategy

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.