Loading src/main/java/it/inaf/oats/vospace/AsyncTransferService.java +3 −3 Original line number Diff line number Diff line package it.inaf.oats.vospace; import com.fasterxml.jackson.databind.ObjectMapper; import it.inaf.oats.vospace.exception.InternalFaultException; import java.io.IOException; import java.io.UncheckedIOException; import net.ivoa.xml.uws.v1.JobSummary; import org.slf4j.Logger; import org.slf4j.LoggerFactory; Loading @@ -26,14 +26,14 @@ public class AsyncTransferService { byte[] result = (byte[]) template.convertSendAndReceive("start_job_queue", message); if (result == null) { throw new IllegalStateException("Transfer service returned an empty response"); throw new InternalFaultException("Transfer service returned an empty response"); } LOG.trace("Tape transfer service answered:\n{}", new String(result)); return MAPPER.readValue(result, JobSummary.class); } catch (IOException ex) { throw new UncheckedIOException(ex); throw new InternalFaultException(ex); } } } src/main/java/it/inaf/oats/vospace/persistence/JobDAO.java +0 −2 Original line number Diff line number Diff line Loading @@ -3,7 +3,6 @@ package it.inaf.oats.vospace.persistence; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.JavaType; import com.fasterxml.jackson.databind.ObjectMapper; import com.sun.org.apache.xalan.internal.xsltc.compiler.util.Type; import java.sql.Timestamp; import java.sql.ResultSet; import java.sql.SQLException; Loading Loading @@ -197,7 +196,6 @@ public class JobDAO { if (last.isPresent()) { sb.append(" LIMIT ?"); //sb.append(last.get().toString()); queryParams.add(last.get()); queryParamTypes.add(Types.INTEGER); } Loading Loading
src/main/java/it/inaf/oats/vospace/AsyncTransferService.java +3 −3 Original line number Diff line number Diff line package it.inaf.oats.vospace; import com.fasterxml.jackson.databind.ObjectMapper; import it.inaf.oats.vospace.exception.InternalFaultException; import java.io.IOException; import java.io.UncheckedIOException; import net.ivoa.xml.uws.v1.JobSummary; import org.slf4j.Logger; import org.slf4j.LoggerFactory; Loading @@ -26,14 +26,14 @@ public class AsyncTransferService { byte[] result = (byte[]) template.convertSendAndReceive("start_job_queue", message); if (result == null) { throw new IllegalStateException("Transfer service returned an empty response"); throw new InternalFaultException("Transfer service returned an empty response"); } LOG.trace("Tape transfer service answered:\n{}", new String(result)); return MAPPER.readValue(result, JobSummary.class); } catch (IOException ex) { throw new UncheckedIOException(ex); throw new InternalFaultException(ex); } } }
src/main/java/it/inaf/oats/vospace/persistence/JobDAO.java +0 −2 Original line number Diff line number Diff line Loading @@ -3,7 +3,6 @@ package it.inaf.oats.vospace.persistence; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.JavaType; import com.fasterxml.jackson.databind.ObjectMapper; import com.sun.org.apache.xalan.internal.xsltc.compiler.util.Type; import java.sql.Timestamp; import java.sql.ResultSet; import java.sql.SQLException; Loading Loading @@ -197,7 +196,6 @@ public class JobDAO { if (last.isPresent()) { sb.append(" LIMIT ?"); //sb.append(last.get().toString()); queryParams.add(last.get()); queryParamTypes.add(Types.INTEGER); } Loading