root/Weektaken2/Weektaak3/ESB/src/hanze/ga/wt3/socket/SocketQ2AppChannel.java

Show revision log
 
354369
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
}