<div>Matthias,</div> <div> </div> <div>Thanks for your response. I cleared everything in my Mnesia and Log files and restarted the broker. I also changed my props.DeliveryMode = 1 to make non persistent messages on basicpublish. I also ensured that my basicpublisher closes both the channel and connections properly in the basicpublisher code. </div> <div> </div> <div>I tried running this code on multiple computers and still get the same problem. I also ran it against your dev environment hoping that maybe it was a problem with my installed broker but it still did not work. Earlier today I also took the SimpleSubscriber Java solution and build that sample. And the Java one just works perfectly without any problems. I used the same simple publisher and the java simplesubscriber just blocked and received msgs whenever I sent them via the simplepublisher. So I am thinking probably the one thing left to
verify is whether or not we are running the same RabbitMQ.Client DLL file. I sent you the version that I am running, please let me know if we are running the same one.</div> <div> </div> <div>Here is the sequence of events to explain the attached log file:</div> <div> </div> <div>1) Start broker and broker rebuilds fresh cope of both db and log directories after I had deleted the old ones</div> <div>2) Run my basicpublisher program twice to publish two simple "hello" msgs</div> <div>3) Rum my basicsubscriber program which dequeues the two msgs and immediately throws the EndOfStream Exception and I think in the log results in the "abrupt socket closure".</div> <div>4) I again run my basicsubscriber program and this time there is no msg in the queue so when it tries to deque .. there is nothing ... and it immediately causes another "abrupt socket closure" in log. Here is the log:</div> <div> </div> <div><BR>=INFO REPORT====
31-Mar-2008::03:29:00 ===<BR> application: mnesia<BR> exited: stopped<BR> type: temporary</div> <div>=INFO REPORT==== 31-Mar-2008::03:29:00 ===<BR>Added vhost <<"/">></div> <div>=INFO REPORT==== 31-Mar-2008::03:29:00 ===<BR>Created user <<"guest">></div> <div>=INFO REPORT==== 31-Mar-2008::03:29:00 ===<BR>Rolling persister log to "c:/Documents and Settings/Development/rabbitmq/db/rabbit-mnesia/rabbit_persister.LOG.previous"</div> <div>=INFO REPORT==== 31-Mar-2008::03:29:00 ===<BR>started TCP listener on 0.0.0.0:5672</div> <div>=INFO REPORT==== 31-Mar-2008::03:30:50 ===<BR>accepted TCP connection on 0.0.0.0:5672 from 10.10.10.25:2581</div> <div>=INFO REPORT==== 31-Mar-2008::03:30:50 ===<BR>closing TCP connection from 10.10.10.25:2581</div> <div>=INFO REPORT==== 31-Mar-2008::03:30:53 ===<BR>accepted TCP connection on 0.0.0.0:5672 from 10.10.10.25:2582</div> <div>=INFO REPORT====
31-Mar-2008::03:30:53 ===<BR>closing TCP connection from 10.10.10.25:2582</div> <div>=INFO REPORT==== 31-Mar-2008::03:31:13 ===<BR>accepted TCP connection on 0.0.0.0:5672 from 10.10.10.25:2583</div> <div>=INFO REPORT==== 31-Mar-2008::03:31:14 ===<BR>Connection closed abruptly.</div> <div>=INFO REPORT==== 31-Mar-2008::03:31:14 ===<BR>closing TCP connection from 10.10.10.25:2583</div> <div>=INFO REPORT==== 31-Mar-2008::03:34:45 ===<BR>accepted TCP connection on 0.0.0.0:5672 from 10.10.10.25:2584</div> <div>=INFO REPORT==== 31-Mar-2008::03:34:46 ===<BR>Connection closed abruptly.</div> <div>=INFO REPORT==== 31-Mar-2008::03:34:46 ===<BR>closing TCP connection from 10.10.10.25:2584<BR></div> <div> </div> <div><BR><BR><B><I>Matthias Radestock <matthias@lshift.net></I></B> wrote:</div> <BLOCKQUOTE class=replbq style="PADDING-LEFT: 5px; MARGIN-LEFT: 5px; BORDER-LEFT: #1010ff 2px solid">Bill,,<BR><BR>BillC wrote:<BR>> Here is the log on RabbitMQ:<BR>>
<BR>> Thanks for your help. I just cleaned up the old log. Ran the publish <BR>> program twice to enque two messages. Then I ran the subscriber program <BR>> to deque twice.<BR>> <BR>> I see a lot of abrupt connection closures but no real explanations as to <BR>> the reason.<BR>> <BR>> <BR>> =INFO REPORT==== 30-Mar-2008::16:25:40 ===<BR>> disk_log: repairing "c:/Documents and <BR>> Settings/Development/rabbitmq/db/rabbit-mnesia/rabbit_persister.LOG" ...<BR>> <BR>> =INFO REPORT==== 30-Mar-2008::16:25:40 ===<BR>> Repaired persister log - 22 recovered, 0 bad<BR><BR>That is an odd error. Do you get it every time you start the broker? How <BR>are you stopping the broker?<BR><BR>That plus the tracer log you sent previously indicate that your test <BR>uses persistent messages. There is nothing wrong with that but it may <BR>explain why you are seeing errors when we don't. Try running your tests <BR>with transient messages, after clearing
out the previously persisted <BR>messages (stop the broker, remove the persister log file mentioned above <BR>and then restart the broker).<BR><BR><BR>Matthias.<BR></BLOCKQUOTE><BR>