List of applyTransformers() Examples

Examples of applyTransformers()

org.mule.DefaultMuleMessage.applyTransformers()
{@inheritDoc}
org.mule.api.MuleMessage.applyTransformers()
Will apply a list of transformers to the payload of the message. This *Will* change the payload of the message. This method provides the only way to alter the paylaod of this message without recreating a copy of the message @param event the event being processed @param transformers the transformers to apply to the message payload @throws TransformerException if a transformation error occurs or one or more of the transformers passed in aare incompatible with the message payload

Examples of org.mule.api.MuleMessage.applyTransformers()

            {
                // See if there is a default transformer on the connector
                List transformers = ((AbstractConnector) endpoint.getConnector()).getDefaultInboundTransformers(endpoint);
                if (transformers != null)
                {
                    result.applyTransformers(null, transformers);
                }
                ByteArrayOutputStream out = new ByteArrayOutputStream();
                wireFormat.write(out, result, getEncoding());
                return out.toByteArray();
            }

View Full Code Here

Examples of org.mule.api.MuleMessage.applyTransformers()

        if (this.getRoundTripTransformer() != null)
        {
            Transformer trans = this.getTransformer();
            Transformer trans2 = this.getRoundTripTransformer();
            MuleMessage message = new DefaultMuleMessage(getTestData(), muleContext);
            message.applyTransformers(null, Arrays.asList(trans, trans2));
            Object result = message.getPayload();
            this.compareRoundtripResults(this.getTestData(), result);
        }
    }

View Full Code Here

Examples of org.mule.api.MuleMessage.applyTransformers()

                    {
                        resultMessage = result.getMessage();
                    }
                    if (resultMessage != null)
                    {
                        resultMessage.applyTransformers(result, endpoint.getResponseTransformers());
                    }
                    if (!exceptionPayloadAvailable(resultMessage))
                    {
                        if (logger.isDebugEnabled())
                        {

View Full Code Here

Examples of org.mule.api.MuleMessage.applyTransformers()

        String inputMessage = "ABCDEF";
        byte[] array = (byte[]) trans.transform(inputMessage);


        MuleMessage message = new DefaultMuleMessage(inputMessage, muleContext);
        List<Transformer> transformers = Arrays.asList(new Transformer[] {trans});
        message.applyTransformers(null, transformers);
        assertEquals("text/plain", message.getDataType().getMimeType());
        assertEquals("iso-8859-1", message.getEncoding());
    }
}

View Full Code Here

Examples of org.mule.api.MuleMessage.applyTransformers()

        if (event != null && event.getMessage() != null)
        {
            try
            {
                MuleMessage message = event.getMessage();
                message.applyTransformers(event, this);
                if (message instanceof DefaultMessageCollection)
                {
                    if (((DefaultMessageCollection) message).isInvalidatedPayload())
                    {
                        if (logger.isDebugEnabled())

View Full Code Here

Examples of org.mule.api.MuleMessage.applyTransformers()

                        {
                            logger.debug("Received event on: " + jobConfig.getEndpointRef());
                        }
                        if (pollGlobalEndpoint.get())
                        {
                            result.applyTransformers(null, finalEndpoint.getTransformers());
                        }


                        //we need to do this because
                        result = (MuleMessage) ((ThreadSafeAccess) result).newThreadCopy();

View Full Code Here

Examples of org.mule.api.MuleMessage.applyTransformers()

        {
            message = new DefaultMuleMessage(response, getMessageReceiver().getEndpoint().getMuleContext());
        }
        //TODO RM*: Maybe we can have a generic Transformer wrapper rather that using DefaultMuleMessage (or another static utility
        //class
        message.applyTransformers(null, getMessageReceiver().getResponseTransportTransformers(), HttpResponse.class);
        return (HttpResponse) message.getPayload();
    }


    protected MuleMessage createMessageFromSource(Object message) throws MuleException
    {

View Full Code Here

Examples of org.mule.api.MuleMessage.applyTransformers()

        {
            message = new DefaultMuleMessage(response, getEndpoint().getMuleContext());
        }
        //TODO RM*: Maybe we can have a generic Transformer wrapper rather that using DefaultMuleMessage (or another static utility
        //class
        message.applyTransformers(null, defaultResponseTransformers, HttpResponse.class);
        return (HttpResponse) message.getPayload();
    }


    public static MessageReceiver findReceiverByStem(Map<Object, MessageReceiver> receivers, String uriStr)
    {

View Full Code Here

0 1 2 3

TOP

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.