15,911,762 members
Sign in
Sign in
Email
Password
Forgot your password?
Sign in with
home
articles
Browse Topics
>
Latest Articles
Top Articles
Posting/Update Guidelines
Article Help Forum
Submit an article or tip
Import GitHub Project
Import your Blog
quick answers
Q&A
Ask a Question
View Unanswered Questions
View All Questions
View C# questions
View C++ questions
View Javascript questions
View Visual Basic questions
View Python questions
discussions
forums
CodeProject.AI Server
All Message Boards...
Application Lifecycle
>
Running a Business
Sales / Marketing
Collaboration / Beta Testing
Work Issues
Design and Architecture
Artificial Intelligence
ASP.NET
JavaScript
Internet of Things
C / C++ / MFC
>
ATL / WTL / STL
Managed C++/CLI
C#
Free Tools
Objective-C and Swift
Database
Hardware & Devices
>
System Admin
Hosting and Servers
Java
Linux Programming
Python
.NET (Core and Framework)
Android
iOS
Mobile
WPF
Visual Basic
Web Development
Site Bugs / Suggestions
Spam and Abuse Watch
features
features
Competitions
News
The Insider Newsletter
The Daily Build Newsletter
Newsletter archive
Surveys
CodeProject Stuff
community
lounge
Who's Who
Most Valuable Professionals
The Lounge
The CodeProject Blog
Where I Am: Member Photos
The Insider News
The Weird & The Wonderful
help
?
What is 'CodeProject'?
General FAQ
Ask a Question
Bugs and Suggestions
Article Help Forum
About Us
Search within:
Articles
Quick Answers
Messages
Comments by Member 11837253 (Top 6 by date)
Member 11837253
5-Apr-18 10:54am
View
Deleted
I am still having same issue. I have to manually stop and start service everytime to read messages from msmq. Here is my code
protected override void OnStart(string[] args)
{
JobModel job = new JobModel();
MessageQueue msMq = new MessageQueue(MqResponseName);
msMq.Formatter = new XmlMessageFormatter(new Type[] { typeof(JobModel) });
while (mq != null)
{
var msg = (JobModel)mq.Receive().Body;
job.ClientId = msg.ClientId;
job.LDS = msg.LDS;
msMq.Label = job.LDS + "Recieved";
//sending message from request queue to response queue with Status "Recieved"
msMq.Send(msg);
}
}
Member 11837253
4-Apr-18 17:04pm
View
Deleted
I tried that code, it didn't worked.
protected override void OnStart(string[] args)
{
while (mq != null)
mq.Receive();
}
Member 11837253
4-Apr-18 16:27pm
View
Windows service picking messages only when i start it and after that it stops listening
Member 11837253
4-Apr-18 16:25pm
View
I added but no luck. I modified code
public partial class Service1 : ServiceBase
{
private const string MqName = @".\private$\RequestQueue";
private static MessageQueue _mq;
private static MessageQueue mq
{
get
{
if (_mq == null)
{
if (!MessageQueue.Exists(MqName))
MessageQueue.Create(MqName);
_mq = new MessageQueue(MqName, QueueAccessMode.ReceiveAndAdmin);
_mq.Formatter = new BinaryMessageFormatter();
}
return _mq;
}
}
public Service1()
{
InitializeComponent();
mq.ReceiveCompleted += new ReceiveCompletedEventHandler(mq_ReceiveCompleted);
}
private void mq_ReceiveCompleted(object sender, ReceiveCompletedEventArgs e)
{
MessageQueue cmq = (MessageQueue)sender;
try
{
Message msg = cmq.EndReceive(e.AsyncResult);
}
catch
{
}
cmq.Refresh();
cmq.BeginReceive();
}
protected override void OnStart(string[] args)
{
while(mq != null)
mq.BeginReceive();
}
private void MsMq_ReceiveCompleted(object sender, ReceiveCompletedEventArgs e)
{
var msMq = (MessageQueue)sender;
var msg = msMq.EndReceive(e.AsyncResult);
msMq.BeginReceive();
}
protected override void OnStop()
{
if (mq != null)
mq.Close();
return;
}
}
Member 11837253
4-Apr-18 15:51pm
View
Deleted
OnStart method I am already checking like this:
protected override void OnStart(string[] args)
{
if (mq != null)
mq.BeginReceive();
}
Member 11837253
4-Apr-18 15:50pm
View
Deleted
Thanks for the quick response. Where do I add this condition?
Show More