public class MSMQServer
{
  /**
   * The main entry point for the application
   *
   * @param args Array of parameters passed to the
   * application via the comand line.
   */
  public static void main(String[] args)
  {
    // This is the typeid that will be associated with the
    // new queue
    String typeID = "{E9E8CB90-D05E-11d2-B9D0-006097A7D34F}";
 
    Variant variantTrue = new Variant();
    Variant variantNoParam = new Variant();
    Variant guid = new Variant();
    Variant nop = new Variant((int)RELOPS.REL_NOP);
    Variant isEqual = new Variant((int)RELOPS.REL_EQ);
    Variant oneSecondDelay = new Variant();
    Variant theBody = new Variant();
    Variant transactionHolder = new Variant();
 
    IMSMQQueueInfo queueInfo = (IMSMQQueueInfo)new MSMQQueueInfo();
    IMSMQQueue queue = null;
    IMSMQMessage message = new MSMQMessage();
    IMSMQTransactionDispenser transactionDispenser = new MSMQTransactionDispenser();
    IMSMQTransaction transaction;
 
    //Setting the variables
    variantTrue.putBoolean(true);
    variantNoParam.noParam();
    oneSecondDelay.putInt(1000);
 
    queueInfo.putPathName(".\\testQueue");
    queueInfo.putLabel("testQueue");
    queueInfo.putJournal(MQJOURNAL.MQ_JOURNAL);
    queueInfo.putServiceTypeGuid(typeID);
 
    try
    {
      queueInfo.Create(variantTrue,variantTrue);
    }
    catch(ComFailException except)
    {
    }
 
    queue = queueInfo.Open(MQACCESS.MQ_SEND_ACCESS, MQSHARE.MQ_DENY_NONE);
    theBody.putString("This is a test");
    message.putBody(theBody);
    message.putJournal(MQMSGJOURNAL.MQMSG_JOURNAL);
 
    transaction = transactionDispenser.BeginTransaction();
    try
    {
      transactionHolder.putDispatch(transaction);
      message.Send(queue,transactionHolder);
      transaction.Commit(variantNoParam, variantNoParam, variantNoParam);
    }
    catch(Exception transactionFailed)
    {
      transaction.Abort(variantNoParam, variantNoParam);
    }
  }
}