request.setHeader(Constants.Gateway.API_KEY, "api-key-example");
request.setHeader("X-Archive-Name", applicationId + ".jar");
MockResponder mockResponder = new MockResponder();
BodyConsumer bodyConsumer = httpHandler.deploy(request, mockResponder);
BufferFileInputStream is = new BufferFileInputStream(deployedJar.getInputStream(), 100 * 1024);
try {
byte[] chunk = is.read();
while (chunk.length > 0) {
mockResponder = new MockResponder();
bodyConsumer.chunk(ChannelBuffers.wrappedBuffer(chunk), mockResponder);
Preconditions.checkState(mockResponder.getStatus() == null, "failed to deploy app");
chunk = is.read();
}
mockResponder = new MockResponder();
bodyConsumer.finished(mockResponder);
Preconditions.checkState(mockResponder.getStatus().getCode() == 200, "failed to deploy app");
} catch (Exception e) {
throw Throwables.propagate(e);
} finally {
is.close();
}
return deployedJar;
}