- wimoqueue.zip
- Documentation
- bin
- Documentation.dll
- Documentation.pdb
- Documentation.csproj
- Documentation.csproj.user
- Images
- Properties
- ReadMe.html
- WiMoQ_ClassHierarchy.png
- WiMoQMembers.png
- WiMoQPower.png
- WiMoQReaderWriter.png
- WiMoQWriter.png
- J2i.Net.NamedObjects
- J2i.Net.PowerQueue
- J2i.Net.ReaderWriterClient
- J2i.Net.WriterClient
- WiMoMessageQueues.sln
- WiMoMessageQueues.vsmdi
|
using System;
using System.IO;
using System.Linq;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Text;
using System.Windows.Forms;
using J2i.Net.NamedObjects;
namespace J2i.Net.WriterClient
{
public partial class Form1 : Form
{
const string QueueEndpointName = "J2i.Net.ReaderWriterTestQueue";
const int maxItems = 8;
const int maxMessageSize = 1024;
string _helpFilePath ;
MessageQueueWriter _writer = null;
string HelpFilePath
{
get
{
if (_helpFilePath == null)
{
_helpFilePath = Path.Combine(Path.GetDirectoryName(this.GetType().Assembly.GetModules()[0].FullyQualifiedName), "J2i.Net.WriterClient.Htlp.html");
}
return _helpFilePath;
}
}
public Form1()
{
InitializeComponent();
_writer = new MessageQueueWriter(QueueEndpointName, maxItems, maxMessageSize);
}
private void Form1_Load(object sender, EventArgs e)
{
}
private void miExit_Click(object sender, EventArgs e)
{
_writer.Dispose();
this.Close();
}
private void cmdSend_Click(object sender, EventArgs e)
{
QueueResult result = _writer.Write(this.txtMessage.Text,2000);
if (result == QueueResult.OK)
{
txtMessage.Text = String.Empty;
statusBar.Text = "Message Send.";
}
else
{
statusBar.Text = String.Format("Message not sent:{0}", result);
}
UpdateQueueInfo();
txtMessage.Focus();
}
void UpdateQueueInfo()
{
MessageQueueInfo mqinfo = _writer.GetMessageQueueInfo();
this.lvQueueInfo.Items.Clear();
ListViewItem item;
item = new ListViewItem(new string[] { "Number of Writers", mqinfo.NumWriters.ToString() });
lvQueueInfo.Items.Add(item);
item = new ListViewItem(new string[] { "Number of Readers", mqinfo.NumReaders.ToString() });
lvQueueInfo.Items.Add(item);
item = new ListViewItem(new string[] { "Max Message Count", mqinfo.dwMaxQueueMessages.ToString() });
lvQueueInfo.Items.Add(item);
item = new ListViewItem(new string[] { "Max Messages", mqinfo.dwMaxMessages.ToString() });
lvQueueInfo.Items.Add(item);
item = new ListViewItem(new string[] { "Current Messages", mqinfo.dwCurrentMessages.ToString() });
lvQueueInfo.Items.Add(item);
}
private void miQueueInfo_Click(object sender, EventArgs e)
{
UpdateQueueInfo();
}
private void Form1_HelpRequested(object sender, HelpEventArgs hlpevent)
{
Help.ShowHelp(this, HelpFilePath);
}
}
}
|
By viewing downloads associated with this article you agree to the Terms of Service and the article's licence.
If a file you wish to view isn't highlighted, and is a text file (not binary), please
let us know and we'll add colourisation support for it.