--- java/com/directthought/lifeguard/MessageHelper.java 6 Jun 2008
14:45:41 -0000 1.1.1.1
+++ java/com/directthought/lifeguard/MessageHelper.java 17 Jul 2008
16:25:48 -0000
@@ -58,10 +58,15 @@
ret.setBatch(wr.getBatch());
ret.setServiceName(wr.getServiceName());
ret.setInputBucket(wr.getInputBucket());
- ret.setInput(wr.getInput());
+ FileRef ref = of.createFileRef();
+ ref.setKey(wr.getInput().getKey());
+ ref.setType(wr.getInput().getType());
+ ref.setLocation(wr.getInput().getLocation());
+ ret.setInput(ref);
+ ret.setOutputBucket(wr.getOutputBucket());
if (outFiles != null) {
for (MetaFile file : outFiles) {
- FileRef ref = of.createFileRef();
+ ref = of.createFileRef();
ref.setKey(file.key);
ref.setType(file.mimeType);
ref.setLocation("S3");