<div><div><div>&#39;Tis with tongue in cheek that I send this along...as the last time I tried this, it was not supposed to work (always) on Windows.<div><br></div><div>I have installed 1.7.1 in a new directory, recompiled the Java client and tried this test again.<div>
<br></div><div>This is the contents of rabbitmq.config</div><div><div><font class="Apple-style-span" face="&#39;courier new&#39;, monospace">[</font></div><div><font class="Apple-style-span" face="&#39;courier new&#39;, monospace">  {rabbit, [{vm_memory_high_watermark, 3}]},</font></div>
<div><font class="Apple-style-span" face="&#39;courier new&#39;, monospace">  {rabbit, [{memory_alarms, true}]},</font></div><div><font class="Apple-style-span" face="&#39;courier new&#39;, monospace">  {mnesia, [{dump_log_write_threshold, 1000}]},</font></div>
<div><font class="Apple-style-span" face="&#39;courier new&#39;, monospace">  {rabbit, []}</font></div><div><font class="Apple-style-span" face="&#39;courier new&#39;, monospace">].</font></div><div>I have tried various options with the above vm_memory_high_watermark, e.g., .4, .6 and so forth, the 3 above being from the last try. Perhaps there more options that I missed? It would not surprise me.</div>
<div><br clear="all"><div><font face="&#39;courier new&#39;, monospace">Running the MulticastMain (Java) test against RabbitMQ with the parameters shown, leads to an Erlang crash after some time.</font></div><div><font face="&#39;courier new&#39;, monospace">The data below is from a Windows 7 X64 machine running JDK 6 X64.</font></div>
<div><font face="&#39;courier new&#39;, monospace"><br></font></div><div><font face="&#39;courier new&#39;, monospace">&quot;Cannot allocate 467078560 bytes&quot; is the error message.</font></div><div><font face="&#39;courier new&#39;, monospace"><br>
</font></div><div><font face="&#39;courier new&#39;, monospace">C:\AMQP\RabbitMQ\rabbitmq-java-client-1.7.1\test\src&gt;java -server ^</font></div><div><font face="&#39;courier new&#39;, monospace">com.rabbitmq.examples.MulticastMain ^</font></div>
<div><font face="&#39;courier new&#39;, monospace">-hlocalhost -p5672 -tdirect -eex1 -i10 -m1024 ^</font></div><div><font face="&#39;courier new&#39;, monospace">-n1024 -q20 -r1000 -s100 -x1 -y1</font></div><div><font face="&#39;courier new&#39;, monospace">starting consumer #0</font></div>
<div><font face="&#39;courier new&#39;, monospace">starting producer #0</font></div><div><font face="&#39;courier new&#39;, monospace">sending rate: 997 msg/s</font></div><div><font face="&#39;courier new&#39;, monospace">sending rate: 1000 msg/s</font></div>
<div><font face="&#39;courier new&#39;, monospace">sending rate: 1000 msg/s</font></div><div><font face="&#39;courier new&#39;, monospace">sending rate: 1000 msg/s</font></div><div><font face="&#39;courier new&#39;, monospace">...</font></div>
<div><font face="&#39;courier new&#39;, monospace">...</font></div><div><font face="&#39;courier new&#39;, monospace">...</font></div><div><div><font face="&#39;courier new&#39;, monospace">sending rate: 1000 msg/s</font></div>
<div><font face="&#39;courier new&#39;, monospace">Exception in thread &quot;Thread-1&quot; java.lang.RuntimeException: com.rabbitmq.client.ShutdownSignalException: connection error; reason: java.net.SocketException: Connection reset</font></div>
<div><font face="&#39;courier new&#39;, monospace">        at com.rabbitmq.examples.MulticastMain$Consumer.run(MulticastMain.java:385)</font></div><div><font face="&#39;courier new&#39;, monospace">        at java.lang.Thread.run(Unknown Source)</font></div>
<div><font face="&#39;courier new&#39;, monospace">Caused by: com.rabbitmq.client.ShutdownSignalException: connection error; reason</font></div><div><font face="&#39;courier new&#39;, monospace">: java.net.SocketException: Connection reset</font></div>
<div><font face="&#39;courier new&#39;, monospace">        at com.rabbitmq.client.impl.AMQConnection.shutdown(AMQConnection.java:588)</font></div><div><font face="&#39;courier new&#39;, monospace">        at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:454)</font></div>
<div><font face="&#39;courier new&#39;, monospace">Caused by: java.net.SocketException: Connection reset</font></div><div><font face="&#39;courier new&#39;, monospace">        at java.net.SocketInputStream.read(Unknown Source)</font></div>
<div><font face="&#39;courier new&#39;, monospace">        at java.io.BufferedInputStream.fill(Unknown Source)</font></div><div><font face="&#39;courier new&#39;, monospace">        at java.io.BufferedInputStream.read(Unknown Source)</font></div>
<div><font face="&#39;courier new&#39;, monospace">        at java.io.DataInputStream.readUnsignedByte(Unknown Source)</font></div><div><font face="&#39;courier new&#39;, monospace">        at com.rabbitmq.client.impl.Frame.readFrom(Frame.java:117)</font></div>
<div><font face="&#39;courier new&#39;, monospace">        at com.rabbitmq.client.impl.SocketFrameHandler.readFrame(SocketFrameHandler.java:151)</font></div><div><font face="&#39;courier new&#39;, monospace">        at com.rabbitmq.client.impl.AMQConnection.readFrame(AMQConnection.java:379)</font></div>
<div><font face="&#39;courier new&#39;, monospace">        at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:420)</font></div><div><font face="&#39;courier new&#39;, monospace">...</font></div><div>
<font face="&#39;courier new&#39;, monospace">...</font></div><div><div><font face="&#39;courier new&#39;, monospace">C:\AMQP\RabbitMQ\rabbitmq_server-1.7.1\sbin&gt;&quot;C:\erl5.7.4\bin\erl.exe&quot; -pa &quot;C:\AM</font></div>
<div><font face="&#39;courier new&#39;, monospace">QP\RabbitMQ\rabbitmq_server-1.7.1\sbin\..\ebin&quot; -enum_args -noinput -boot start_</font></div><div><font face="&#39;courier 
new&#39;, monospace">sasl &quot;&quot; -sname rabbit -s rabbit +W w +A30 -kernel inet_default_listen_options &quot;[</font></div><div><font face="&#39;courier new&#39;, monospace">{nodelay, true}, {sndbuf, 16384}, {recbuf, 4096}]&quot; -kernel inet_default_connect_</font></div>
<div><font face="&#39;courier new&#39;, monospace">options &quot;[{nodelay, true}]&quot; -rabbit tcp_listeners &quot;[{\&quot;0.0.0.0\&quot;, 5672}]&quot; -kerne</font></div><div><font face="&#39;courier new&#39;, monospace">l error_logger {file,\&quot;&quot;C:/AMQP/RabbitMQ/rabbitmq_server-1.7.1/log/rabbit.log&quot;\&quot;</font></div>
<div><font face="&#39;courier new&#39;, monospace">}  -sasl errlog_type error -sasl sasl_error_logger {file,\&quot;&quot;C:/AMQP/RabbitMQ/rab</font></div><div><font face="&#39;courier new&#39;, monospace">bitmq_server-1.7.1/log/rabbit-sasl.log&quot;\&quot;} -os_mon start_cpu_sup true -os_mon st</font></div>
<div><font face="&#39;courier new&#39;, monospace">art_disksup false -os_mon start_memsup false -os_mon start_os_sup false -os_mon</font></div><div><font face="&#39;courier new&#39;, monospace">memsup_system_only true -os_mon system_memory_high_watermark 0.95 -mnesia dir \&quot;</font></div>
<div><font face="&#39;courier new&#39;, monospace">&quot;C:/AMQP/RabbitMQ/rabbitmq_server-1.7.1/db/rabbit-mnesia&quot;\&quot;</font></div><div><font face="&#39;courier new&#39;, monospace"><br></font></div><div><font face="&#39;courier new&#39;, monospace"><br>
</font></div><div><font face="&#39;courier new&#39;, monospace">+---+   +---+</font></div><div><font face="&#39;courier new&#39;, monospace">|   |   |   |</font></div><div><font face="&#39;courier new&#39;, monospace">|   |   |   |</font></div>
<div><font face="&#39;courier new&#39;, monospace">|   |   |   |</font></div><div><font face="&#39;courier new&#39;, monospace">|   +---+   +-------+</font></div><div><font face="&#39;courier new&#39;, monospace">|                   |</font></div>
<div><font face="&#39;courier new&#39;, monospace">| RabbitMQ  +---+   |</font></div><div><font face="&#39;courier new&#39;, monospace">|           |   |   |</font></div><div><font face="&#39;courier new&#39;, monospace">|   v1.7.1  +---+   |</font></div>
<div><font face="&#39;courier new&#39;, monospace">|                   |</font></div><div><font face="&#39;courier new&#39;, monospace">+-------------------+</font></div><div><font face="&#39;courier new&#39;, monospace">AMQP 8-0</font></div>
<div><font face="&#39;courier new&#39;, monospace">Copyright (C) 2007-2009 LShift Ltd., Cohesive Financial Technologies LLC., and R</font></div><div><font face="&#39;courier new&#39;, monospace">abbit Technologies Ltd.</font></div>
<div><font face="&#39;courier new&#39;, monospace">Licensed under the MPL.  See <a href="http://www.rabbitmq.com/" target="_blank">http://www.rabbitmq.com/</a></font></div><div><font face="&#39;courier new&#39;, monospace"><br>
</font></div><div><font face="&#39;courier new&#39;, monospace">node          : rabbit@BIGPOOH</font></div><div><font face="&#39;courier new&#39;, monospace">app descriptor: c:/AMQP/RabbitMQ/rabbitmq_server-1.7.0/sbin/../ebin/rabbit.app</font></div>
<div><font face="&#39;courier new&#39;, monospace">home dir      : C:\Users\AppsJ</font></div><div><font face="&#39;courier new&#39;, monospace">cookie hash   : 1frVt/baXXdWZIsayTJJ8Q==</font></div><div><font face="&#39;courier new&#39;, monospace">log           : C:/AMQP/RabbitMQ/rabbitmq_server-1.7.0/log/rabbit.log</font></div>
<div><font face="&#39;courier new&#39;, monospace">sasl log      : C:/AMQP/RabbitMQ/rabbitmq_server-1.7.0/log/rabbit-sasl.log</font></div><div><font face="&#39;courier new&#39;, monospace">database dir  : c:/AMQP/RabbitMQ/rabbitmq_server-1.7.0/db/rabbit-mnesia</font></div>
<div><font face="&#39;courier new&#39;, monospace"><br></font></div><div><font face="&#39;courier new&#39;, monospace">starting database             ...done</font></div><div><font face="&#39;courier new&#39;,
 monospace">starting core processes       ...done</font></div><div><font face="&#39;courier new&#39;, monospace">starting recovery             ...done</font></div><div><font face="&#39;courier new&#39;, monospace">starting persister            ...done</font></div>
<div><font face="&#39;courier new&#39;, monospace">starting guid generator       ...done</font></div><div><font face="&#39;courier new&#39;, monospace">starting builtin applications ...done</font></div><div><font face="&#39;courier new&#39;, monospace">starting TCP listeners        ...done</font></div>
<div><font face="&#39;courier new&#39;, monospace">starting SSL listeners        ...done</font></div><div><font face="&#39;courier new&#39;, monospace"><br></font></div><div><font face="&#39;courier new&#39;, monospace">broker running</font></div>
<div><font face="&#39;courier new&#39;, monospace"><br></font></div><div><font face="&#39;courier new&#39;, monospace">Crash dump was written to: erl_crash.dump</font></div><div><font face="&#39;courier new&#39;, 
monospace">eheap_alloc: Cannot allocate 467078560 bytes of memory (of type &quot;heap&quot;).</font></div><div><font face="&#39;courier new&#39;, monospace"><br></font></div><div><font face="&#39;courier new&#39;, monospace">This application has requested the Runtime to terminate it in an unusual way.</font></div>
<div><font face="&#39;courier new&#39;, monospace">Please contact the application&#39;s support team for more information.</font></div><div><font face="&#39;courier new&#39;, monospace"><br></font></div></div></div><div><font face="&#39;courier new&#39;, monospace">The crash dump is rather large, so I shall not post it here...but will make it available if someone requires it.</font></div>
<div><font face="&#39;courier new&#39;, monospace">=erl_crash_dump:0.1</font></div><div><font face="&#39;courier new&#39;, monospace">Fri Jan 22 18:44:49 2010</font></div><div><font face="&#39;courier new&#39;, monospace">Slogan: eheap_alloc: Cannot allocate 467078560 bytes of memory (of type &quot;heap&quot;).</font></div>
<div><font face="&#39;courier new&#39;, monospace">System version: Erlang R13B03 (erts-5.7.4) [smp:2:2] [rq:2] [async-threads:30]</font></div><div><font face="&#39;courier new&#39;, monospace">Compiled: Tue Nov 24 11:12:28 2009</font></div>
-- <br>---<br>John Apps<br>(49) 171 869 1813</div></div></div>
</div></div></div>