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

Show revision log
 
366368
32
		return header.substring(6, header.indexOf(" HTTP/1.1"));
32
		return header.substring(6, header.indexOf(" HTTP/1.1"));
33
	}
33
	}
34
34



35
	private String getReqeustInfo(String inputLine) {



36
		// Queuenaam / Content length



37
		return inputLine.substring(5).trim();



38
	}



39



40
	private void handleSocketRequest(String inputLine) {



41



42
		// Pak socket



43
		SocketApp2QChannel inputSocket;



44
		inputSocket = (SocketApp2QChannel) ESBServer.esbChannels.get("LocatorIn");



45



46
		// Header info



47
		String header = getReqeustInfo(inputLine);



48
		String[] info = header.split("/");



49



50
		// Queue controleren



51
		if (this.getHttpQueueName(inputSocket).equals(info[0].trim())) {



52
			try {



53
				String readline = inputReader.readLine();



54
				while (readline != null) {



55
					inputSocket.getDestinationQueue().addToQueue(inputLine);



56
					outPutWriter.println("ACK");



57
					break;



58
				}



59
			} catch (Exception e) {



60
				// Do nothing



61
				outPutWriter.println("NACK");



62
			}



63
		} else {



64
			outPutWriter.println("NACK");



65
		}



66
	}



67



35
	private void handleValidRequest() {
68
	private void handleValidRequest() {



36
		int contentLength = 0;
69
		int contentLength = 0;



37
		try {
70
		try {


...
...
103
136



104
	}
137
	}



105
138



106
	private void handleSocketRequest(String inputLine) {



107



108
		// Pak socket



109
		SocketApp2QChannel inputSocket;



110
		inputSocket = (SocketApp2QChannel) ESBServer.esbChannels.get("LocatorIn");



111



112
		// Header info



113
		String header = getReqeustInfo(inputLine);



114
		String[] info = header.split("/");



115



116
		// Queue controleren



117
		if (this.getHttpQueueName(inputSocket).equals(info[0].trim())) {



118
			try {



119
				String readline = inputReader.readLine();



120
				while (readline != null) {



121
					inputSocket.getDestinationQueue().addToQueue(inputLine);



122
					outPutWriter.println("ACK");



123
					break;



124
				}



125
			} catch (Exception e) {



126
				// Do nothing



127
				outPutWriter.println("NACK");



128
			}



129
		} else {



130
			outPutWriter.println("NACK");



131
		}



132
	}



133



134
	private String getReqeustInfo(String inputLine) {



135
		// Queuenaam / Content length



136
		return inputLine.substring(5).trim();



137
	}



138



139
	@Override
139
	@Override



140
	public void run() {
140
	public void run() {



141
		// Open connection
141
		// Open connection