[rabbitmq-discuss] creating fanout exchange gives ShutdownSignalException
Aaron Feng
aaron.feng at gmail.com
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
More information about the rabbitmq-discuss
mailing list