using System;
using System.Text;
using System.Messaging;
using System.Collections;
using System.EnterpriseServices;
using System.Security.Cryptography;
using System.Security.Cryptography.Xml;
public class CJIJMessageQueueForAD2 : ServicedComponent
{
public System.Messaging.MessageQueue msmq;
public CJIJMessageQueueForAD2()
{}
public string AdShoot(string mqTitle, string mqBody)
{
try
{
///Queue Check Logic
Adprepared();
//msmq = new System.Messaging.MessageQueue(@".\Private$\CJIJAdvertisement01");
}
catch(Exception e)
{
return "1-1 : " + e.Message + " / " + e.Source + " / " + e.InnerException + " / " + e.StackTrace + " / " + e.TargetSite + " / " + e.HelpLink;
}
try
{
System.Messaging.Message msgCue = new System.Messaging.Message();
msgCue.Body = mqBody.ToString();
msgCue.Label = mqTitle.ToString();
msgCue.AcknowledgeType = AcknowledgeTypes.PositiveArrival | AcknowledgeTypes.PositiveReceive;
msmq.Send(msgCue);
return "1-2 : Message Send Complete";
}
catch(Exception e)
{
return "1-2 : " + e.Message + " / " + e.Source + " / " + e.InnerException + " / " + e.StackTrace + " / " + e.TargetSite + " / " + e.HelpLink;
}
}
public string CreateMQ()
{
try
{
//if(MessageQueue.Exists("FormatName:DIRECT="+MQNameURL.ToString()))
//msmq = new System.Messaging.MessageQueue("FormatName:DIRECT="+MQNameURL.ToString());
msmq = new System.Messaging.MessageQueue(@".\Private$\CJIJAdvertisement02");
return "2-1 : MSMQ Create Complete";
}
catch(Exception e)
{
return "2-1 : " + e.Message + " / " + e.Source + " / " + e.InnerException + " / " + e.StackTrace + " / " + e.TargetSite + " / " + e.HelpLink;
}
}
public void Adprepared()
{
if(MessageQueue.Exists(@".\Private$\CJIJAdvertisement02"))
msmq = new System.Messaging.MessageQueue(@".\Private$\CJIJAdvertisement02");
else
msmq = MessageQueue.Create(@".\Private$\CJIJAdvertisement02");
}
}