Hi Bradford,<div><br></div><div>Is this the exact code from the REPL?</div><div><br></div><div>If so, you can't create a different exchange with an existing exchange name of different type. �stop_app, reset then start_app using rabbitmqctl, and try to create the fanout exchange first.</div>
<div><br></div><div>Aaron<br><br><div class="gmail_quote">On Mon, May 11, 2009 at 12:48 AM, bradford cross <span dir="ltr"><<a href="mailto:bradford.n.cross@gmail.com">bradford.n.cross@gmail.com</a>></span> wrote:<br>
<blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex;">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>
<br>_______________________________________________<br>
rabbitmq-discuss mailing list<br>
<a href="mailto:rabbitmq-discuss@lists.rabbitmq.com">rabbitmq-discuss@lists.rabbitmq.com</a><br>
<a href="http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss" target="_blank">http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss</a><br>
<br></blockquote></div><br></div>