@@ -0,0 +1,1570 @@
+package org.cstamas.vertx.content.impl;%0A%0Aimport io.vertx.core.Vertx;%0Aimport io.vertx.core.buffer.Buffer;%0Aimport io.vertx.core.http.HttpClient;%0Aimport io.vertx.core.http.HttpServer;%0Aimport io.vertx.core.json.JsonObject;%0Aimport io.vertx.core.logging.Logger;%0Aimport io.vertx.core.logging.LoggerFactory;%0Aimport io.vertx.core.streams.ReadStream;%0Aimport org.cstamas.vertx.content.FlowControl;%0Aimport org.cstamas.vertx.content.Transport;%0A%0Aimport static com.google.common.base.Preconditions.checkNotNull;%0Aimport static org.cstamas.vertx.content.ContentManager.txId;%0A%0A/**%0A * %7B@link Transport%7D implementation that uses %7B@link HttpServer%7D and %7B@link HttpClient%7D for transport.%0A */%0Apublic class HttpTransport%0A    implements Transport%0A%7B%0A  private static final Logger log = LoggerFactory.getLogger(HttpTransport.class);%0A%0A  private static final String NAME = %22http%22;%0A%0A  private final Vertx vertx;%0A%0A  public HttpTransport(final Vertx vertx) %7B%0A    this.vertx = checkNotNull(vertx);%0A  %7D%0A%0A  @Override%0A  public String name() %7B%0A    return NAME;%0A  %7D%0A%0A  @Override%0A  public void send(final JsonObject contentHandle,%0A                   final FlowControl flowControl,%0A                   final ReadStream%3CBuffer%3E stream)%0A  %7B%0A    String txId = txId(contentHandle);%0A    // TODO: HTTP Server should publish resource (copied to tmp or just as %22single shot%22?) and send the URL%0A  %7D%0A%0A  @Override%0A  public ReadStream%3CBuffer%3E receive(final JsonObject contentHandle, final FlowControl flowControl)%0A  %7B%0A    String txId = txId(contentHandle);%0A    // TODO: client should GET the content%0A    return null;%0A  %7D%0A%7D%0A

Add HTTP transport, scratch for now