Subversion Repositories udp_ip_stack

package com.pjf;
 
import java.io.IOException;
import java.net.SocketException;
import java.net.UnknownHostException;
 
public class UDPTestStream {
	private UDPCxn cxn;
	private Listener listener;
 
	class Listener extends Thread {
 
		@Override
		public void run() {
			byte[] rep;
			while (true) {
				try {
					rep = cxn.rcv();
					String reply = new String(rep);
					System.out.println("Got [" + reply + "]");			
				} catch (IOException e) {
					e.printStackTrace();
				}
			}
		}
	}
 
	public UDPTestStream() throws SocketException, UnknownHostException {
		cxn = new UDPCxn("192.168.5.9");
		listener = new Listener();
		listener.start();
	}
 
	public void go() throws IOException, InterruptedException {
		String fix1 = "1=45~34=";
		String fix2 = "~18=23~";
		for (int price=225; price>=150; price--) {
			StringBuffer fixmsg = new StringBuffer(fix1);
			fixmsg.append(Integer.toString(price));
			fixmsg.append(fix2);
			System.out.println("Sending price tick " + price);
			cxn.fixSend(fixmsg.toString(), 2000, false);
		}
		Thread.sleep(2000);
	}
 
 
	public static void main(String[] args) {
		UDPTestStream ut;
		try {
			ut = new UDPTestStream();
			ut.go();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
 
 
}