Changeset 369

User picture

Author: klystr

(2009/12/07 11:19) About 2 years ago


  





Affected files




    

          

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




      
      
368369
15
	private Socket socket;
15
	private Socket socket;



16
	private PrintWriter outPutWriter;
16
	private PrintWriter outPutWriter;



17
	private BufferedReader inputReader;
17
	private BufferedReader inputReader;



18
	private String inputMessage;



19
	private HTTPApp2QChannel httpObject;
18
	private HTTPApp2QChannel httpObject;



20
19



21
	public HTTPPostConnection(Socket accept, HTTPApp2QChannel httpObject) {
20
	public HTTPPostConnection(Socket accept, HTTPApp2QChannel httpObject) {





          

  Updated
Weektaken2/Weektaak3/ESB/src/hanze/ga/wt3/socket/SocketApp2QChannel.java  Download diff




      
      
368369
6
6



7
	@Override
7
	@Override



8
	public void run() {
8
	public void run() {



9
9
		



10
	}
10
	}



11
11



12
}
12
}





          

  Updated
Weektaken2/Weektaak3/ESB/src/hanze/ga/wt3/socket/SocketQ2AppChannel.java  Download diff




      
      
368369
1
package hanze.ga.wt3.socket;
1
package hanze.ga.wt3.socket;



2
2



3
import java.io.PrintWriter;



4
import java.net.Socket;



5



3
import hanze.ga.wt3.channels.Q2App;
6
import hanze.ga.wt3.channels.Q2App;



4
7



5
public class SocketQ2AppChannel extends Q2App {
8
public class SocketQ2AppChannel extends Q2App {



6
9



7
	@Override
10
	@Override



8
	public void run() {
11
	public void run() {



12
		try {



13
			while (true) {



14
				this.Q2socket();



15
				Thread.sleep(3000);



16
			}



17
		} catch (Exception e) {



18
			e.printStackTrace();



19
		}



20
	}



9
21



22
	private void Q2socket() {



23
		while (this.getSourceQueue().getSize() > 0) {



24
			this.sendToSocket(this.getSourceQueue().pollFromQueue());



25
		}



10
	}
26
	}



11
27



28
	private void sendToSocket(String queueItem) {



29
		try {



30
			// Open socket



31
			Socket socket = new Socket(this.getChannelIp(), this.getChannelPort());



32
			PrintWriter outPutWriter = new PrintWriter(socket.getOutputStream(), true);



33
			



34
			// Schrijf queueItem naar socket



35
			outPutWriter.write(queueItem);



36
			



37
			// Sluiten



38
			outPutWriter.close();



39
			socket.close();



40
		} catch (Exception e) {



41
			e.printStackTrace();



42
		}



43
	}



44



12
}
45
}