release 4.0.16

.gitignore

@@ -0,0 +1 @@
+/qserv-test/

hsarback/src/main/java/de/hsadmin/servlets/QueueStatusReceiverServlet.java

@@ -112,6 +112,7 @@ public class QueueStatusReceiverServlet extends HttpServlet
 
 	@Override
 	public void onMessage(Message jmsMessage) {
+		assert jmsMessage != null;
 		Transaction transaction = null;
 		messageCount++;
 		try {
@@ -123,7 +124,13 @@ public class QueueStatusReceiverServlet extends HttpServlet
 				transaction.beginTransaction();
 				EntityManager em = transaction.getEntityManager();
 				em.clear();
-				QueueTask persistentQT = em.find(QueueTask.class, detachedQT.getId());
+				final long queueTaskId = detachedQT.getId();
+				QueueTask persistentQT = em.find(QueueTask.class, queueTaskId);
+				if (persistentQT == null) {
+					jmsMessage.acknowledge();
+					errorCount++;
+					throw new TechnicalException("QueueTask not found, id: " + queueTaskId);
+				}
 				persistentQT.assign(detachedQT);
 				Processor processor = persistentQT.getProcessor();
 				if (processor != null) {
@@ -133,6 +140,7 @@ public class QueueStatusReceiverServlet extends HttpServlet
 				em.flush();
 				transaction.commitTransaction();
 			} else {
+				errorCount++;
 				final String err = "Deserialization failed " + new Date();
 				System.out.println(err);
 				throw new TechnicalException(err);

qserv-deploy/pom.xml

@@ -4,7 +4,7 @@
 	<modelVersion>4.0.0</modelVersion>
 	<groupId>de.hsadmin</groupId>
 	<artifactId>hsadmin-qserv</artifactId>
-	<version>4.0.15</version>
+	<version>4.0.16</version>
 	<packaging>jar</packaging>
 
 	<name>HSAdmin-QServ</name>
@@ -20,7 +20,7 @@
 		<dependency>
 			<groupId>de.hsadmin.core</groupId>
 			<artifactId>hsadmin-qserv</artifactId>
-			<version>4.0.15</version>
+			<version>4.0.16</version>
 		</dependency>
 		<dependency>
 			<groupId>org.apache.activemq</groupId>

qserv/src/main/java/de/hsadmin/core/model/Transaction.java

@@ -145,7 +145,9 @@ public class Transaction {
 		if (transactionActive) {
 			rollbackTransaction();
 		}
-		entityManager.close();
+		if (entityManager != null) {
+			entityManager.close();
+		}
 	}
 
 	/**