I am referencing the downloaded 1.5.3 RabbitMQ.Client and RabbitMQ.ServiceModel...<br><br><CodeSnip><br>//subscribe call in winform button click event...<br><br>using (System.ServiceModel.ChannelFactory<IDispatcherService> scf = GetDispatcherCF())<br>
{<br> IDispatcherService client = scf.CreateChannel();<br> client.Subscribe(new SubscriberInfo("amqp:///subscriber", "c1", "c2"));<br>}<br><br>//IDispatcherService Interface...<br><br>using Test.Entity;<br>
using System;<br>using System.ServiceModel;<br><br>namespace Test.Base<br>{<br> [ServiceContract]<br> public interface IDispatcherService<br> {<br> [OperationContract(IsOneWay = true)]<br> void Publish(Message message);<br>
[OperationContract(IsOneWay = true)]<br> void Subscribe(SubscriberInfo subscriber);<br> [OperationContract(IsOneWay = true)]<br> void Unsubscribe(SubscriberInfo subscriber, bool removeAllContexts);<br>
}<br>}<br><br>//GetDispatcherCF() called by winform button click event above...<br><br>private ChannelFactory<IDispatcherService> GetDispatcherCF()<br>{<br> ChannelFactory<IDispatcherService> scf;<br> <br>
<b>//the error I posted previously and below occurs here during the RabbitMQBinding instantiation... </b><br> scf = new ChannelFactory<IDispatcherService>(<br> new RabbitMQBinding(<br> new Uri("amqp://localhost:5672/"), <br>
Protocols.AMQP_0_8),<br> new EndpointAddress("amqp:///dispatcher"));<br><br><br> return scf;<br>}<br><br></CodeSnip><br><br><ErrorSnip><br>the following is returned...<br>
<br>The AMQP operation was interrupted:
AMQP close-reason, initiated by Library, code=311, text="The body of a
message (18446744073709551575 bytes) was too long.", classId=0,
methodId=0, cause=RabbitMQ.Client.Impl.<div id=":18v" class="ii gt">BodyTooLongException: The body of a message (18446744073709551575 bytes) was too long.<br>
at RabbitMQ.Client.Impl.ContentHeaderBase.ReadFrom(Int32 channelNumber, NetworkBinaryReader reader) in C:\RabbitMQ.Client\RabbitMQ\Client\Impl\ContentHeaderBase.cs:line 23<br> at RabbitMQ.Client.Impl.CommandAssembler.HandleFrame(Frame f) in C:\RabbitMQ.Client\RabbitMQ\Client\Impl\CommandAssembler.cs:line 53<br>
at RabbitMQ.Client.Impl.Session.HandleFrame(Frame frame) in C:\RabbitMQ.Client\RabbitMQ\Client\Impl\Session.cs:line 16<br> at RabbitMQ.Client.Impl.ConnectionBase.MainLoopIteration() in C:\RabbitMQ.Client\RabbitMQ\Client\Impl\ConnectionBase.cs:line 434<br>
at RabbitMQ.Client.Impl.ConnectionBase.MainLoop() in C:\RabbitMQ.Client\RabbitMQ\Client\Impl\ConnectionBase.cs:line 388</div><br></ErrorSnip><br><br>