Changeset 368

 		System.out.println("[" + this.getqName() + "] Item was added");
 		this.queue.add(input);
 	}
 	public void deleteFromQueue(String queuedObject) {
 		this.queue.remove(queuedObject);
 	}
 	}
 	/**
+	 * Geeft Array terug van hele queue
+	 *
+	 * @return Lijst met alle items
+	 */
+	public LinkedList<String> peekEntireQueue() {
+		return new LinkedList<String>(this.queue);
+	}
+	/**
 	 * Removes latest item from the Queue and removes it from the Queue.
 	 *
 	 * @return File contents
 		return this.queue.poll();
 	}
-	/**
-	 * Geeft Array terug van hele queue
-	 *
-	 * @return Lijst met alle items
-	 */
-	public LinkedList<String> peekEntireQueue() {
-		return new LinkedList<String>(this.queue);
-	}
 	public void setqName(String qName) {
 		this.qName = qName;
 	}

	367		368
5	import java.io.InputStream;	5	import java.io.InputStream;
6	import java.net.SocketException;	6	import java.net.SocketException;
7		7
8	import org.apache.commons.net.ftp.FTPClient;
9	import org.apache.commons.net.ftp.FTPFile;
10
11	public class ESBFTP {	8	public class ESBFTP {
12		9
13	private String ftpAddress, ftpUserName, ftpPassword;	10	private String ftpAddress, ftpUserName, ftpPassword;
...		...
34	}	31	}
35		32
36	/**	33	/**
		34	* Haalt bestanden uit directory
		35	*
		36	* @param directory
		37	* doeldirectory
		38	* @return Array van FTPFiles
		39	*/
		40	public FTPFile[] getFilesFromDir(String directory) {
		41	this.makeConnection();
		42	FTPFile[] output = null;
		43	try {
		44	output = this.ftpClient.listFiles(directory);
		45	} catch (IOException e) {
		46	e.printStackTrace();
		47	}
		48	this.terminateConnection();
		49	return output;
		50	}
		51
		52	/**
37	* Maakt verbinding met de FTP-server en slaat deze verbinding op in de	53	* Maakt verbinding met de FTP-server en slaat deze verbinding op in de
38	* lokale variabele ftpClient	54	* lokale variabele ftpClient
39	*/	55	*/
...		...
50	}	66	}
51		67
52	/**	68	/**
53	* Sluit connectie met server die nu in lokale variabele ftpClient staat	69	* Haalt opgegeven bestand van de server er verwijderd deze.
		70	*
		71	* @param filePath
		72	* Pad + bestandsnaam
		73	* @return Bestandsinhoud
54	*/	74	*/
55	private void terminateConnection() {	75	public String pollFile(String filePath) {
		76	this.makeConnection();
		77	ByteArrayOutputStream outputStream = null;
56	try {	78	try {
57	this.ftpClient.disconnect();	79	outputStream = new ByteArrayOutputStream();
		80	this.ftpClient.retrieveFile(filePath, outputStream);
		81	// this.ftpClient.dele(filePath);
58	} catch (IOException e) {	82	} catch (IOException e) {
59	e.printStackTrace();	83	e.printStackTrace();
60	}	84	}
61	this.ftpClient = null;	85
		86	this.terminateConnection();
		87	return outputStream.toString();
62	}	88	}
63		89
64	/**	90	/**
...		...
82	}	108	}
83		109
84	/**	110	/**
85	* Haalt bestanden uit directory	111	* Sluit connectie met server die nu in lokale variabele ftpClient staat
86	*
87	* @param directory
88	* doeldirectory
89	* @return Array van FTPFiles
90	*/	112	*/
91	public FTPFile[] getFilesFromDir(String directory) {	113	private void terminateConnection() {
92	this.makeConnection();
93	FTPFile[] output = null;
94	try {	114	try {
95	output = this.ftpClient.listFiles(directory);	115	this.ftpClient.disconnect();
96	} catch (IOException e) {	116	} catch (IOException e) {
97	e.printStackTrace();	117	e.printStackTrace();
98	}	118	}
99	this.terminateConnection();	119	this.ftpClient = null;
100	return output;
101	}	120	}
102
103	/**
104	* Haalt opgegeven bestand van de server er verwijderd deze.
105	*
106	* @param filePath
107	* Pad + bestandsnaam
108	* @return Bestandsinhoud
109	*/
110	public String pollFile(String filePath) {
111	this.makeConnection();
112	ByteArrayOutputStream outputStream = null;
113	try {
114	outputStream = new ByteArrayOutputStream();
115	this.ftpClient.retrieveFile(filePath, outputStream);
116	// this.ftpClient.dele(filePath);
117	} catch (IOException e) {
118	e.printStackTrace();
119	}
120
121	this.terminateConnection();
122	return outputStream.toString();
123	}
124	}	121	}

	367		368
6	import java.io.StringReader;	6	import java.io.StringReader;
7	import java.io.StringWriter;	7	import java.io.StringWriter;
8		8
9	import org.apache.commons.net.ftp.FTPFile;
10
11	public class FTPApp2QChannel extends App2Q {	9	public class FTPApp2QChannel extends App2Q {
12		10
13	private String ftpAddress;	11	private String ftpAddress;
...		...
16	private String ftpPassword;	14	private String ftpPassword;
17	private ESBFTP ftpClient;	15	private ESBFTP ftpClient;
18		16
19	@Override	17	public String getFtpAddress() {
20	public void run() {	18	return ftpAddress;
21	try {
22	while (true) {
23	this.readAndProcessFTP();
24	Thread.sleep(10000);
25	}
26	} catch (InterruptedException e) {
27	e.printStackTrace();
28	}
29	}	19	}
30		20
		21	public String getFtpInitDir() {
		22	return ftpInitDir;
		23	}
		24
		25	public String getFtpPassword() {
		26	return ftpPassword;
		27	}
		28
		29	public String getFtpUserName() {
		30	return ftpUserName;
		31	}
		32
31	private void readAndProcessFTP() {	33	private void readAndProcessFTP() {
32	// Maak FTP-verbinding klaar	34	// Maak FTP-verbinding klaar
33	this.ftpClient = new ESBFTP(this.getFtpAddress(), this.getFtpUserName(), this	35	this.ftpClient = new ESBFTP(this.getFtpAddress(), this.getFtpUserName(), this
...		...
45	}	47	}
46	}	48	}
47		49
48	private String undoFilter(String fileContents) {	50	@Override
49	StringWriter stringWriter = new StringWriter();	51	public void run() {
50	FromIBGFilter fromFilter = new FromIBGFilter();	52	try {
51	fromFilter.doFilter(new StringReader(fileContents), stringWriter);	53	while (true) {
52		54	this.readAndProcessFTP();
53	return stringWriter.toString();	55	Thread.sleep(10000);
		56	}
		57	} catch (InterruptedException e) {
		58	e.printStackTrace();
		59	}
54	}	60	}
55		61
56	public String getFtpAddress() {
57	return ftpAddress;
58	}
59
60	public void setFtpAddress(String ftpAddress) {	62	public void setFtpAddress(String ftpAddress) {
61	this.ftpAddress = ftpAddress;	63	this.ftpAddress = ftpAddress;
62	}	64	}
63		65
64	public String getFtpInitDir() {
65	return ftpInitDir;
66	}
67
68	public void setFtpInitDir(String ftpInitDir) {	66	public void setFtpInitDir(String ftpInitDir) {
69	this.ftpInitDir = ftpInitDir;	67	this.ftpInitDir = ftpInitDir;
70	}	68	}
71		69
72	public String getFtpUserName() {	70	public void setFtpPassword(String ftpPassword) {
73	return ftpUserName;	71	this.ftpPassword = ftpPassword;
74	}	72	}
75		73
76	public void setFtpUserName(String ftpUserName) {	74	public void setFtpUserName(String ftpUserName) {
77	this.ftpUserName = ftpUserName;	75	this.ftpUserName = ftpUserName;
78	}	76	}
79		77
80	public String getFtpPassword() {	78	private String undoFilter(String fileContents) {
81	return ftpPassword;	79	StringWriter stringWriter = new StringWriter();
82	}	80	FromIBGFilter fromFilter = new FromIBGFilter();
		81	fromFilter.doFilter(new StringReader(fileContents), stringWriter);
83		82
84	public void setFtpPassword(String ftpPassword) {	83	return stringWriter.toString();
85	this.ftpPassword = ftpPassword;
86	}	84	}
87		85
88	}	86	}

 		this.httpObject = httpq2AppChannel;
 	}
+	private String findId(String inQueue) {
+		File tmpFile = new File("C:/queuetemp.tmp");
+		try {
+			FileWriter fw = new FileWriter("C:/queuetemp.tmp");
+			fw.write(inQueue);
+			fw.close();
+		} catch (Exception e) {
+			// Doe niets
+		}
+		Xml xmlParser = new Xml("C:/queuetemp.tmp", "message");
+		String reqId = xmlParser.child("id").content();
+		tmpFile.delete();
+		return reqId;
+	}
+	private String getHttpQueueName() {
+		return this.httpObject.getSourceQueue().getqName();
+	}
 	private String getId(String queryType) {
 		int start = queryType.indexOf("?ID=") + 4;
 		queryType = queryType.replace(" HTTP/1.1", "");
 		return header.substring(5, header.indexOf(" HTTP/1.1"));
 	}
-	private void reply(String queryType) {
-		if (queryType.indexOf("?ID=") > 0) { // Specifiek ID
-			this.replyId(this.getId(queryType));
-		} else { // Overzicht
-			this.replyList();
-		}
-	}
-	private String getHttpQueueName() {
-		return this.httpObject.getSourceQueue().getqName();
-	}
 	private void initListen() {
 		System.out.println("[HTTPQ2AppChannel] Connection received from "
 				+ socket.getInetAddress().getHostName());
 	}
-	private void replyList() {
+	private void reply(String queryType) {
-		LinkedList<String> queued = this.httpObject.getSourceQueue().peekEntireQueue();
+		if (queryType.indexOf("?ID=") > 0) { // Specifiek ID
-		if (queued.size() > 0) {
+			this.replyId(this.getId(queryType));
-			LinkedList<String> idOutput = new LinkedList<String>();
+		} else { // Overzicht
-			int contentLength = 0;
+			this.replyList();
-			for (String inQueue : queued) {
-				String inputId = "ID=" + this.findId(inQueue) + "\n";
-				idOutput.add(inputId);
-				contentLength += inputId.length();
-			}
-			outPutWriter.write("HTTP/1.1 200 OK\n");
-			outPutWriter.write("Content-Length=" + contentLength + "\n");
-			for (String id : idOutput) {
-				System.out.println(id);
-				outPutWriter.write(id.trim());
-			}
 		}
 	}
-	private String findId(String inQueue) {
-		File tmpFile = new File("C:/queuetemp.tmp");
-		try {
-			FileWriter fw = new FileWriter("C:/queuetemp.tmp");
-			fw.write(inQueue);
-			fw.close();
-		} catch (Exception e) {
-			// Doe niets
-		}
-		Xml xmlParser = new Xml("C:/queuetemp.tmp", "message");
-		String reqId = xmlParser.child("id").content();
-		tmpFile.delete();
-		return reqId;
-	}
 	private void replyId(String queryId) {
 		LinkedList<String> queued = this.httpObject.getSourceQueue().peekEntireQueue();
 		if (queued.size() > 0) {
 		outPutWriter.write("HTTP/1.1 404 Not Found");
 	}
+	private void replyList() {
+		LinkedList<String> queued = this.httpObject.getSourceQueue().peekEntireQueue();
+		if (queued.size() > 0) {
+			LinkedList<String> idOutput = new LinkedList<String>();
+			int contentLength = 0;
+			for (String inQueue : queued) {
+				String inputId = "ID=" + this.findId(inQueue) + "\n";
+				idOutput.add(inputId);
+				contentLength += inputId.length();
+			}
+			outPutWriter.write("HTTP/1.1 200 OK\n");
+			outPutWriter.write("Content-Length=" + contentLength + "\n");
+			for (String id : idOutput) {
+				System.out.println(id);
+				outPutWriter.write(id.trim());
+			}
+		}
+	}
 	@Override
 	public void run() {
 		// Open connection

 		return header.substring(6, header.indexOf(" HTTP/1.1"));
 	}
+	private String getReqeustInfo(String inputLine) {
+		// Queuenaam / Content length
+		return inputLine.substring(5).trim();
+	}
+	private void handleSocketRequest(String inputLine) {
+		// Pak socket
+		SocketApp2QChannel inputSocket;
+		inputSocket = (SocketApp2QChannel) ESBServer.esbChannels.get("LocatorIn");
+		// Header info
+		String header = getReqeustInfo(inputLine);
+		String[] info = header.split("/");
+		// Queue controleren
+		if (this.getHttpQueueName(inputSocket).equals(info[0].trim())) {
+			try {
+				String readline = inputReader.readLine();
+				while (readline != null) {
+					inputSocket.getDestinationQueue().addToQueue(inputLine);
+					outPutWriter.println("ACK");
+					break;
+				}
+			} catch (Exception e) {
+				// Do nothing
+				outPutWriter.println("NACK");
+			}
+		} else {
+			outPutWriter.println("NACK");
+		}
+	}
 	private void handleValidRequest() {
 		int contentLength = 0;
 		try {
 	}
-	private void handleSocketRequest(String inputLine) {
-		// Pak socket
-		SocketApp2QChannel inputSocket;
-		inputSocket = (SocketApp2QChannel) ESBServer.esbChannels.get("LocatorIn");
-		// Header info
-		String header = getReqeustInfo(inputLine);
-		String[] info = header.split("/");
-		// Queue controleren
-		if (this.getHttpQueueName(inputSocket).equals(info[0].trim())) {
-			try {
-				String readline = inputReader.readLine();
-				while (readline != null) {
-					inputSocket.getDestinationQueue().addToQueue(inputLine);
-					outPutWriter.println("ACK");
-					break;
-				}
-			} catch (Exception e) {
-				// Do nothing
-				outPutWriter.println("NACK");
-			}
-		} else {
-			outPutWriter.println("NACK");
-		}
-	}
-	private String getReqeustInfo(String inputLine) {
-		// Queuenaam / Content length
-		return inputLine.substring(5).trim();
-	}
 	@Override
 	public void run() {
 		// Open connection

 public class ESBServer {
+	public static HashMap<String, Channel> esbChannels;
 	public static void main(String[] args) {
 		new ESBServer("C:/Users/Martijn/workspace/ESB/src/hanze/ga/wt3/xml/configuration.xml");
 	}
-	public static HashMap<String, Channel> esbChannels;
 	private HashMap<String, ESBQueue> esbQueues;
 	@SuppressWarnings("static-access")

 			this.buildFTPApp2Q(channelDef);
 		}
 	}
-	/**
-	 * Zorgt ervoor dat een Channel de juiste bron- en bestemmingsQueue heeft.
-	 */
-	private void linkQueueToChannel() {
-		for (ESBQueue esbQueue : this.queues.values()) {
-			// Link receiver
-			Channel receiver = esbQueue.getqReceiverChannel();
-			if (receiver instanceof App2Q) {
-				((App2Q) receiver).setDestinationQueue(esbQueue);
-			} else if (receiver instanceof Q2App) {
-				((Q2App) receiver).setSourceQueue(esbQueue);
-			}
-			// Link sender
-			Channel sender = esbQueue.getqSenderChannel();
-			if (sender instanceof App2Q) {
-				((App2Q) sender).setDestinationQueue(esbQueue);
-			} else if (sender instanceof Q2App) {
-				((Q2App) sender).setSourceQueue(esbQueue);
-			}
-		}
-	}
-	private void buildFTPApp2Q(Xml channel) {
-		FTPApp2QChannel ftp = new FTPApp2QChannel();
-		// Globale settings
-		ftp.setChannelName(channel.child("name").content());
-		// FTP Adapter waarden
-		Xml adapterNode = channel.child("adapter");
-		ftp.setFtpAddress(adapterNode.child("address").content());
-		ftp.setFtpInitDir(adapterNode.child("init-dir").content());
-		ftp.setFtpPassword(adapterNode.child("password").content());
-		ftp.setFtpUserName(adapterNode.child("username").content());
-		ftp.setChannelPort(adapterNode.child("port").content());
-		// Zet in lijst
-		this.channels.put(channel.child("name").content(), ftp);
-	}
 	/**
 	 * Bouwen van ESB aan de hand van XML-bestand.
 	 *
 		}
 	}
+	private void buildFTPApp2Q(Xml channel) {
+		FTPApp2QChannel ftp = new FTPApp2QChannel();
+		// Globale settings
+		ftp.setChannelName(channel.child("name").content());
+		// FTP Adapter waarden
+		Xml adapterNode = channel.child("adapter");
+		ftp.setFtpAddress(adapterNode.child("address").content());
+		ftp.setFtpInitDir(adapterNode.child("init-dir").content());
+		ftp.setFtpPassword(adapterNode.child("password").content());
+		ftp.setFtpUserName(adapterNode.child("username").content());
+		ftp.setChannelPort(adapterNode.child("port").content());
+		// Zet in lijst
+		this.channels.put(channel.child("name").content(), ftp);
+	}
 	private void buildFTPQ2App(Xml channel) {
 		FTPQ2AppChannel ftp = new FTPQ2AppChannel();
 		return queues;
 	}
+	/**
+	 * Zorgt ervoor dat een Channel de juiste bron- en bestemmingsQueue heeft.
+	 */
+	private void linkQueueToChannel() {
+		for (ESBQueue esbQueue : this.queues.values()) {
+			// Link receiver
+			Channel receiver = esbQueue.getqReceiverChannel();
+			if (receiver instanceof App2Q) {
+				((App2Q) receiver).setDestinationQueue(esbQueue);
+			} else if (receiver instanceof Q2App) {
+				((Q2App) receiver).setSourceQueue(esbQueue);
+			}
+			// Link sender
+			Channel sender = esbQueue.getqSenderChannel();
+			if (sender instanceof App2Q) {
+				((App2Q) sender).setDestinationQueue(esbQueue);
+			} else if (sender instanceof Q2App) {
+				((Q2App) sender).setSourceQueue(esbQueue);
+			}
+		}
+	}
 }

4.1 Webapplicaties Leertaken

Affected files

Weektaken2/Weektaak3/ESB/src/hanze/ga/wt3/channels/ESBQueue.java Download diff

Weektaken2/Weektaak3/ESB/src/hanze/ga/wt3/ftp/ESBFTP.java Download diff

Weektaken2/Weektaak3/ESB/src/hanze/ga/wt3/ftp/FTPApp2QChannel.java Download diff

Weektaken2/Weektaak3/ESB/src/hanze/ga/wt3/http/HTTPGetConnection.java Download diff

Weektaken2/Weektaak3/ESB/src/hanze/ga/wt3/http/HTTPPostConnection.java Download diff

Weektaken2/Weektaak3/ESB/src/hanze/ga/wt3/main/ESBServer.java Download diff

Weektaken2/Weektaak3/ESB/src/hanze/ga/wt3/xml/ESBDOMParser.java Download diff