Author: ogusakov
Date: Wed Jul 30 11:41:33 2008
New Revision: 681168
URL: http://svn.apache.org/viewvc?rev=681168&view=rev
Log:
stopped working on HttpReaderTransport as it should be native in jetty client
Added:
maven/sandbox/trunk/mercury/src/main/java/org/apache/maven/mercury/transport/http/
maven/sandbox/trunk/mercury/src/main/java/org/apache/maven/mercury/transport/http/HttpReaderTransport.java
maven/sandbox/trunk/mercury/src/main/java/org/apache/maven/mercury/transport/http/Messages.properties
Added:
maven/sandbox/trunk/mercury/src/main/java/org/apache/maven/mercury/transport/http/HttpReaderTransport.java
URL:
http://svn.apache.org/viewvc/maven/sandbox/trunk/mercury/src/main/java/org/apache/maven/mercury/transport/http/HttpReaderTransport.java?rev=681168&view=auto
==============================================================================
---
maven/sandbox/trunk/mercury/src/main/java/org/apache/maven/mercury/transport/http/HttpReaderTransport.java
(added)
+++
maven/sandbox/trunk/mercury/src/main/java/org/apache/maven/mercury/transport/http/HttpReaderTransport.java
Wed Jul 30 11:41:33 2008
@@ -0,0 +1,70 @@
+package org.apache.maven.mercury.transport.http;
+
+import org.apache.maven.mercury.spi.http.client.HttpClientException;
+import
org.apache.maven.mercury.spi.http.client.retrieve.DefaultRetrievalRequest;
+import org.apache.maven.mercury.spi.http.client.retrieve.DefaultRetriever;
+import org.apache.maven.mercury.spi.http.client.retrieve.RetrievalRequest;
+import org.apache.maven.mercury.spi.http.client.retrieve.RetrievalResponse;
+import org.apache.maven.mercury.transport.api.AbstractTransport;
+import org.apache.maven.mercury.transport.api.Binding;
+import org.apache.maven.mercury.transport.api.ReaderTransport;
+import org.apache.maven.mercury.transport.api.TransportException;
+import org.apache.maven.mercury.transport.api.TransportTransaction;
+import org.codehaus.plexus.i18n.DefaultLanguage;
+import org.codehaus.plexus.i18n.Language;
+
+/**
+ * Jetty client adaptor to ReaderTransport APIs
+ *
+ * @author Oleg Gusakov
+ * @version $Id$
+ *
+ */
+public class HttpReaderTransport
+extends AbstractTransport
+implements ReaderTransport
+{
+ private static final Language _lang = new DefaultLanguage(
HttpReaderTransport.class );
+ private static final org.slf4j.Logger _log =
org.slf4j.LoggerFactory.getLogger( HttpReaderTransport.class );
+
+ DefaultRetriever _httpReader;
+
+ /**
+ *
+ */
+ public HttpReaderTransport()
+ throws TransportException
+ {
+ try
+ {
+ _httpReader = new DefaultRetriever();
+ }
+ catch( HttpClientException e )
+ {
+ throw new TransportException(e);
+ }
+ }
+
+ /* (non-Javadoc)
+ * @see
org.apache.maven.mercury.transport.api.ReaderTransport#read(org.apache.maven.mercury.transport.api.TransportTransaction)
+ */
+ public TransportTransaction read( TransportTransaction trx )
+ throws TransportException
+ {
+ if( trx == null )
+ {
+ _log.error( _lang.getMessage( "empty.transaction", trx == null ? "null"
: trx.toString() ) );
+ return trx;
+ }
+
+ DefaultRetrievalRequest request = new DefaultRetrievalRequest();
+
+ for( Binding b : trx.getBindings() )
+ request.addBinding( b );
+
+ RetrievalResponse response = _httpReader.retrieve( request );
+
+ return trx;
+ }
+
+}
Added:
maven/sandbox/trunk/mercury/src/main/java/org/apache/maven/mercury/transport/http/Messages.properties
URL:
http://svn.apache.org/viewvc/maven/sandbox/trunk/mercury/src/main/java/org/apache/maven/mercury/transport/http/Messages.properties?rev=681168&view=auto
==============================================================================
---
maven/sandbox/trunk/mercury/src/main/java/org/apache/maven/mercury/transport/http/Messages.properties
(added)
+++
maven/sandbox/trunk/mercury/src/main/java/org/apache/maven/mercury/transport/http/Messages.properties
Wed Jul 30 11:41:33 2008
@@ -0,0 +1 @@
+empty.transaction=cannot serve empty transaction {0}, returning it back
\ No newline at end of file
