You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by da...@apache.org on 2012/09/17 14:59:56 UTC

svn commit: r1386592 - in /activemq/trunk/activemq-optional: pom.xml src/main/java/org/apache/activemq/transport/http/HttpClientTransport.java src/main/java/org/apache/activemq/util/oxm/XStreamMessageTransformer.java

Author: davsclaus
Date: Mon Sep 17 12:59:56 2012
New Revision: 1386592

URL: http://svn.apache.org/viewvc?rev=1386592&view=rev
Log:
Fixed code to not use @deprecated methods from 3rd party JARs

Modified:
    activemq/trunk/activemq-optional/pom.xml
    activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/transport/http/HttpClientTransport.java
    activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/util/oxm/XStreamMessageTransformer.java

Modified: activemq/trunk/activemq-optional/pom.xml
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-optional/pom.xml?rev=1386592&r1=1386591&r2=1386592&view=diff
==============================================================================
--- activemq/trunk/activemq-optional/pom.xml (original)
+++ activemq/trunk/activemq-optional/pom.xml Mon Sep 17 12:59:56 2012
@@ -234,9 +234,9 @@
                 </Export-Package>
                 <Import-Package>
                     org.eclipse.jetty*;version="[7.5,8.0)";resolution:=optional,
-                    !org.apache.activemq.transport.ws*;version=${project.version};,
-                    !org.apache.activemq.transport.xstream;version=${project.version};,
-                    !org.apache.activemq.transport.util;version=${project.version};,
+                    !org.apache.activemq.transport.ws*;version=${project.version},
+                    !org.apache.activemq.transport.xstream;version=${project.version},
+                    !org.apache.activemq.transport.util;version=${project.version},
                     org.apache.activemq*;version=${project.version};resolution:=optional
                 </Import-Package>
             </instructions>

Modified: activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/transport/http/HttpClientTransport.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/transport/http/HttpClientTransport.java?rev=1386592&r1=1386591&r2=1386592&view=diff
==============================================================================
--- activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/transport/http/HttpClientTransport.java (original)
+++ activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/transport/http/HttpClientTransport.java Mon Sep 17 12:59:56 2012
@@ -49,7 +49,7 @@ import org.apache.http.conn.params.ConnR
 import org.apache.http.entity.ByteArrayEntity;
 import org.apache.http.impl.client.BasicResponseHandler;
 import org.apache.http.impl.client.DefaultHttpClient;
-import org.apache.http.impl.conn.tsccm.ThreadSafeClientConnManager;
+import org.apache.http.impl.conn.PoolingClientConnectionManager;
 import org.apache.http.message.AbstractHttpMessage;
 import org.apache.http.params.HttpConnectionParams;
 import org.apache.http.params.HttpParams;
@@ -59,8 +59,8 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 /**
- * A HTTP {@link org.apache.activemq.transport.TransportChannel} which uses the
- * <a href="http://jakarta.apache.org/commons/httpclient/">commons-httpclient</a>
+ * A HTTP {@link org.apache.activemq.transport.Transport} which uses the
+ * <a href="http://hc.apache.org/index.html">Apache HTTP Client</a>
  * library
  */
 public class HttpClientTransport extends HttpTransportSupport {
@@ -285,7 +285,7 @@ public class HttpClientTransport extends
     }
 
     protected HttpClient createHttpClient() {
-        DefaultHttpClient client = new DefaultHttpClient(new ThreadSafeClientConnManager());
+        DefaultHttpClient client = new DefaultHttpClient(new PoolingClientConnectionManager());
         if (useCompression) {
             client.addRequestInterceptor( new HttpRequestInterceptor() {
                 @Override

Modified: activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/util/oxm/XStreamMessageTransformer.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/util/oxm/XStreamMessageTransformer.java?rev=1386592&r1=1386591&r2=1386592&view=diff
==============================================================================
--- activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/util/oxm/XStreamMessageTransformer.java (original)
+++ activemq/trunk/activemq-optional/src/main/java/org/apache/activemq/util/oxm/XStreamMessageTransformer.java Mon Sep 17 12:59:56 2012
@@ -32,6 +32,8 @@ import com.thoughtworks.xstream.io.Hiera
 import com.thoughtworks.xstream.io.xml.PrettyPrintWriter;
 import com.thoughtworks.xstream.io.xml.XppReader;
 
+import org.xmlpull.mxp1.MXParser;
+
 /**
  * Transforms object messages to text messages and vice versa using
  * {@link XStream}
@@ -99,7 +101,7 @@ public class XStreamMessageTransformer e
         if (streamDriver != null) {
         	in = streamDriver.createReader(new StringReader(textMessage.getText()));
         } else {
-        	in = new XppReader(new StringReader(textMessage.getText()));
+        	in = new XppReader(new StringReader(textMessage.getText()), new MXParser());
         }
         return getXStream().unmarshal(in);
     }