<div><div><div>'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="'courier new', monospace">[</font></div><div><font class="Apple-style-span" face="'courier new', monospace"> {rabbit, [{vm_memory_high_watermark, 3}]},</font></div>
<div><font class="Apple-style-span" face="'courier new', monospace"> {rabbit, [{memory_alarms, true}]},</font></div><div><font class="Apple-style-span" face="'courier new', monospace"> {mnesia, [{dump_log_write_threshold, 1000}]},</font></div>
<div><font class="Apple-style-span" face="'courier new', monospace"> {rabbit, []}</font></div><div><font class="Apple-style-span" face="'courier new', 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="'courier new', 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="'courier new', monospace">The data below is from a Windows 7 X64 machine running JDK 6 X64.</font></div>
<div><font face="'courier new', monospace"><br></font></div><div><font face="'courier new', monospace">"Cannot allocate 467078560 bytes" is the error message.</font></div><div><font face="'courier new', monospace"><br>
</font></div><div><font face="'courier new', monospace">C:\AMQP\RabbitMQ\rabbitmq-java-client-1.7.1\test\src>java -server ^</font></div><div><font face="'courier new', monospace">com.rabbitmq.examples.MulticastMain ^</font></div>
<div><font face="'courier new', monospace">-hlocalhost -p5672 -tdirect -eex1 -i10 -m1024 ^</font></div><div><font face="'courier new', monospace">-n1024 -q20 -r1000 -s100 -x1 -y1</font></div><div><font face="'courier new', monospace">starting consumer #0</font></div>
<div><font face="'courier new', monospace">starting producer #0</font></div><div><font face="'courier new', monospace">sending rate: 997 msg/s</font></div><div><font face="'courier new', monospace">sending rate: 1000 msg/s</font></div>
<div><font face="'courier new', monospace">sending rate: 1000 msg/s</font></div><div><font face="'courier new', monospace">sending rate: 1000 msg/s</font></div><div><font face="'courier new', monospace">...</font></div>
<div><font face="'courier new', monospace">...</font></div><div><font face="'courier new', monospace">...</font></div><div><div><font face="'courier new', monospace">sending rate: 1000 msg/s</font></div>
<div><font face="'courier new', monospace">Exception in thread "Thread-1" java.lang.RuntimeException: com.rabbitmq.client.ShutdownSignalException: connection error; reason: java.net.SocketException: Connection reset</font></div>
<div><font face="'courier new', monospace"> at com.rabbitmq.examples.MulticastMain$Consumer.run(MulticastMain.java:385)</font></div><div><font face="'courier new', monospace"> at java.lang.Thread.run(Unknown Source)</font></div>
<div><font face="'courier new', monospace">Caused by: com.rabbitmq.client.ShutdownSignalException: connection error; reason</font></div><div><font face="'courier new', monospace">: java.net.SocketException: Connection reset</font></div>
<div><font face="'courier new', monospace"> at com.rabbitmq.client.impl.AMQConnection.shutdown(AMQConnection.java:588)</font></div><div><font face="'courier new', monospace"> at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:454)</font></div>
<div><font face="'courier new', monospace">Caused by: java.net.SocketException: Connection reset</font></div><div><font face="'courier new', monospace"> at java.net.SocketInputStream.read(Unknown Source)</font></div>
<div><font face="'courier new', monospace"> at java.io.BufferedInputStream.fill(Unknown Source)</font></div><div><font face="'courier new', monospace"> at java.io.BufferedInputStream.read(Unknown Source)</font></div>
<div><font face="'courier new', monospace"> at java.io.DataInputStream.readUnsignedByte(Unknown Source)</font></div><div><font face="'courier new', monospace"> at com.rabbitmq.client.impl.Frame.readFrom(Frame.java:117)</font></div>
<div><font face="'courier new', monospace"> at com.rabbitmq.client.impl.SocketFrameHandler.readFrame(SocketFrameHandler.java:151)</font></div><div><font face="'courier new', monospace"> at com.rabbitmq.client.impl.AMQConnection.readFrame(AMQConnection.java:379)</font></div>
<div><font face="'courier new', monospace"> at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:420)</font></div><div><font face="'courier new', monospace">...</font></div><div>
<font face="'courier new', monospace">...</font></div><div><div><font face="'courier new', monospace">C:\AMQP\RabbitMQ\rabbitmq_server-1.7.1\sbin>"C:\erl5.7.4\bin\erl.exe" -pa "C:\AM</font></div>
<div><font face="'courier new', monospace">QP\RabbitMQ\rabbitmq_server-1.7.1\sbin\..\ebin" -enum_args -noinput -boot start_</font></div><div><font face="'courier
new', monospace">sasl "" -sname rabbit -s rabbit +W w +A30 -kernel inet_default_listen_options "[</font></div><div><font face="'courier new', monospace">{nodelay, true}, {sndbuf, 16384}, {recbuf, 4096}]" -kernel inet_default_connect_</font></div>
<div><font face="'courier new', monospace">options "[{nodelay, true}]" -rabbit tcp_listeners "[{\"0.0.0.0\", 5672}]" -kerne</font></div><div><font face="'courier new', monospace">l error_logger {file,\""C:/AMQP/RabbitMQ/rabbitmq_server-1.7.1/log/rabbit.log"\"</font></div>
<div><font face="'courier new', monospace">} -sasl errlog_type error -sasl sasl_error_logger {file,\""C:/AMQP/RabbitMQ/rab</font></div><div><font face="'courier new', monospace">bitmq_server-1.7.1/log/rabbit-sasl.log"\"} -os_mon start_cpu_sup true -os_mon st</font></div>
<div><font face="'courier new', monospace">art_disksup false -os_mon start_memsup false -os_mon start_os_sup false -os_mon</font></div><div><font face="'courier new', monospace">memsup_system_only true -os_mon system_memory_high_watermark 0.95 -mnesia dir \"</font></div>
<div><font face="'courier new', monospace">"C:/AMQP/RabbitMQ/rabbitmq_server-1.7.1/db/rabbit-mnesia"\"</font></div><div><font face="'courier new', monospace"><br></font></div><div><font face="'courier new', monospace"><br>
</font></div><div><font face="'courier new', monospace">+---+ +---+</font></div><div><font face="'courier new', monospace">| | | |</font></div><div><font face="'courier new', monospace">| | | |</font></div>
<div><font face="'courier new', monospace">| | | |</font></div><div><font face="'courier new', monospace">| +---+ +-------+</font></div><div><font face="'courier new', monospace">| |</font></div>
<div><font face="'courier new', monospace">| RabbitMQ +---+ |</font></div><div><font face="'courier new', monospace">| | | |</font></div><div><font face="'courier new', monospace">| v1.7.1 +---+ |</font></div>
<div><font face="'courier new', monospace">| |</font></div><div><font face="'courier new', monospace">+-------------------+</font></div><div><font face="'courier new', monospace">AMQP 8-0</font></div>
<div><font face="'courier new', monospace">Copyright (C) 2007-2009 LShift Ltd., Cohesive Financial Technologies LLC., and R</font></div><div><font face="'courier new', monospace">abbit Technologies Ltd.</font></div>
<div><font face="'courier new', monospace">Licensed under the MPL. See <a href="http://www.rabbitmq.com/" target="_blank">http://www.rabbitmq.com/</a></font></div><div><font face="'courier new', monospace"><br>
</font></div><div><font face="'courier new', monospace">node : rabbit@BIGPOOH</font></div><div><font face="'courier new', monospace">app descriptor: c:/AMQP/RabbitMQ/rabbitmq_server-1.7.0/sbin/../ebin/rabbit.app</font></div>
<div><font face="'courier new', monospace">home dir : C:\Users\AppsJ</font></div><div><font face="'courier new', monospace">cookie hash : 1frVt/baXXdWZIsayTJJ8Q==</font></div><div><font face="'courier new', monospace">log : C:/AMQP/RabbitMQ/rabbitmq_server-1.7.0/log/rabbit.log</font></div>
<div><font face="'courier new', monospace">sasl log : C:/AMQP/RabbitMQ/rabbitmq_server-1.7.0/log/rabbit-sasl.log</font></div><div><font face="'courier new', monospace">database dir : c:/AMQP/RabbitMQ/rabbitmq_server-1.7.0/db/rabbit-mnesia</font></div>
<div><font face="'courier new', monospace"><br></font></div><div><font face="'courier new', monospace">starting database ...done</font></div><div><font face="'courier new',
monospace">starting core processes ...done</font></div><div><font face="'courier new', monospace">starting recovery ...done</font></div><div><font face="'courier new', monospace">starting persister ...done</font></div>
<div><font face="'courier new', monospace">starting guid generator ...done</font></div><div><font face="'courier new', monospace">starting builtin applications ...done</font></div><div><font face="'courier new', monospace">starting TCP listeners ...done</font></div>
<div><font face="'courier new', monospace">starting SSL listeners ...done</font></div><div><font face="'courier new', monospace"><br></font></div><div><font face="'courier new', monospace">broker running</font></div>
<div><font face="'courier new', monospace"><br></font></div><div><font face="'courier new', monospace">Crash dump was written to: erl_crash.dump</font></div><div><font face="'courier new',
monospace">eheap_alloc: Cannot allocate 467078560 bytes of memory (of type "heap").</font></div><div><font face="'courier new', monospace"><br></font></div><div><font face="'courier new', monospace">This application has requested the Runtime to terminate it in an unusual way.</font></div>
<div><font face="'courier new', monospace">Please contact the application's support team for more information.</font></div><div><font face="'courier new', monospace"><br></font></div></div></div><div><font face="'courier new', 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="'courier new', monospace">=erl_crash_dump:0.1</font></div><div><font face="'courier new', monospace">Fri Jan 22 18:44:49 2010</font></div><div><font face="'courier new', monospace">Slogan: eheap_alloc: Cannot allocate 467078560 bytes of memory (of type "heap").</font></div>
<div><font face="'courier new', monospace">System version: Erlang R13B03 (erts-5.7.4) [smp:2:2] [rq:2] [async-threads:30]</font></div><div><font face="'courier new', 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>