I still have an issue getting fanout to work.<br>
<br>

Take a look at the code from my clojure repl.<br>

<br>

com.parsimony-group.rabbitcj&gt; (def connection (let [params (doto (ConnectionParameters.)<br>

��������������������������������������� (.setVirtualHost &quot;/&quot;)<br>

��������������������������������������� (.setUsername &quot;guest&quot;)<br>

��������������������������������������� (.setPassword &quot;guest&quot;))<br>

������������������������������ factory (ConnectionFactory. params)]<br>

�������������������������� (.newConnection factory host))<br>

��� ��� ��� ��� �� )<br>

#&#39;com.parsimony-group.rabbitcj/connection<br>

com.parsimony-group.rabbitcj&gt; (def channel (.createChannel connection))<br>

#&#39;com.parsimony-group.rabbitcj/channel<br>

com.parsimony-group.rabbitcj&gt;� (.exchangeDeclare channel &quot;foo&quot; &quot;direct&quot; )<br>

#&lt;DeclareOk #method&lt;exchange.declare-ok&gt;()&gt;<br>

com.parsimony-group.rabbitcj&gt;� (.exchangeDeclare channel &quot;foo&quot; &quot;amq.fanout&quot; )<br>

; Evaluation aborted.<br>

<br>
<br>
...very simple, exchangeDeclare is fine for direct, but clows up for fanout case...I get the error message:<br>
<br>
<br>
No message.<br>
� [Thrown class com.rabbitmq.client.ShutdownSignalException]<br>
<br>
Restarts:<br>
�0: [ABORT] Return to SLIME&#39;s top level.<br>
<br>
Backtrace:<br>
� 0: com.rabbitmq.client.impl.AMQConnection.shutdown(AMQConnection.java:606)<br>
� 1: com.rabbitmq.client.impl.AMQConnection.handleConnectionClose(AMQConnection.java:561)<br>
� 2: com.rabbitmq.client.impl.AMQConnection.processControlCommand(AMQConnection.java:541)<br>
� 3: com.rabbitmq.client.impl.AMQConnection$1.processAsync(AMQConnection.java:84)<br>
� 4: com.rabbitmq.client.impl.AMQChannel.handleCompleteInboundCommand(AMQChannel.java:159)<br>
� 5: com.rabbitmq.client.impl.AMQChannel.handleFrame(AMQChannel.java:110)<br>
� 6: com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:446)<br>
<br>
<br>