I have correctly send message in MonoTouch Project using RabbitMQ.NET Client
DLL.
and use this to get receive messages(all parameters is correct):
IModel channel=null;
string ServerIP="192.168.68.4";
string queueName="172.16.1.1";
//int port=15672;
ConnectionFactory cf=new ConnectionFactory();
cf.HostName=ServerIP;
//
cf.Protocol=RabbitMQ.Client.Protocols.DefaultProtocol;
IConnection conn=cf.CreateConnection();
Console.WriteLine ("factory.CreateConnection()");
channel = conn.CreateModel ();
Console.WriteLine ("RECEIVE :
_RMQConnection.CreateModel()");
channel.QueueDeclare(queueName, true, false,false,null);
_receiveMessageConsumer = new
QueueingBasicConsumer(channel);
channel.BasicConsume(queueName, true,
_receiveMessageConsumer);
Console.WriteLine("channel.BasicConsume(_QueueName, true,
_receiveMessageConsumer)....");
while (_DoneFlag==false) {
object result = null;
_receiveMessageConsumer.Queue.Dequeue(400, out result);
BasicDeliverEventArgs messageInEnvelope = null;
if (result!=null)
{
messageInEnvelope =
(BasicDeliverEventArgs)result;
}
if (messageInEnvelope == null) {
Console.WriteLine("messageInEnvelope == null)");
continue;
}
byte[] bytes = messageInEnvelope.Body;
string
str=System.Text.Encoding.UTF8.GetString(bytes);
Console.WriteLine("接受到的消息：" + str);
//RMQMessage msg =
JsonConvert.DeserializeObject<RMQMessage>(System.Text.Encoding.UTF8.GetString(bytes));
//System.Threading.Thread.Sleep(30);
}
---> When i send message to RabbitMQ Server(by manual or programmiaclly) ,
it occurs ''SharedQueue closed" Error (System.IO.EndOfStreamException )....
help :)
Those are all exception information:
System.IO.EndOfStreamException: SharedQueue closed
at RabbitMQ.Util.SharedQueue.EnsureIsOpen () [0x00000] in <filename
unknown>:0
at RabbitMQ.Util.SharedQueue.Dequeue (Int32 millisecondsTimeout,
System.Object& result) [0x00000] in <filename unknown>:0
at RabbitMQ_MonoTouchTest.MainViewController.StartReceiveTest1 ()
[0x00082] in
/Users/yj/Desktop/RMQ2/RabbitMQ/RabbitMQ_MonoTouchTest/MainViewController.cs:163
at RabbitMQ_MonoTouchTest.MainViewController.ViewDidLoad () [0x00006] in
/Users/yj/Desktop/RMQ2/RabbitMQ/RabbitMQ_MonoTouchTest/MainViewController.cs:63
at (wrapper managed-to-native)
MonoTouch.UIKit.UIApplication:UIApplicationMain (int,string[],intptr,intptr)
at MonoTouch.UIKit.UIApplication.Main (System.String[] args, System.String
principalClassName, System.String delegateClassName) [0x0004c] in
/Developer/MonoTouch/Source/monotouch/src/UIKit/UIApplication.cs:38
at RabbitMQ_MonoTouchTest.Application.Main (System.String[] args)
[0x00000] in
/Users/yj/Desktop/RMQ2/RabbitMQ/RabbitMQ_MonoTouchTest/Main.cs:27
--
View this message in context:
http://monotouch.2284126.n4.nabble.com/Run-SharedQueue-closed-Error-when-i-send-RabbitMQ-Message-tp4657968.html
Sent from the MonoTouch mailing list archive at Nabble.com.
_______________________________________________
MonoTouch mailing list
[email protected]
http://lists.ximian.com/mailman/listinfo/monotouch
