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> (def connection (let [params (doto (ConnectionParameters.)<br>
��������������������������������������� (.setVirtualHost "/")<br>
��������������������������������������� (.setUsername "guest")<br>
��������������������������������������� (.setPassword "guest"))<br>
������������������������������ factory (ConnectionFactory. params)]<br>
�������������������������� (.newConnection factory host))<br>
��� ��� ��� ��� �� )<br>
#'com.parsimony-group.rabbitcj/connection<br>
com.parsimony-group.rabbitcj> (def channel (.createChannel connection))<br>
#'com.parsimony-group.rabbitcj/channel<br>
com.parsimony-group.rabbitcj>� (.exchangeDeclare channel "foo" "direct" )<br>
#<DeclareOk #method<exchange.declare-ok>()><br>
com.parsimony-group.rabbitcj>� (.exchangeDeclare channel "foo" "amq.fanout" )<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'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>