Skip to content

C
CONF
Commit ab85a819 authored by Spiros Koulouzis's avatar Spiros Koulouzis
Browse files
Options

Fixed bug in for null file

parent 67a1a59c
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 3 deletions
drip-provisioner/src/main/java/nl/uva/sne/drip/drip/provisioner/Consumer.java
View file @ ab85a819
......@@ -75,7 +75,7 @@ public class Consumer extends DefaultConsumer {
try {
//The queue only moves bytes so we need to convert them to stting
String message = new String(body, "UTF-8");
//Create a tmp folder to save the output.
String tempInputDirPath = System.getProperty("java.io.tmpdir") + File.separator + "Input-" + Long.toString(System.nanoTime()) + File.separator;
File tempInputDir = new File(tempInputDirPath);
if (!(tempInputDir.mkdirs())) {
......@@ -114,7 +114,6 @@ public class Consumer extends DefaultConsumer {
for (int i = 0; i < parameters.length(); i++) {
JSONObject param = (JSONObject) parameters.get(i);
String name = (String) param.get(Parameter.NAME);
if (name.equals("ec2.conf")) {
try {
ec2ConfFile = new File(tempInputDirPath + "ec2.Conf");
......@@ -149,7 +148,7 @@ public class Consumer extends DefaultConsumer {
try {
File topologyFile = new File(tempInputDirPath + "topology_main");
if (topologyFile.createNewFile()) {
PrintWriter out = new PrintWriter(geniConfFile);
PrintWriter out = new PrintWriter(topologyFile);
out.print(param.get(Parameter.VALUE));
mainTopologyPath = topologyFile.getAbsolutePath();
} else {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment