// Path: src/com/tt/reaper/message/NotifyMessage.java
// public class NotifyMessage  extends RequestMessage {
// 	public NotifyMessage(Request request) {
// 		super(Message.NOTIFY, request);
// 	}
// 
// 	public NotifyMessage(String data)
// 	{
// 		super(SipMessage.NOTIFY, Request.NOTIFY, getNewCallId());
// 		init(data);
// 	}
// 
// 	private boolean init(String data)
// 	{
// 		if (super.init() == false)
// 			return false;
// 		try {
// 			ContentTypeHeader contentTypeHeader;
// 			contentTypeHeader = headerFactory
// 					.createContentTypeHeader("application", "text/plain");
// 			request.setContent(data, contentTypeHeader);
// 			return true;
// 		}
// 		catch (Exception e)
// 		{
// 			logger.error("Error adding content: ", e);
// 		}
// 		return false;
// 	}
// }


import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertTrue;
import java.io.FileInputStream;
import java.util.Iterator;
import org.junit.Test;
import com.tt.reaper.message.NotifyMessage;
package com.tt.reaper.rtcp;





public class TestRtcpPacket {
	public static final String XRFILE = "data/rtcpxr.data";
	public static final String RECEIVER_FILE = "data/rtcp_receiver_report.data";
	public static final String SENDER_FILE = "data/rtcp_sender_report.data";
	public static final String SOURCE_MAC = "00:00:00:00:00:00";
	public static final String SOURCE_IP = "10.0.100.1";
	public static final int SOURCE_PORT = 9091;
	public static final String DESTINATION_MAC = "01:01:01:01:01:01";
	public static final String DESTINATION_IP = "100.1.1.1";
	public static final int DESTINATION_PORT = 8081;
	private static final int BUFFER_SIZE = 1024;
	private static byte[] buffer = new byte[BUFFER_SIZE];
    
    public static DataPacket create(String fileName)
    {
// Path: src/com/tt/reaper/message/NotifyMessage.java
// public class NotifyMessage  extends RequestMessage {
// 	public NotifyMessage(Request request) {
// 		super(Message.NOTIFY, request);
// 	}
// 
// 	public NotifyMessage(String data)
// 	{
// 		super(SipMessage.NOTIFY, Request.NOTIFY, getNewCallId());
// 		init(data);
// 	}
// 
// 	private boolean init(String data)
// 	{
// 		if (super.init() == false)
// 			return false;
// 		try {
// 			ContentTypeHeader contentTypeHeader;
// 			contentTypeHeader = headerFactory
// 					.createContentTypeHeader("application", "text/plain");
// 			request.setContent(data, contentTypeHeader);
// 			return true;
// 		}
// 		catch (Exception e)
// 		{
// 			logger.error("Error adding content: ", e);
// 		}
// 		return false;
// 	}
// }


// Path: test/com/tt/reaper/rtcp/TestRtcpPacket.java
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertTrue;
import java.io.FileInputStream;
import java.util.Iterator;
import org.junit.Test;
import com.tt.reaper.message.NotifyMessage;

package com.tt.reaper.rtcp;





public class TestRtcpPacket {
	public static final String XRFILE = "data/rtcpxr.data";
	public static final String RECEIVER_FILE = "data/rtcp_receiver_report.data";
	public static final String SENDER_FILE = "data/rtcp_sender_report.data";
	public static final String SOURCE_MAC = "00:00:00:00:00:00";
	public static final String SOURCE_IP = "10.0.100.1";
	public static final int SOURCE_PORT = 9091;
	public static final String DESTINATION_MAC = "01:01:01:01:01:01";
	public static final String DESTINATION_IP = "100.1.1.1";
	public static final int DESTINATION_PORT = 8081;
	private static final int BUFFER_SIZE = 1024;
	private static byte[] buffer = new byte[BUFFER_SIZE];
    
    public static DataPacket create(String fileName)
    {
    	NotifyMessage message = createDatagram(fileName);