weiter bearbeitet (fd742da5) · Commits · ERZ / SWE_de.bsvrz.ste.tmcvew

src/main/java/de/bsvrz/ste/tmcvew/TMCVewMeldung.java

+67 −65

Original line number	Diff line number	Diff line
		@@ -178,13 +178,13 @@ public class TMCVewMeldung implements ClientReceiverInterface {
		Geaendert("Geändert", 2),

		/** Gelöscht. */
		Geloescht("Gelöscht", 3),
		Geloescht("Gelöscht", 3);

		@Deprecated
		Aufhebung("Aufhebung", 300),

		@Deprecated
		Loeschung("Loeschung", 301);
		// @Deprecated
		// Aufhebung("Aufhebung", 300),
		//
		// @Deprecated
		// Loeschung("Loeschung", 301);

		/**
		* textueller Wert.
		@@ -592,7 +592,7 @@ public class TMCVewMeldung implements ClientReceiverInterface {

		/**
		* Prüft die übergebenen Daten und gibt sie ggf. zum Senden frei oder loggt
		* entsprechende Fehlermeldung ins
		* entsprechende Fehlermeldung.
		*
		* @param data
		* die aktuell weiterzuleitenden Daten
		@@ -707,28 +707,29 @@ public class TMCVewMeldung implements ClientReceiverInterface {
		final Data datenSenden = sender.getDatenSenden() != null && sender.getDatenSenden().hasData()
		? sender.getDatenSenden().getData() : null;

		/*
		* Wenn bereits Status Aufhebung gesendet wurde, wird nur noch Status
		* Löschung weitergeleitet, wenn bereits Status Löschung gesendet wurde,
		* werden keine Daten mehr weitergeleitet.
		*/
		if (datenSenden != null) {
		final TMCStatus sendeStatus = getStatus(datenSenden);
		if (sendeStatus == TMCStatus.Aufhebung) {
		if (status != TMCStatus.Loeschung \|\| true) {
		DEBUG.config(text + "\nEs liegt bereits eine Aktualisierung mit Status " + sendeStatus
		+ " vor - nur Aktualisierungen mit Status " + TMCStatus.Loeschung + " werden weitergeleitet"
		+ suffixFehler);
		return;
		}
		} else if (sendeStatus == TMCStatus.Loeschung) {
		if (!(status == TMCStatus.Loeschung && verwaltung.getLoeschVerfahren() == 1)) {
		DEBUG.config(text + "\nEs liegt bereits eine Aktualisierung mit Status " + sendeStatus + " vor"
		+ suffixFehler);
		return;
		}
		}
		}
		// TODO:
		// /*
		// * Wenn bereits Status Aufhebung gesendet wurde, wird nur noch Status
		// * Löschung weitergeleitet, wenn bereits Status Löschung gesendet wurde,
		// * werden keine Daten mehr weitergeleitet.
		// */
		// if (datenSenden != null) {
		// final TMCStatus sendeStatus = getStatus(datenSenden);
		// if (sendeStatus == TMCStatus.Aufhebung) {
		// if (status != TMCStatus.Loeschung \|\| true) {
		// DEBUG.config(text + "\nEs liegt bereits eine Aktualisierung mit Status " + sendeStatus
		// + " vor - nur Aktualisierungen mit Status " + TMCStatus.Loeschung + " werden weitergeleitet"
		// + suffixFehler);
		// return;
		// }
		// } else if (sendeStatus == TMCStatus.Loeschung) {
		// if (!(status == TMCStatus.Loeschung && verwaltung.getLoeschVerfahren() == 1)) {
		// DEBUG.config(text + "\nEs liegt bereits eine Aktualisierung mit Status " + sendeStatus + " vor"
		// + suffixFehler);
		// return;
		// }
		// }
		// }

		/*
		* Zu sendende Daten unter dem Aspekt TMCGeneriert werden dann nicht
		@@ -739,8 +740,8 @@ public class TMCVewMeldung implements ClientReceiverInterface {
		final Data datenBearbeitetData = datenBearbeitet != null && datenBearbeitet.hasData()
		? datenBearbeitet.getData() : null;
		final Zustand zustandBearbeited = datenBearbeitetData != null ? getZustand(datenBearbeitetData) : null;
		if ((zustandBearbeited == Zustand.Editiert \|\| zustandBearbeited == Zustand.Verworfen) &&
		// !(sendeStatus == Status.Aufhebung && status == Status.Löschung))
		if ((zustandBearbeited == Zustand.Editiert \|\| zustandBearbeited == Zustand.Verworfen)
		&&
		(datenSenden == null \|\| !(getZustand(datenSenden) == Zustand.Verworfen))) {
		DEBUG.config(
		text + "\nEs liegen bearbeitete Daten im Zustand " + zustandBearbeited + " vor" + suffixFehler);
		@@ -750,17 +751,17 @@ public class TMCVewMeldung implements ClientReceiverInterface {

		/*
		* Wenn zu sendende Daten unter dem Aspekt TMCBearbeitet den Zustand
		* verworfen haben, wird mindestens der Status Aufhebung erzwungen
		* 'verworfen' haben, wird mindestens der Status 'Gelöscht' erzwungen
		*/
		if (asp.equals(datenBeschreibungBearbeitet.getAspect())) {
		if (zustand == Zustand.Verworfen) {
		if (status != TMCStatus.Aufhebung && status != TMCStatus.Loeschung) {
		text += "\nDer Status wird auf \"" + TMCStatus.Aufhebung + "\" gesetzt, da der Zustand \""
		if (status != TMCStatus.Geloescht) {
		text += "\nDer Status wird auf \"" + TMCStatus.Geloescht.toString() + "\" gesetzt, da der Zustand \""
		+ Zustand.Verworfen + "\" ist";
		try {
		setStatus(datenSatz, TMCStatus.Aufhebung);
		setStatus(datenSatz, TMCStatus.Geloescht);
		} catch (final RuntimeException e) {
		DEBUG.error(text + "\nFehler beim Setzen von Status auf " + TMCStatus.Aufhebung + suffixFehler, e);
		DEBUG.error(text + "\nFehler beim Setzen von Status auf " + TMCStatus.Geloescht + suffixFehler, e);
		return;
		}
		}
		@@ -775,35 +776,36 @@ public class TMCVewMeldung implements ClientReceiverInterface {
		*/
		boolean loeschen = false;

		switch (verwaltung.getLoeschVerfahren()) {
		case 0:
		/*
		* Wenn Status Aufhebung oder Löschung gesendet werden soll und
		* bisher noch keine Daten gesendet wurden, wird die Aktualisierung
		* unterdrückt und die Meldung gelöscht.
		*/
		if ((status == TMCStatus.Aufhebung \|\| status == TMCStatus.Loeschung)
		&& (sender.getDatenSenden() == null \|\| !sender.getDatenSenden().hasData())) {
		text += "\nStatus " + status + " wurde empfangen und es wurde bisher noch nichts gesendet";
		loeschen = true;
		}
		break;

		case 1:
		/*
		* Wenn Status Aufhebung gesendet werden soll und bisher noch keine
		* Daten gesendet wurden oder wenn Löschung gesendet werden soll,
		* wird die Aktualisierung unterdrückt und die Meldung gelöscht.
		*/
		if (status == TMCStatus.Aufhebung && (sender.getDatenSenden() == null \|\| !sender.getDatenSenden().hasData())) {
		text += "\nStatus " + status + " wurde empfangen und es wurde bisher noch nichts gesendet";
		loeschen = true;
		} else if (status == TMCStatus.Loeschung) {
		text += "\nStatus " + status + " wurde empfangen";
		loeschen = true;
		}
		break;
		}
		// TODO:
		// switch (verwaltung.getLoeschVerfahren()) {
		// case 0:
		// /*
		// * Wenn Status Aufhebung oder Löschung gesendet werden soll und
		// * bisher noch keine Daten gesendet wurden, wird die Aktualisierung
		// * unterdrückt und die Meldung gelöscht.
		// */
		// if ((status == TMCStatus.Aufhebung \|\| status == TMCStatus.Loeschung)
		// && (sender.getDatenSenden() == null \|\| !sender.getDatenSenden().hasData())) {
		// text += "\nStatus " + status + " wurde empfangen und es wurde bisher noch nichts gesendet";
		// loeschen = true;
		// }
		// break;
		//
		// case 1:
		// /*
		// * Wenn Status Aufhebung gesendet werden soll und bisher noch keine
		// * Daten gesendet wurden oder wenn Löschung gesendet werden soll,
		// * wird die Aktualisierung unterdrückt und die Meldung gelöscht.
		// */
		// if (status == TMCStatus.Aufhebung && (sender.getDatenSenden() == null \|\| !sender.getDatenSenden().hasData())) {
		// text += "\nStatus " + status + " wurde empfangen und es wurde bisher noch nichts gesendet";
		// loeschen = true;
		// } else if (status == TMCStatus.Loeschung) {
		// text += "\nStatus " + status + " wurde empfangen";
		// loeschen = true;
		// }
		// break;
		// }

		if (loeschen) {
		DEBUG.config(text + suffixFehler + "\nAktuelle Meldung wird gelöscht");

src/test/java/de/bsvrz/ste/tmcvew/RdsMeldung.java

+116 −81

Original line number	Diff line number	Diff line
		@@ -25,7 +25,6 @@ import de.bsvrz.dav.daf.main.config.DynamicObjectType;
		import de.bsvrz.dav.daf.main.config.InvalidationListener;
		import de.bsvrz.dav.daf.main.config.MutableSet;
		import de.bsvrz.dav.daf.main.config.SystemObject;
		import de.bsvrz.dav.daf.main.config.SystemObjectType;
		import de.bsvrz.sys.funclib.application.StandardApplication;
		import de.bsvrz.sys.funclib.application.StandardApplicationRunner;
		import de.bsvrz.sys.funclib.commandLineArgs.ArgumentList;
		@@ -113,22 +112,22 @@ public class RdsMeldung implements StandardApplication, Runnable {
		private String ergebnis;
		private boolean erfolg = false;
		private boolean _erfolg = false;
		private boolean debug = true;
		private boolean debug = false;
		private int m_teiler = 1;
		private static Process m_proc = null;

		// static {
		// Runtime.getRuntime().addShutdownHook(new Thread() {
		// public void run() {
		// prozessStop();
		// }
		// });
		// }
		static {
		Runtime.getRuntime().addShutdownHook(new Thread() {
		public void run() {
		prozessStop();
		}
		});
		}

		/**
		* Objekt beinhaltet alle dynamischen Staus.
		*/
		RdsMeldungsVerwaltung m_rds_meldung;
		TmcMeldungsVerwaltung m_rds_meldung;

		/**
		* Liste mit einzelnen Konfigurationsbereichen durch Aufspaltung von _kb mit
		@@ -261,13 +260,13 @@ public class RdsMeldung implements StandardApplication, Runnable {

		while (true) {
		// 1. Kennung -> Laufende Nummer im Test bei 0 ist Testlauf beendet
		// 2. Kennung -> Erwarteter Status
		// 3. Kennung -> Erwarteter Zustand
		// 4. Kennung -> Erwartete Quelle
		// 5. Kennung -> Zeit in Sekunden in der Rückmeldung erwartet wird,
		// bei 0 wird kein Telegramm erwartet
		// 6. Kennung -> Zeit in Sekunden in der Rückmeldung nicht erwartet
		// wird, bei 0 wird kein Telegramm erwartet
		// 2. Kennung -> Erter Status
		// 3. Kennung -> Erter Zustand
		// 4. Kennung -> Erte Quelle
		// 5. Kennung -> Zeit in Sekunden in der Rückmeldung ert wird,
		// bei 0 wird kein Telegramm ert
		// 6. Kennung -> Zeit in Sekunden in der Rückmeldung nicht ert
		// wird, bei 0 wird kein Telegramm ert

		if (ergebnis != null) {
		String v[] = ergebnis.split(":");
		@@ -282,28 +281,34 @@ public class RdsMeldung implements StandardApplication, Runnable {
		// Initialisiere neuen Testfall

		if (!_testnummer.equalsIgnoreCase(_testnummer_old)) {
		if (debug)
		if (debug) {
		System.out
		.println("Rdsmeldung-Thread -> Initialisiere Test: " + _testnummer + " Objekt: " + tmc);
		.println("Rdsmeldung-Thread -> Initialisiere Test: " + _testnummer + ", Objekt: '" + tmc + "'");
		}

		loesche = true;
		_testnummer_old = _testnummer;

		try {
		zaehler = Long.parseLong(_zeit);

		if (zaehler > m_teiler)
		if (zaehler > m_teiler) {
		zaehler = zaehler / m_teiler;
		}

		if (zaehler == 0)
		if (zaehler == 0) {
		zaehler = -1;
		}

		zaehler_min = Long.parseLong(_zeit_min);

		if (zaehler_min > m_teiler)
		if (zaehler_min > m_teiler) {
		zaehler_min = zaehler_min / m_teiler;
		}

		if (zaehler_min == 0)
		if (zaehler_min == 0) {
		zaehler_min = -1;
		}
		} catch (Exception e) {
		zaehler = -1;
		e.printStackTrace();
		@@ -311,11 +316,13 @@ public class RdsMeldung implements StandardApplication, Runnable {

		}

		if (zaehler > 0)
		if (zaehler > 0) {
		zaehler--;
		}

		if (zaehler_min > 0)
		if (zaehler_min > 0) {
		zaehler_min--;
		}

		if (zaehler == 0) {
		System.out.println("Rdsmeldung-Thread -> Fehlende Meldung " + tmc);
		@@ -323,27 +330,35 @@ public class RdsMeldung implements StandardApplication, Runnable {
		fehler = false;
		}

		// System.out.println("Rdsmeldung-Thread -> ZM: "+ zaehler_min);
		if (debug) {
		System.out.println("Rdsmeldung-Thread -> ZM: " + zaehler_min);
		}

		if (m_rds_meldung.getRdsMeldung() != null)
		empfMeldung = m_rds_meldung.getRdsMeldung();
		if (m_rds_meldung.getMeldungen() != null) {
		empfMeldung = m_rds_meldung.getMeldungen();
		}

		if (empfMeldung != null)
		rdsa = empfMeldung.get(tmc); // Hole Meldung für empfangenes
		// Objekt
		else
		if (empfMeldung != null) {
		rdsa = empfMeldung.get(tmc); // Hole Meldung für empfangenes Objekt
		} else {
		rdsa = null;
		}

		if (rdsa != null) {
		if (rdsa.getFlag() == 0) // neues TMC-Objekt
		if (debug) {
		System.out.println("Rdsmeldung-Thread -> Meldung: " + rdsa.getPid() + ", Flag: " + rdsa.getFlag());
		}

		if (rdsa.getFlag() == 0) { // neues TMC-Objekt
		flag = 0;
		}

		if (rdsa.getFlag() != flag) {
		flag = rdsa.getFlag();
		zaehler = -1;

		if (_zeit.equalsIgnoreCase("0")) {
		System.out.println("Rdsmeldung-Thread -> Unerwartete Meldung " + rdsa.getPid());
		if ("0".equalsIgnoreCase(_zeit)) {
		System.out.println("Rdsmeldung-Thread -> Unerte Meldung " + rdsa.getPid());
		fehler = false;
		}

		@@ -355,8 +370,9 @@ public class RdsMeldung implements StandardApplication, Runnable {
		if (rdsa.getParameter().getQuelle().equalsIgnoreCase(_quelle)
		&& rdsa.getParameter().getZustand().equalsIgnoreCase(_zustand)
		&& rdsa.getParameter().getStatus().equalsIgnoreCase(_status)) {
		if (debug)
		if (debug) {
		System.out.println("Rdsmeldung-Thread -> Meldung ok " + rdsa.getPid());
		}

		if (_status.equalsIgnoreCase("Modifikation"))
		ok = tmcmeldung(m_connection, tmc, quelle, _zustand, "versendet", "0");
		@@ -379,16 +395,13 @@ public class RdsMeldung implements StandardApplication, Runnable {

		ok = tmcmeldung(m_connection, tmc, quelle, _zustand, "versendet", "9");

		try // Objekt soll gelöscht werden, Prüfe nach 5
		// Sekunden ob Löschung erfolgreich
		{
		try { // Objekt soll gelöscht werden, Prüfe nach 5 Sekunden ob Löschung erfolgreich
		Thread.sleep(5000);
		} catch (InterruptedException e) {
		} catch (final InterruptedException e) {
		e.printStackTrace();
		}

		if (_erfolg == false) // Objekt nicht gelöscht
		{
		if (!_erfolg) { // Objekt nicht gelöscht
		fehler = false;
		System.out.println(
		"Rdsmeldung-Thread -> Objekt: " + rdsa.getPid() + " nicht gelöscht");
		@@ -404,16 +417,18 @@ public class RdsMeldung implements StandardApplication, Runnable {
		}
		} // ende Meldung empfangen

		if (_testnummer.equalsIgnoreCase("0")) {
		if (fehler == false) {
		if ("0".equalsIgnoreCase(_testnummer)) {
		if (fehler) {
		erfolg = fehler;
		if (debug)
		if (debug) {
		System.out.println("Rdsmeldung-Thread -> Testlauf mit Fehler beendet ");
		}
		} else {
		erfolg = fehler;
		if (debug)
		if (debug) {
		System.out.println("Rdsmeldung-Thread -> Testlauf erfolgreich beendet ");
		}
		}
		break; // Thread beenden für Junit - Test
		}
		}
		@@ -422,12 +437,14 @@ public class RdsMeldung implements StandardApplication, Runnable {

		try {
		Thread.sleep(1000);
		} catch (InterruptedException e) {
		} catch (final InterruptedException e) {
		e.printStackTrace();
		}
		}

		System.out.println("TEST");
		// if (debug) {
		// System.out.println("Rdsmeldung-Thread -> ENDE");
		// }
		}

		/**
		@@ -821,14 +838,14 @@ public class RdsMeldung implements StandardApplication, Runnable {

		loescheTMCObjekte();

		System.out.println("TMCVerkehrsMeldung -> --- Starte Prozess RdsMeldungsVerwaltung -----");
		System.out.println("TMCVerkehrsMeldung -> --- Starte Prozess TmcMeldungsVerwaltung -----");

		m_rds_meldung = new RdsMeldungsVerwaltung((ClientDavConnection) m_connection, LMS_PID);
		m_rds_meldung = new TmcMeldungsVerwaltung((ClientDavConnection) m_connection, LMS_PID);

		/*
		* Neu Sans 20090216 START
		***********************************************/
		// Warte einige Zeit, bis die abhängigen Prozesse und Threads die
		// einige Zeit, bis die abhängigen Prozesse und Threads die
		// Löschungen und Neuanmeldungen
		// verarbeitet haben
		Thread.sleep(2000);
		@@ -879,13 +896,13 @@ public class RdsMeldung implements StandardApplication, Runnable {
		}

		// 1. Kennung -> Laufende Nummer im Test bei 0 ist Testlauf beendet
		// 2. Kennung -> Erwarteter Status
		// 3. Kennung -> Erwarteter Zustand
		// 4. Kennung -> Erwartete Quelle
		// 5. Kennung -> Zeit in Sekunden in der Rückmeldung erwartet wird,
		// bei 0 wird kein Telegramm erwartet
		// 6. Kennung -> Zeit in Sekunden in der Rückmeldung nicht erwartet
		// wird, bei 0 wird kein Telegramm erwartet
		// 2. Kennung -> Erter Status
		// 3. Kennung -> Erter Zustand
		// 4. Kennung -> Erte Quelle
		// 5. Kennung -> Zeit in Sekunden in der Rückmeldung ert wird,
		// bei 0 wird kein Telegramm ert
		// 6. Kennung -> Zeit in Sekunden in der Rückmeldung nicht ert
		// wird, bei 0 wird kein Telegramm ert

		iniTest("1:Modifikation:quittiert:automatisch:0:0"); // Für
		// Auswertung
		@@ -893,11 +910,16 @@ public class RdsMeldung implements StandardApplication, Runnable {
		// bei 0:
		// wird kein
		// Telegramm
		// erwartet
		// ert

		ok = tmcmeldung(connection, tmc, quelle, zustand, aspekt, status);

		Thread.sleep(20000 / teiler); // Sleep 20 Sekunden
		if (debug) {
		System.out.println("Testfall 2: " + tmc + " " + quelle + " " + zustand + " " + aspekt
		+ " " + status + " --> " + ok);
		}

		Thread.sleep(10000 / teiler); // Sleep 20 Sekunden

		tmc = "TMCMeldung2";
		quelle = "Automatik";
		@@ -913,22 +935,28 @@ public class RdsMeldung implements StandardApplication, Runnable {
		iniTest("2:Modifikation:quittiert:automatisch:5:0");

		ok = tmcmeldung(connection, tmc, quelle, zustand, aspekt, status);

		if (debug) {
		System.out.println("Testfall 2a: " + tmc + " " + quelle + " " + zustand + " " + aspekt
		+ " " + status + " --> " + ok);
		}
		}

		// --------------------------------------------------------------------------------------------
		// Testfall 3
		// --------------------------------------------------------------------------------------------

		if (test.equalsIgnoreCase("Testfall3")) {
		if ("Testfall3".equalsIgnoreCase(test)) {
		tmc = "TMCMeldung3";
		quelle = "Automatik";
		zustand = "editiert";
		aspekt = "bearbeitet";
		status = "0";

		if (debug)
		if (debug) {
		System.out.println("Start Testfall 3: " + tmc + " " + quelle + " " + zustand + " " + aspekt
		+ " " + status);
		}

		iniTest("1:Modifikation:editiert:automatisch:5:0");

		@@ -942,9 +970,10 @@ public class RdsMeldung implements StandardApplication, Runnable {
		aspekt = "generiert";
		status = "0";

		if (debug)
		if (debug) {
		System.out.println("Start Testfall 3a: " + tmc + " " + quelle + " " + zustand + " " + aspekt
		+ " " + status);
		}

		iniTest("2:Modifikation:quittiert:automatisch:0:0");

		@@ -954,16 +983,17 @@ public class RdsMeldung implements StandardApplication, Runnable {
		// Testfall 4
		// --------------------------------------------------------------------------------------------

		if (test.equalsIgnoreCase("Testfall4")) {
		if ("Testfall4".equalsIgnoreCase(test)) {
		tmc = "TMCMeldung4";
		quelle = "Automatik";
		zustand = "nicht quittiert";
		aspekt = "generiert";
		status = "0";

		if (debug)
		if (debug) {
		System.out.println("Start Testfall 4: " + tmc + " " + quelle + " " + zustand + " " + aspekt
		+ " " + status);
		}

		iniTest("1:Modifikation:nicht quittiert:automatisch:180:100");

		@@ -977,9 +1007,10 @@ public class RdsMeldung implements StandardApplication, Runnable {
		aspekt = "generiert";
		status = "0";

		if (debug)
		if (debug) {
		System.out.println("Start Testfall 4a: " + tmc + " " + quelle + " " + zustand + " " + aspekt
		+ " " + status);
		}

		iniTest("2:Modifikation:nicht quittiert:automatisch:0:0");

		@@ -993,9 +1024,10 @@ public class RdsMeldung implements StandardApplication, Runnable {
		aspekt = "bearbeitet";
		status = "0";

		if (debug)
		if (debug) {
		System.out.println("Start Testfall 4b: " + tmc + " " + quelle + " " + zustand + " " + aspekt
		+ " " + status);
		}

		iniTest("3:Aufhebung:verworfen:automatisch:5:0");

		@@ -1006,16 +1038,17 @@ public class RdsMeldung implements StandardApplication, Runnable {
		// Testfall 5
		// --------------------------------------------------------------------------------------------

		if (test.equalsIgnoreCase("Testfall5")) {
		if ("Testfall5".equalsIgnoreCase(test)) {
		tmc = "TMCMeldung5";
		quelle = "manuell";
		zustand = "editiert";
		aspekt = "bearbeitet";
		status = "0";

		if (debug)
		if (debug) {
		System.out.println("Start Testfall 1: " + tmc + " " + quelle + " " + zustand + " " + aspekt
		+ " " + status);
		}

		iniTest("1:Modifikation:editiert:manuell:5:0");

		@@ -1924,13 +1957,16 @@ public class RdsMeldung implements StandardApplication, Runnable {
		ok = tmcmeldung(connection, tmc, quelle, zustand, aspekt, status);
		}

		try {
		Thread.sleep(5000); // Sleep 5 Sekunden
		} catch (final InterruptedException ie) {
		ie.printStackTrace();
		}

		iniTest("0:Modifikation:quittiert:automatisch:0:0"); // Testlauf beendet

		Thread.sleep(5000); // Sleep 5 Sekunden

		// return erfolg;
		return ok;
		}

		@@ -1951,7 +1987,7 @@ public class RdsMeldung implements StandardApplication, Runnable {

		Debug.setLoggerLevel("DEFAULT", Debug.OFF);
		// Debug.setHandlerLevel("StdErr", Debug.CONFIG);
		Debug.setHandlerLevel("StdErr", Debug.FINE);
		Debug.setHandlerLevel("StdErr", Debug.INFO);

		// Datenverteilerverbindung aufbauen

		@@ -2060,23 +2096,22 @@ public class RdsMeldung implements StandardApplication, Runnable {
		final InputStream is = m_proc.getErrorStream();

		new Thread() {
		byte[] text = new byte[1024];
		private byte[] text = new byte[1024];

		@Override
		public void run() {
		while (true) {
		try {
		if (is.available() != 0) {
		int anzahl = is.read(text);
		final int anzahl = is.read(text);

		System.err.println("" + new String(text, 0, anzahl));
		} else {
		sleep(100);
		}
		} catch (IOException e) {
		// TODO Automatisch erstellter Catch-Block
		e.printStackTrace();
		} catch (InterruptedException e) {
		} catch (final IOException e) {
		break;
		} catch (final InterruptedException e) {
		// TODO Automatisch erstellter Catch-Block
		e.printStackTrace();
		}
		@@ -2084,14 +2119,14 @@ public class RdsMeldung implements StandardApplication, Runnable {
		}
		}.start(); // Thread
		// }
		} catch (IOException e) {
		} catch (final IOException e) {
		System.err.println("Fehler beim Starten der Inkarnation " + "de.bsvrz.ste.rdstmcvew.RDSVerwaltungApp");
		}

		try {
		System.out.println(text);
		Thread.sleep(15000); // Wartezeit bis zu prüfender Prozess gestartet
		} catch (InterruptedException e) {
		Thread.sleep(15000); // zeit bis zu prüfender Prozess gestartet
		} catch (final InterruptedException e) {
		// TODO Auto-generated catch block
		e.printStackTrace();
		} // 2 Sekunden

src/test/java/de/bsvrz/ste/tmcvew/RdsMeldungTest2.java

+8 −8

Original line number	Diff line number	Diff line
		@@ -99,14 +99,14 @@ public class RdsMeldungTest2 {
		*/
		@Test
		public void testTestfall() throws Exception {
		// try {
		boolean testfall = m.testfall(connection, "Testfall2", 1);
		System.out.println("TESTFALL: " + testfall);
		// assertTrue("Test 2", m.testfall(connection, "Testfall2", 1));
		// } catch (final Exception e) {
		// e.printStackTrace();
		// assertEquals("Test 2", e.getMessage(), "Ungültige Exeption geworfen");
		// }
		try {
		// final boolean testfall = m.testfall(connection, "Testfall2", 1);
		// System.out.println("TESTFALL: " + testfall);
		assertTrue("Test 2", m.testfall(connection, "Testfall2", 1));
		} catch (final Exception e) {
		e.printStackTrace();
		assertEquals("Test 2", e.getMessage(), "Ungültige Exeption geworfen");
		}
		System.out.println("TESTTEST");
		}
		}

src/test/java/de/bsvrz/ste/tmcvew/RdsMeldungsEmpfang.java

+20 −26

File changed.

Preview size limit exceeded, changes collapsed.

src/test/java/de/bsvrz/ste/tmcvew/RdsMeldungsVerwaltung.java→src/test/java/de/bsvrz/ste/tmcvew/TmcMeldungsVerwaltung.java

+201 −0

File changed and moved.

Preview size limit exceeded, changes collapsed.