Glad to hear you got it working. If defining the queue in the configuration file fixed your issue, then I guess that one of your clients was creating it itself previously and in doing so / using it differently than to if it already existed.
(aside: queues [and subscriptions] aren't exclusive by default so that bit of the config shouldnt really be achieving anything). Robbie On 27 July 2012 19:22, Christopher Wood <[email protected]> wrote: > On Fri, Jul 27, 2012 at 02:36:05PM +0100, Robbie Gemmell wrote: > > It could be a little more complicated than just whether the queue itself > is > > exclusive since AMQP 0-10 also has the additional concept of exclusive > > subscriptions (consumers) on a queue, which is what your logs actually > > appear to be complaining about. > > Thank you, this was exactly it. When I added my queue config to > virtualhosts.xml in my Qpid broker and then started ActiveMQ (having the > queue available for Camel before any other subscribers), the Camel > component could log in and read from the target queue. I suspect I wasn't > setting a non-exclusive subscription when I added the queue, or not > unsubscribing/disconnecting properly, or something. I will figure that part > out. > > > It would help if you could tell us more about what you are actually doing > > with the clients/camel, what your destination strings are, etc etc. A set > > of the broker logs with the full client interaction would be useful > > (possibly after deleting the queue and starting fresh, although in saying > > that I now notice your queue is actually marked auto-delete according to > > the protocol logging you pasted.). > > I will paste in some pointers for other newbies, since my own roadblock is > cleared. (My examples in the OP were taken after nuking all daemons and log > files.) Keep in mind that I'm new, so it's quite likely that these are not > optimal or even completely sensical. > > > > Anybody not willing to make corrections can stop reading now. ;) > > > > A new system (aka XN) will have components talking among themselves in > AMQP. > > First, I add some Camel and Qpid components to ActiveMQ 5.5.1 in order to > let it understand AMQP: > > a) from Qpid > > qpid-common-0.16.jar > qpid-client-0.16.jar > > b) from Camel > > camel-amqp-2.10.0.jar > camel-core-2.10.0.jar ** > camel-jetty-2.10.0.jar ** > camel-jms-2.10.0.jar ** > camel-spring-2.10.0.jar ** > > ** Means that I had to replace the components shipped with ActiveMQ, or > ActiveMQ would fail to deliver to the JMS queue with a null pointer > exception. > > This is my camel.xml for use with ActiveMQ, cribbed from internet sources. > From my non-Java perspective it looks like I can configure the beans with > the correct information, and then route any way I please using the > camelContext. NB: This is message routing inside the ActiveMQ daemon using > the Camel component, not network routing. > > <beans > xmlns="http://www.springframework.org/schema/beans"; > xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; > xsi:schemaLocation="http://camel.apache.org/schema/spring > http://camel.apache.org/schema/spring/camel-spring.xsd > http://www.springframework.org/schema/beans > http://www.springframework.org/schema/beans/spring-beans.xsd";> > > <camelContext id="camel" xmlns="http://camel.apache.org/schema/spring";> > <route> > <description>AMQP to JMS Routing</description> > <from uri="amqp:queue:amq.cw2"/> > <to uri="activemq:queue:cw.1"/> > </route> > </camelContext> > > <!-- note the & which is the & but encoded --> > > <bean id="amqp" class="org.apache.camel.component.amqp.AMQPComponent" > > <property name="connectionFactory"> > <bean class="org.apache.qpid.client.AMQConnectionFactory"> > <constructor-arg index="0" type="java.lang.String"> > <value>amqp://cwood:cwood@ > /sp?brokerlist='tcp://hostname:5672?retries='1000'&connectdelay='5000';'</value> > </constructor-arg> > </bean> > </property> > </bean> > > <bean id="activemq" > class="org.apache.activemq.camel.component.ActiveMQComponent" > > <property name="connectionFactory"> > <bean class="org.apache.activemq.ActiveMQConnectionFactory"> > <property name="brokerURL" > value="vm://hostname?create=false&waitForStart=10000" /> > <property name="userName" value="cwood"/> > <property name="password" value="cwood"/> > </bean> > </property> > </bean> > </beans> > > If you have already figured out how to non-exclusively subscribe to a Qpid > queue you're better off than me, but in case not here is my Qpid virtual > host configuration: > > <?xml version="1.0" encoding="ISO-8859-1"?> > <virtualhosts> > <default>sp</default> > <virtualhost> > <name>sp</name> > <sp> > <store> > > <class>org.apache.qpid.server.store.MemoryMessageStore</class> > </store> > <queues> > <queue> > <name>amq.cw2</name> > <exclusive>false</exclusive> > </queue> > </queues> > </sp> > </virtualhost> > </virtualhosts> > > Then I start things up in this order: > > Qpid (via init script) > ActiveMQ (/opt/activemq/bin/activemq console for debugging messages) > > Once those are running I use this script (cribbed from the amqp ruby gem > docs, but the messiness is all mine) to submit a message to AMQP: > > #!/usr/bin/ruby > # encoding: utf-8 > > require "rubygems" > # gem install amqp --user-install > require 'amqp' > > tcphandler = Proc.new { |settings| puts "Failed to connect. > #{settings.inspect}"; EventMachine.stop } > authhandler = Proc.new { |settings| puts "Failed to authenticate. > #{settings.inspect}"; EventMachine.stop } > > csettings = { > :host => 'hostname', > :user => 'pub', > :pass => 'pub', > :vhost => 'sp', > :on_tcp_connection_failure => tcphandler, > :on_possible_authentication_failure => authhandler, > } > > EventMachine.run do > AMQP.connect(csettings) do |client, open_ok| > > channel = AMQP::Channel.new(client) > > exchange = AMQP::Exchange.new(channel, :direct, "cw1") > > queue = channel.queue("amq.cw2") > queue.bind(exchange, :routing_key => 'cw3') do > puts "Bound #{exchange.name} => #{queue.name}" > end > > channel.on_error do |ch, channel_close| > puts channel_close.reply_text > connection.close { EventMachine.stop } > end > > now = Time.new > > exchange.publish "cw test at #{now}", :routing_key => 'cw3' > > end > end > > > > Links that helped me: > > http://rubyamqp.info/ > > http://camel.465427.n5.nabble.com/URI-format-for-AMQP-topic-help-required-td471356.html > http://activemq.apache.org/sample-camel-routes.html > http://www.amqp.org/resources/download > > > > > As an aside, I take it you are doing this due to a need to integrate some > > existing systems using ActiveMQ JMS clients with others using Qpid/AMQP > > clients / broker? > > Without giving away secrets, the new system uses AMQP and our current > ActiveMQ/JMS broker needs to be copied on some messages, so that we can use > pre-existing STOMP/JMS clients to react to certain communications inside > the new system. > > > Robbie > > > > On 27 July 2012 12:31, Christopher Wood <[email protected]> > wrote: > > > > > On Fri, Jul 27, 2012 at 03:53:13AM +0100, Oleksandr Rudyy wrote: > > > > Hi Christopher, > > > > > > > > What is the version of your broker? > > > > > > > > In case if broker version >= 0.16, I found so far 2 scenarios > leading > > > > to these issue: > > > > 1) queue was created as exclusive, consumer subscribed, and > > > > exclusivity flag was reset through JMX while consumer was still > > > > present > > > > > > In the ruby client I set :exclusive => false. Come to think of it, I'm > not > > > sure how to check from the amqp gem whether a queue is exclusive. I'll > look > > > into that. > > > > > > > 2) queue was created as normal, exclusivity flag was set through > JMX, > > > > consumer subscribed, and exclusivity flag was reset through JMX while > > > > consumer was still present > > > > > > I was seeing this even without using the JMX admin interface, oddly > > > enough. Though I did see the same behaviour after using JMX to change > the > > > queue to exclusive and then non-exclusive. I wonder if I wasn't seeing > the > > > right setting (but right now I don't have enough knowledge to say for > sure). > > > > > > > It seems on resetting of exclusivity flag through JMX, broker does > not > > > > clean owningSession and authorizationHolder. > > > > > > > > Could you please clarify whether by any chance you have run into any > > > > of these 2 scenarios? > > > > > > > > Kind Regards, > > > > Alex > > > > > > > > > > > > On 26 July 2012 21:56, Christopher Wood <[email protected]> > > > wrote: > > > > > Good morning. So far my qpid experience has been quite smooth, and > > > using it has been comparatively relaxing. Of course my hitch would come > > > when I try to mash up qpid, activemq, and camel. I'm asking my question > > > here since I'm having a problem with the mix, and the only > inconsistency I > > > can find so far is in qpid components. If you'd like to punt me off to > some > > > other list, I'm all ears. ;) > > > > > > > > > > The questions: > > > > > > > > > > Why do my qpid logs say that the queue is exclusive when my Qpid > JMX > > > Management Console says that it isn't? > > > > > How do I ensure that my queues are non-exclusive? > > > > > If the queue has to be exclusive, what is keeping the queue > exclusive > > > and how do I get it to stop? > > > > > > > > > > > > > > > > > > > > Short details: > > > > > > > > > > I have a qpid broker, with ActiveMQ/Camel connecting to slurp in > > > messages from a qpid queue and then translate them to an activemq > queue for > > > JMS access. The ActiveMQ/Camel instance fails to do... some specific > task > > > I'm not quite clear on, but fails because the queue is exclusive. I > didn't > > > set the queue to be exclusive. > > > > > > > > > > Platform: > > > > > > > > > > Debian 6 x86_64 > > > > > AMQP Client to send the initial message is ruby 1.8.7 with the amqp > > > gem. > > > > > Oracle (Sun) java 1.6.0_31 > > > > > Qpid 0.16 (running as a daemon) > > > > > ActiveMQ 5.5.1 with camel-amqp-2.10.0.jar, qpid-common-0.16.jar, > > > qpid-client-0.16.jar (running as a daemon) > > > > > > > > > > The log says: > > > > > > > > > > 2012-07-26 16:27:04,584 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - SEND: [conn:6b6c14c0] ch=0 id=2 > > > ExecutionException(errorCode=RESOURCE_LOCKED, commandId=3, > > > description=Exclusive Queue: amq.cw2 owned exclusively by another > session) > > > > > > > > > > My console says that amq.cw2 is exclusive:false, see the attached > > > screenshot. > > > > > > > > > > > > > > > > > > > > Longer details: > > > > > > > > > > Here is one connection from ActiveMQ, as seen in the qpid logs: > > > > > > > > > > 2012-07-26 16:27:04,527 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - RECV: [conn:6b6c14c0] AMQP.1 0-10 > > > > > 2012-07-26 16:27:04,528 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - SEND: [conn:6b6c14c0] AMQP.1 0-10 > > > > > 2012-07-26 16:27:04,529 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - SEND: [conn:6b6c14c0] ch=0 > > > > ConnectionStart(serverProperties={qpid.federation_tag=58d89af6-e6d1-4705-8bd6-eec225e77fa3, > > > qpid.features=[qpid.jms-selector]}, mechanisms=[AMQPLAIN, PLAIN, > CRAM-MD5], > > > locales=[en_US]) > > > > > 2012-07-26 16:27:04,529 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - FLUSH: [conn:6b6c14c0] > > > > > 2012-07-26 16:27:04,532 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - RECV: [conn:6b6c14c0] ch=0 > > > ConnectionStartOk(clientProperties={product=qpid, > qpid.client_version=0.16, > > > platform=Java(TM) SE Runtime Environment, 1.6.0_31-b04, Sun > Microsystems > > > Inc., amd64, Linux, 2.6.32-5-amd64, unknown, qpid.session_flow=1, > > > clientName=cwlab-011343334394271, qpid.client_pid=28586, > > > qpid.client_process=Qpid Java Client}, mechanism=CRAM-MD5) > > > > > 2012-07-26 16:27:04,532 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - SEND: [conn:6b6c14c0] ch=0 > > > ConnectionSecure(challenge=[B@4c68059) > > > > > 2012-07-26 16:27:04,533 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - FLUSH: [conn:6b6c14c0] > > > > > 2012-07-26 16:27:04,534 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - RECV: [conn:6b6c14c0] ch=0 > > > ConnectionSecureOk(response=[B@4145582) > > > > > 2012-07-26 16:27:04,535 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - SEND: [conn:6b6c14c0] ch=0 > > > ConnectionTune(channelMax=256, maxFrameSize=65535, heartbeatMin=0, > > > heartbeatMax=0) > > > > > 2012-07-26 16:27:04,535 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - FLUSH: [conn:6b6c14c0] > > > > > 2012-07-26 16:27:04,536 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - RECV: [conn:6b6c14c0] ch=0 > > > ConnectionTuneOk(channelMax=256, maxFrameSize=65535, heartbeat=0) > > > > > 2012-07-26 16:27:04,537 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - RECV: [conn:6b6c14c0] ch=0 > > > ConnectionOpen(virtualHost=sp, insist=true) > > > > > 2012-07-26 16:27:04,544 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - SEND: [conn:6b6c14c0] ch=0 > > > ConnectionOpenOk(knownHosts=[]) > > > > > 2012-07-26 16:27:04,544 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - FLUSH: [conn:6b6c14c0] > > > > > 2012-07-26 16:27:04,547 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - RECV: [conn:6b6c14c0] ch=0 > > > SessionAttach(name=[B@448be1c9) > > > > > 2012-07-26 16:27:04,547 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - SEND: [conn:6b6c14c0] ch=0 > > > SessionAttached(name=[B@448be1c9) > > > > > 2012-07-26 16:27:04,548 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - FLUSH: [conn:6b6c14c0] > > > > > 2012-07-26 16:27:04,550 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - RECV: [conn:6b6c14c0] ch=0 > > > SessionRequestTimeout(timeout=0) > > > > > 2012-07-26 16:27:04,550 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - SEND: [conn:6b6c14c0] ch=0 > > > SessionTimeout(timeout=0) > > > > > 2012-07-26 16:27:04,550 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - FLUSH: [conn:6b6c14c0] > > > > > 2012-07-26 16:27:04,551 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - RECV: [conn:6b6c14c0] ch=0 > > > SessionCommandPoint(commandId=0, commandOffset=0) > > > > > 2012-07-26 16:27:04,552 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - RECV: [conn:6b6c14c0] ch=0 > > > ExchangeBound(exchange=amq.cw2, queue=amq.cw2) > > > > > 2012-07-26 16:27:04,553 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - SEND: [conn:6b6c14c0] ch=0 > > > SessionCommandPoint(commandId=0, commandOffset=0) > > > > > 2012-07-26 16:27:04,553 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - FLUSH: [conn:6b6c14c0] > > > > > 2012-07-26 16:27:04,554 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - SEND: [conn:6b6c14c0] ch=0 id=0 > > > ExecutionResult(commandId=0, > > > value=ExchangeBoundResult(exchangeNotFound=true)) > > > > > 2012-07-26 16:27:04,554 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - FLUSH: [conn:6b6c14c0] > > > > > 2012-07-26 16:27:04,562 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - SEND: [conn:6b6c14c0] ch=0 > > > SessionFlush(completed=true) > > > > > 2012-07-26 16:27:04,563 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - FLUSH: [conn:6b6c14c0] > > > > > 2012-07-26 16:27:04,564 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - RECV: [conn:6b6c14c0] ch=0 > > > SessionFlush(completed=true) > > > > > 2012-07-26 16:27:04,565 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - SEND: [conn:6b6c14c0] ch=0 > > > SessionCompleted(commands={[0, 0]}) > > > > > 2012-07-26 16:27:04,565 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - FLUSH: [conn:6b6c14c0] > > > > > 2012-07-26 16:27:04,566 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - RECV: [conn:6b6c14c0] ch=0 > > > QueueQuery(queue=amq.cw2) > > > > > 2012-07-26 16:27:04,567 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - SEND: [conn:6b6c14c0] ch=0 id=1 > > > ExecutionResult(commandId=1, value=QueueQueryResult(queue=amq.cw2, > > > autoDelete=true, arguments={}, messageCount=1, subscriberCount=0)) > > > > > 2012-07-26 16:27:04,567 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - FLUSH: [conn:6b6c14c0] > > > > > 2012-07-26 16:27:04,572 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - RECV: [conn:6b6c14c0] ch=0 > > > SessionCompleted(commands=[0, 0]) > > > > > 2012-07-26 16:27:04,574 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - RECV: [conn:6b6c14c0] ch=0 [S] > > > ExecutionSync() > > > > > 2012-07-26 16:27:04,578 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - SEND: [conn:6b6c14c0] ch=0 > > > SessionCompleted(commands={[0, 2]}) > > > > > 2012-07-26 16:27:04,579 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - FLUSH: [conn:6b6c14c0] > > > > > 2012-07-26 16:27:04,581 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - SEND: [conn:6b6c14c0] ch=0 > > > SessionCompleted(commands={[0, 2]}) > > > > > 2012-07-26 16:27:04,581 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - FLUSH: [conn:6b6c14c0] > > > > > 2012-07-26 16:27:04,583 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - RECV: [conn:6b6c14c0] ch=0 > > > MessageSubscribe(queue=amq.cw2, destination=1, acceptMode=EXPLICIT, > > > acquireMode=PRE_ACQUIRED, resumeTtl=0, > arguments={x-filter-jms-selector=}) > > > > > 2012-07-26 16:27:04,584 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - SEND: [conn:6b6c14c0] ch=0 id=2 > > > ExecutionException(errorCode=RESOURCE_LOCKED, commandId=3, > > > description=Exclusive Queue: amq.cw2 owned exclusively by another > session) > > > > > 2012-07-26 16:27:04,585 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - FLUSH: [conn:6b6c14c0] > > > > > 2012-07-26 16:27:04,595 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - SEND: [conn:6b6c14c0] ch=0 > > > SessionRequestTimeout(timeout=0) > > > > > 2012-07-26 16:27:04,598 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - FLUSH: [conn:6b6c14c0] > > > > > 2012-07-26 16:27:04,599 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - SEND: [conn:6b6c14c0] ch=0 > > > SessionDetach(name=[B@fe14de0) > > > > > 2012-07-26 16:27:04,600 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - FLUSH: [conn:6b6c14c0] > > > > > 2012-07-26 16:27:04,602 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - RECV: [conn:6b6c14c0] ch=0 > > > MessageSetFlowMode(destination=1, flowMode=WINDOW) > > > > > 2012-07-26 16:27:04,603 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - RECV: [conn:6b6c14c0] ch=0 > > > MessageFlow(destination=1, unit=BYTE, value=4294967295) > > > > > 2012-07-26 16:27:04,604 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - RECV: [conn:6b6c14c0] ch=0 [S] > > > ExecutionSync() > > > > > 2012-07-26 16:27:04,606 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - RECV: [conn:6b6c14c0] ch=0 > > > SessionTimeout(timeout=0) > > > > > 2012-07-26 16:27:04,607 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - RECV: [conn:6b6c14c0] ch=0 > > > SessionDetached(name=[B@10bfb545, code=NORMAL) > > > > > 2012-07-26 16:27:07,801 DEBUG [IoReceiver - /10.201.140.228:60713] > > > util.Logger (Logger.java:54) - connection closed: conn:6b6c14c0 > > > > > > > > > > Here is the error from ActiveMQ: > > > > > > > > > > INFO | > > > > Connection:amqp://cwood:********@cwlab-011343334394271/sp?brokerlist='tcp://cwlab-01.secret:5672?connectdelay='5000'&retries='1000'' > > > > > INFO | Using ProtocolVersion for Session:0-10 > > > > > INFO | New Method Dispatcher:AMQProtocolSession[null] > > > > > INFO | Connecting with ProtocolHandler Version:0-10 > > > > > INFO | The broker does not support the configured connection idle > > > timeout of 120 sec, using the brokers max supported value of 0 sec > instead. > > > > > INFO | Connected with ProtocolHandler Version:0-10 > > > > > INFO | Successfully refreshed JMS Connection > > > > > INFO | Created > session:org.apache.qpid.client.AMQSession_0_10@46fb3d6 > > > > > INFO | Prefetching delayed existing messages will not flow until > > > requested via receive*() or setML(). > > > > > INFO | Closing AMQConnection due to :org.apache.qpid.AMQException: > > > ch=0 id=2 ExecutionException(errorCode=RESOURCE_LOCKED, commandId=3, > > > description=Exclusive Queue: amq.cw2 owned exclusively by another > session) > > > [error code 405: Already exists] > > > > > ERROR | Throwable Received but no listener set: > > > org.apache.qpid.AMQException: ch=0 id=2 > > > ExecutionException(errorCode=RESOURCE_LOCKED, commandId=3, > > > description=Exclusive Queue: amq.cw2 owned exclusively by another > session) > > > [error code 405: Already exists] > > > > > INFO | Closing AMQConnection due to :org.apache.qpid.AMQException: > > > ch=0 id=2 ExecutionException(errorCode=RESOURCE_LOCKED, commandId=3, > > > description=Exclusive Queue: amq.cw2 owned exclusively by another > session) > > > [error code 405: Already exists] > > > > > ERROR | Throwable Received but no listener set: > > > org.apache.qpid.AMQException: ch=0 id=2 > > > ExecutionException(errorCode=RESOURCE_LOCKED, commandId=3, > > > description=Exclusive Queue: amq.cw2 owned exclusively by another > session) > > > [error code 405: Already exists] > > > > > INFO | Closing session: > org.apache.qpid.client.AMQSession_0_10@46fb3d6 > > > > > WARN | Setup of JMS message listener invoker failed for > destination > > > 'amq.cw2' - trying to recover. Cause: Error registering consumer: > > > org.apache.qpid.AMQException: ch=0 id=2 > > > ExecutionException(errorCode=RESOURCE_LOCKED, commandId=3, > > > description=Exclusive Queue: amq.cw2 owned exclusively by another > session) > > > [error code 405: Already exists] > > > > > javax.jms.JMSException: Error registering consumer: > > > org.apache.qpid.AMQException: ch=0 id=2 > > > ExecutionException(errorCode=RESOURCE_LOCKED, commandId=3, > > > description=Exclusive Queue: amq.cw2 owned exclusively by another > session) > > > [error code 405: Already exists] > > > > > at > > > org.apache.qpid.client.AMQSession$4.execute(AMQSession.java:2048) > > > > > at > > > org.apache.qpid.client.AMQSession$4.execute(AMQSession.java:2000) > > > > > at > > > > org.apache.qpid.client.AMQConnectionDelegate_0_10.executeRetrySupport(AMQConnectionDelegate_0_10.java:366) > > > > > at > > > > org.apache.qpid.client.AMQConnection.executeRetrySupport(AMQConnection.java:577) > > > > > at > > > > org.apache.qpid.client.failover.FailoverRetrySupport.execute(FailoverRetrySupport.java:102) > > > > > at > > > > org.apache.qpid.client.AMQSession.createConsumerImpl(AMQSession.java:1998) > > > > > at > > > org.apache.qpid.client.AMQSession.createConsumer(AMQSession.java:980) > > > > > at > > > > org.springframework.jms.listener.AbstractPollingMessageListenerContainer.createConsumer(AbstractPollingMessageListenerContainer.java:477) > > > > > at > > > > org.springframework.jms.listener.AbstractPollingMessageListenerContainer.createListenerConsumer(AbstractPollingMessageListenerContainer.java:221) > > > > > at > > > > org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.initResourcesIfNecessary(DefaultMessageListenerContainer.java:1079) > > > > > at > > > > org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1055) > > > > > at > > > > org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1048) > > > > > at > > > > org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:947) > > > > > at > > > java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown Source) > > > > > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown > > > Source) > > > > > at java.lang.Thread.run(Unknown Source) > > > > > Caused by: org.apache.qpid.AMQException: ch=0 id=2 > > > ExecutionException(errorCode=RESOURCE_LOCKED, commandId=3, > > > description=Exclusive Queue: amq.cw2 owned exclusively by another > session) > > > [error code 405: Already exists] > > > > > at > > > > org.apache.qpid.client.AMQSession_0_10.setCurrentException(AMQSession_0_10.java:1054) > > > > > at > > > org.apache.qpid.client.AMQSession_0_10.sync(AMQSession_0_10.java:1034) > > > > > at > > > > org.apache.qpid.client.AMQSession_0_10.sendConsume(AMQSession_0_10.java:646) > > > > > at > > > > org.apache.qpid.client.AMQSession_0_10.sendConsume(AMQSession_0_10.java:67) > > > > > at > > > > org.apache.qpid.client.AMQSession.consumeFromQueue(AMQSession.java:2595) > > > > > at > > > > org.apache.qpid.client.AMQSession.registerConsumer(AMQSession.java:2965) > > > > > at > > > org.apache.qpid.client.AMQSession.access$500(AMQSession.java:97) > > > > > at > > > org.apache.qpid.client.AMQSession$4.execute(AMQSession.java:2025) > > > > > ... 15 more > > > > > > > > > > > > > > > > > > > > > > > > > I am horribly puzzled and I welcome any/all hints. > > > > > > > > > > > --------------------------------------------------------------------- > > > > > To unsubscribe, e-mail: [email protected] > > > > > For additional commands, e-mail: [email protected] > > > > > > > > > > > > > --------------------------------------------------------------------- > > > > To unsubscribe, e-mail: [email protected] > > > > For additional commands, e-mail: [email protected] > > > > > > > > > > > > > > --------------------------------------------------------------------- > > > To unsubscribe, e-mail: [email protected] > > > For additional commands, e-mail: [email protected] > > > > > > > > --------------------------------------------------------------------- > To unsubscribe, e-mail: [email protected] > For additional commands, e-mail: [email protected] > >
