package com.cpsoft.microqm.example;

import java.util.Date;

import com.cpsoft.microqm.client.uQmClient;
import com.cpsoft.microqm.common.Message;

public class speedTest
{
	//Preset Queue Manager Parameters
	static String qm = "10.1.2.102";
	static int qmPort = 7474;
	static int clientPort = 7475;

	public static void main(String[] args)
	{
		Message msg = new Message();

		uQmClient uqm = new uQmClient(qm, qmPort, clientPort);	//Connect to QueueManager on the specified ports
		uqm.createQueue("speed", false);
		System.out.println("Start: " +new Date());
		for(int i=0;i<10;i++)
		{
			msg.setPayload("Message " + i);
			uqm.sendMessage("speed", msg);
		}
		System.out.println("After Put: " + new Date());
		for(int i=0;i<10;i++)
		{
			msg = uqm.getMessage("speed");
			System.out.println((String)msg.getPayload());
		}
		System.out.println("After Get: " + new Date());
		uqm.deleteQueue("speed");
	}
}