David Welford-Costelloe Forums » Post 42

Main Menu

Home

Members

Profile
Your Account

Community

Forums

Statistics

Statistics
Top 10

Files & Links

Downloads

News

Other

    Tutorials
    Content
    FAQ
    Site Map

Forum Index · Search · Usergroups · Edit your profile · Members · Login, Check Messages
Arcade · Ranks · Staff · Statistics · Board Rules · Forum FAQ · Log in

Recent Topics

Next 6 >>

Forum

Author

Replies

Last Post

Ubuntu - Free Linux Operating System

Linux Distros

dcostelloe

Sun Apr 22, 2012 9:09 pm
dcostelloe

Free ASP NET Wiki - Open Source

Open Source

dcostelloe

Sun Mar 18, 2012 2:12 pm
dcostelloe

SpiceWorks It Support Open Source

Open Source

dcostelloe

Sat Mar 17, 2012 12:49 pm
dcostelloe

What I am doing today

Chat

dcostelloe

Mon Feb 20, 2012 8:49 pm
dcostelloe

Common Error with Biztalk file loading

Enterprise Service Bus

dcostelloe

Wed Jan 25, 2012 6:39 pm
dcostelloe

Create PDF using Big Faceless Java PDF Library

Java

LewisIngram

Mon Dec 19, 2011 12:17 pm
LewisIngram

Read a WebSphere WMQ

David Welford-Costelloe Forums Forum Index -> Java

View previous topic :: View next topic

Author

Message

dcostelloe
Major-General

Gender:

Joined: May 28, 2011
Age: 51
Posts: 206
Location: Burlington, Ontario
Reputation: 52

Status: Offline

Posted: Sun May 29, 2011 1:20 am Post subject:

Read a WebSphere WMQ

The following Code show you how to read messages from a WebSphere Queue. This code is part of the Tutorial Using SharpDevelop IDE 3.2 to Develop WebSphere 6.0 Client Part 2

Code:

#region Send WMQ Message
   /// <summary>
   /// Write to WebSphere Queue Method
   /// </summary>
   private void writeWMQ()
   {
   string sRequestManager = null;
   string sRequestQueue = null;

   foreach (PropertiesClass oList in props) {
      sRequestManager = oList.RequestQManager;
      sRequestQueue = oList.RequestQueueName;
   }
   try {
      // Create a connection to the queue manager
      requestQMgr = new MQQueueManager(sRequestManager);

      // Set options
      int iOptions = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT;

      // Open queue and set options
      requestQueue = requestQMgr.AccessQueue(sRequestQueue, iOptions,
            null, null, null);
      // Build Message
      MQMessage send_msg = new MQMessage();
      // Get the message from the TextBox
      send_msg.WriteUTF(txtMessage.Text.Trim());
      // Set the options
      MQPutMessageOptions pmo = new MQPutMessageOptions();
      // put the message on the queue
      requestQueue.Put(send_msg, pmo);
      // Close the Queue
      requestQueue.Close();
      // Disconnect from the queue manager
      requestQMgr.Disconnect();
      setMessages("Message has been placed on the Queue "
            + sRequestQueue + " With Message of: "
            + txtMessage.Text);

   } catch (MQException ex) {
      // MQ Error
      Debug.Print("An MQSeries error occurred : Completion code "
            + ex.CompletionCode + " Reason code " + ex.ReasonCode);
      setMessages("An MQException error: Completion code "
            + ex.CompletionCode + " Reason code " + ex.ReasonCode);

   }
   // Buffer Error?
   catch (Exception ex) {
      Debug.Print("An error occurred while writing to the message buffer: "
                  + ex);
      setMessages("An error occurred while writing to the message buffer: "
                  + ex);
   }

}
#endregion

Enjoy
David

	Tweet	David Welford-Costelloe Forums Forum Index -> Java	Time synchronized with your computer time
Page 1 of 1

You cannot post new topics in this forum
You cannot reply to topics in this forum
You cannot edit your posts in this forum
You cannot delete your posts in this forum
You cannot vote in polls in this forum
You cannot attach files in this forum
You cannot download files in this forum