changes

src/de/hottis/MeasurementCollector/AMessageParser.java

@@ -6,7 +6,7 @@ import java.util.concurrent.ConcurrentLinkedQueue;
 
 public abstract class AMessageParser {
 	private String topic;
-	private ConcurrentLinkedQueue<List<ADataObject>> queue;
+	protected ConcurrentLinkedQueue<List<ADataObject>> queue;
 	
 	public AMessageParser(String topic, ConcurrentLinkedQueue<List<ADataObject>> queue) {
 		this.topic = topic;

src/de/hottis/MeasurementCollector/MBusParser.java

@@ -75,6 +75,9 @@ public class MBusParser extends AMessageParser {
 			for (ADataObject ado : measurementItems) {
 				System.out.println(ado);
 			}
+			
+			queue.add(measurementItems);
+			System.out.println("Queue size: " + queue.size());
 		} catch (Exception e) {
 			System.out.println("Exception when handling mbus message: " + e);
 		}