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>