package com.zeromq.test.Sync_pub_sub;
import org.zeromq.ZMQ;
import org.zeromq.ZMQ.Context;
import org.zeromq.ZMQ.Socket;

/**
 * @author 呂桂強
 * @email [email protected]
 * @version 建立時間：2012-4-26 下午8:17:40
 */
public class syncpub{
	//等待10個訂閱者
	protected static int SUBSCRIBERS_EXPECTED = 10;

	public static void main (String[] args) {
		Context context = ZMQ.context(1);
		Socket publisher = context.socket(ZMQ.PUB);
		publisher.bind("tcp://*:5561");
		try {
			//zmq傳送速度太快，在訂閱者尚未與釋出者建立聯絡時，已經開始了資料釋出
			Thread.sleep (1000);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}  
		
		int update_nbr;
		for (update_nbr = 0; update_nbr < 10; update_nbr++){
			publisher.send("Rhubarb".getBytes(), ZMQ.NOBLOCK);
		}
		publisher.send("END".getBytes(), 0);

		       

		publisher.close();
		context.term();
	}
}