1 17 package org.apache.servicemix.components.xfire; 18 19 import java.io.InputStream ; 20 import java.io.Writer ; 21 22 import javax.jbi.messaging.MessageExchange; 23 import javax.jbi.messaging.MessagingException; 24 import javax.jbi.messaging.NormalizedMessage; 25 import javax.xml.stream.XMLInputFactory; 26 import javax.xml.stream.XMLOutputFactory; 27 import javax.xml.stream.XMLStreamException; 28 import javax.xml.stream.XMLStreamReader; 29 import javax.xml.stream.XMLStreamWriter; 30 import javax.xml.transform.Source ; 31 import javax.xml.transform.TransformerException ; 32 33 import org.apache.servicemix.jbi.jaxp.SourceTransformer; 34 import org.apache.servicemix.jbi.jaxp.StAXSourceTransformer; 35 import org.apache.servicemix.jbi.jaxp.StringSource; 36 import org.codehaus.xfire.exchange.OutMessage; 37 38 41 public class XMarshaler { 42 43 private StAXSourceTransformer transformer; 44 45 public XMarshaler() 46 { 47 transformer = new StAXSourceTransformer(); 48 } 49 50 public void setContent(NormalizedMessage message, String xml) throws MessagingException { 51 message.setContent(new StringSource(xml)); 52 } 53 54 public XMLStreamReader createStreamReader(NormalizedMessage message) throws XMLStreamException, TransformerException { 55 Source content = message.getContent(); 56 return transformer.toXMLStreamReader(content); 57 } 58 59 60 public XMLStreamWriter createStreamWriter(Writer writer) throws XMLStreamException { 61 return transformer.getOutputFactory().createXMLStreamWriter(writer); 62 } 63 64 67 public void fromNMS(MessageExchange asExchange, NormalizedMessage normalizedMessage) { 68 } 69 70 73 public void toNMS(NormalizedMessage normalizedMessage, OutMessage outMessage) { 74 } 75 76 } 77 | Popular Tags |