From 9b8df1b119e79404754816d01b3c492e35a35496 Mon Sep 17 00:00:00 2001
From: Wolfgang Hottgenroth <woho@hottis.de>
Date: Wed, 15 Nov 2017 18:22:51 +0100
Subject: [PATCH] changes

---
 .../MeasurementCollector/AMessageParser.class | Bin 1035 -> 1035 bytes
 .../MeasurementCollector/MBusParser.class     | Bin 5337 -> 5533 bytes
 .../MeasurementCollector/AMessageParser.java  |   2 +-
 .../MeasurementCollector/MBusParser.java      |   3 +++
 4 files changed, 4 insertions(+), 1 deletion(-)

diff --git a/bin/de/hottis/MeasurementCollector/AMessageParser.class b/bin/de/hottis/MeasurementCollector/AMessageParser.class
index 3610428022c38d98c9c2a6f3d399716174bbcefd..ff295b03df5c595761bd1162f4a9aafa1222ac16 100644
GIT binary patch
delta 13
UcmeC?=;qj<#mvYuS)2I*02wC(ssI20

delta 13
UcmeC?=;qj<#mvYwS)2I*02v(vr~m)}

diff --git a/bin/de/hottis/MeasurementCollector/MBusParser.class b/bin/de/hottis/MeasurementCollector/MBusParser.class
index d50f0ec620034ce42515f0e61dca6a8babf1fb01..53c74d447c12fbdb74b9e927bbbad9f530f8abf8 100644
GIT binary patch
delta 723
zcmZ{iOK1~e6otP#N&4q8F{Nt2STX3vREiJ^YE^V2qNr_CinwqgCW5XMX@x?l3pcI@
zH$oT1g_|PO=m=KbxU%R%T-5k}KU&|Zt<T0gqX`HVhT)rg?mhoKGgHnCu528ey>u05
zleobWGS02g(velC?1d48J2vZBALTCh4fli=r);%suzA2SA+R@}5A#T{yLt<~h4hgF
z{e||l*ZjohDg8pwD@Ad5ZZpgap?SqtClyNt!n|^B*sTq3y!wPwwX^cJl#ORBOTx~c
zM00S;FkLDp7E2_LApzFB(oo|~>1jF7_@bCgdDl5EjN<HWdU%l`uj=yH<(bP_mn&yT
z?X2l9Rd029{YM$mR7gdpnIy<+P2R^6XRvACK!=ReDHXb8hMX0rhc&9YG<k=!mUeye
z=pFAp52X(@U=fiCKJtkGX}L{KYw9bP`K%OTla#11rMyLk`NFiu*~T(v_)3^QDe{f)
zO2q-`;|D*9a6%69i&>(QQ`4$aOpe#-WSvga`Bxn!EQk=-)stdLKzlaowr#qA?<T>T
zn}lj^KKX7wb@+BZHt6UW^Q-J2Vh|(7&~4c6-@A=Oj70SfB&!@n|C+fQoXrcCAD(N{
mu-|aVa7`~XK#auyJpOGpT*uogOQ1fWhclVf>@n}-i2WNVV4jo!

delta 579
zcmZ{gO-Phc6o#KO)6Df7=fj`L8OTLZv>0V@BU){A5ebnNwg|TdEz^~*#El3pT3vJ@
zxDXd^Qn0}h6x-CI1VLA2*?&5tmD!(}rFK3?zLmn|^4xpRdG5;@s$5DI&+Sb=1ghCH
z1canr44s~+8jJ=Dcy3$Wl=C9WeO?MF+ZH)*XWfXrN<VRvfe?R$ge?ju!iE(?HXSQ2
z7pDe85lAjwTQV<Iqnv7bz~l_JrS#bp!>J5Q8OAfrP9Rz~FAFSlf?CaRmvY+@yWQO+
zi(Hp1&0Nsi45glqi(Jx^N3VHv(3|5eVFEbvn0LG<$Qc>auCV8m0X`^&sF!<uWJS3_
zdRZl_0k3kF9BUNNA-7oPlTw%5;4@!vy6Kb4Z19zcG^=z|sZe@+>i21cio@3#6@246
zu11gZgP&Scr)jG-K;HJtw{7`0kMcH;^0qA+3i++AbHw&(#4(6r+i=rx?O<2fG5po(
z#rNsNJ+8nyW#>*F)oJU?5?79TFx)Y;8y@LG$Mh60LzJNZg_mVHuG9ag2?Ol@2kBLb
AO8@`>

diff --git a/src/de/hottis/MeasurementCollector/AMessageParser.java b/src/de/hottis/MeasurementCollector/AMessageParser.java
index 82965e4..05313b8 100644
--- a/src/de/hottis/MeasurementCollector/AMessageParser.java
+++ b/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;
diff --git a/src/de/hottis/MeasurementCollector/MBusParser.java b/src/de/hottis/MeasurementCollector/MBusParser.java
index 62b98bc..1933ca2 100644
--- a/src/de/hottis/MeasurementCollector/MBusParser.java
+++ b/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);
 		}