You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cxf.apache.org by ff...@apache.org on 2007/06/08 06:01:42 UTC
svn commit: r545397 -
/incubator/cxf/trunk/rt/transports/jbi/src/main/java/org/apache/cxf/transport/jbi/JBIDestination.java
Author: ffang
Date: Thu Jun 7 21:01:41 2007
New Revision: 545397
URL: http://svn.apache.org/viewvc?view=rev&rev=545397
Log:
fix cruisecontrol failed
Modified:
incubator/cxf/trunk/rt/transports/jbi/src/main/java/org/apache/cxf/transport/jbi/JBIDestination.java
Modified: incubator/cxf/trunk/rt/transports/jbi/src/main/java/org/apache/cxf/transport/jbi/JBIDestination.java
URL: http://svn.apache.org/viewvc/incubator/cxf/trunk/rt/transports/jbi/src/main/java/org/apache/cxf/transport/jbi/JBIDestination.java?view=diff&rev=545397&r1=545396&r2=545397
==============================================================================
--- incubator/cxf/trunk/rt/transports/jbi/src/main/java/org/apache/cxf/transport/jbi/JBIDestination.java (original)
+++ incubator/cxf/trunk/rt/transports/jbi/src/main/java/org/apache/cxf/transport/jbi/JBIDestination.java Thu Jun 7 21:01:41 2007
@@ -175,19 +175,15 @@
NormalizedMessage nm = exchange.getMessage("in");
try {
- //get the message to be interceptor
+
MessageImpl inMessage = new MessageImpl();
inMessage.put(MessageExchange.class, exchange);
- //get the message to be interceptor
- XMLStreamReader reader = StaxUtils.createXMLStreamReader(nm.getContent());
- inMessage.setContent(XMLStreamReader.class, reader);
- final InputStream in = JBIMessageHelper.convertMessageToInputStream(nm.getContent());
- //get the message to be interceptor
+ final InputStream in = JBIMessageHelper.convertMessageToInputStream(nm.getContent());
inMessage.setContent(InputStream.class, in);
-
- //dispatch to correct destination in case of multiple endpoint
+ XMLStreamReader reader = StaxUtils.createXMLStreamReader(in);
+ inMessage.setContent(XMLStreamReader.class, reader);
inMessage.setDestination(this);
getMessageObserver().onMessage(inMessage);