[rabbitmq-discuss] creating fanout exchange gives ShutdownSignalException
bradford cross
bradford.n.cross at gmail.com
Mon May 11 05:48:56 BST 2009
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)
-------------- next part --------------
An HTML attachment was scrubbed...
URL: http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20090510/754b5ead/attachment.htm
More information about the rabbitmq-discuss
mailing list