[rabbitmq-discuss] creating fanout exchange gives ShutdownSignalException

Mon May 11 12:35:46 BST 2009

Hi Bradford,
Is this the exact code from the REPL?

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.

Aaron

On Mon, May 11, 2009 at 12:48 AM, bradford cross <bradford.n.cross at gmail.com
> wrote:

> I still have an issue getting fanout to work.
>
> Take a look at the code from my clojure repl.
>
> com.parsimony-group.rabbitcj> (def connection (let [params (doto
> (ConnectionParameters.)
>                                         (.setVirtualHost "/")
>                                         (.setUsername "guest")
>                                         (.setPassword "guest"))
>                                factory (ConnectionFactory. params)]
>                            (.newConnection factory host))
>                    )
> #'com.parsimony-group.rabbitcj/connection
> com.parsimony-group.rabbitcj> (def channel (.createChannel connection))
> #'com.parsimony-group.rabbitcj/channel
> com.parsimony-group.rabbitcj>  (.exchangeDeclare channel "foo" "direct" )
> #<DeclareOk #method<exchange.declare-ok>()>
> com.parsimony-group.rabbitcj>  (.exchangeDeclare channel "foo" "amq.fanout"
> )
> ; Evaluation aborted.
>
>
> ...very simple, exchangeDeclare is fine for direct, but clows up for fanout
> case...I get the error message:
>
>
> No message.
>   [Thrown class com.rabbitmq.client.ShutdownSignalException]
>
> Restarts:
>  0: [ABORT] Return to SLIME's top level.
>
> Backtrace:
>   0:
> com.rabbitmq.client.impl.AMQConnection.shutdown(AMQConnection.java:606)
>   1:
> com.rabbitmq.client.impl.AMQConnection.handleConnectionClose(AMQConnection.java:561)
>   2:
> com.rabbitmq.client.impl.AMQConnection.processControlCommand(AMQConnection.java:541)
>   3:
> com.rabbitmq.client.impl.AMQConnection$1.processAsync(AMQConnection.java:84)
>   4:
> com.rabbitmq.client.impl.AMQChannel.handleCompleteInboundCommand(AMQChannel.java:159)
>   5: com.rabbitmq.client.impl.AMQChannel.handleFrame(AMQChannel.java:110)
>   6:
> com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:446)
>
>
>
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>
>
-------------- next part --------------
An HTML attachment was scrubbed...
URL: http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20090511/41eea400/attachment.htm 