[rabbitmq-discuss] creating fanout exchange gives ShutdownSignalException

Aaron Feng aaron.feng at gmail.com
Mon May 11 12:48:41 BST 2009


FYI reset will return to default mode. So don't reset if you care  
about what you added to the broker.

Aaron

On 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




More information about the rabbitmq-discuss mailing list