qpid-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Keith Wall (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (QPID-5906) Creating consumer with Rabbit fails unless IMMEDIATE_PREFETCH is set
Date Sat, 19 Jul 2014 13:40:38 GMT

     [ https://issues.apache.org/jira/browse/QPID-5906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Keith Wall updated QPID-5906:
-----------------------------

    Priority: Minor  (was: Major)

> Creating consumer with Rabbit fails unless IMMEDIATE_PREFETCH is set
> --------------------------------------------------------------------
>
>                 Key: QPID-5906
>                 URL: https://issues.apache.org/jira/browse/QPID-5906
>             Project: Qpid
>          Issue Type: Bug
>          Components: Java Client
>         Environment: Rabbit 3.3.4
> Qpid Client 0.29
>            Reporter: Keith Wall
>            Priority: Minor
>
> I've noticed that if I try to use the Qpid Client (testing with 0.29) to create a Consumer
with Rabbit, creating the consumer fails unless I set the IMMEDIATE_PREFETCH system property.
  Specifically, the Rabbit server is returning a NOT_IMPLEMENTED - active=false [error code
540: not implemented] in response to the channel.flow active=false.
> {noformat}
> com.intellij.rt.execution.application.AppMain org.apache.qpid.example.Hello
> 2014-07-19 14:32:34,203 ERROR [IoReceiver - /10.211.55.13:5672] [AMQConnection] Throwable
Received but no listener set: org.apache.qpid.AMQConnectionClosedException: Error: NOT_IMPLEMENTED
- active=false [error code 540: not implemented]
> javax.jms.JMSException: Error registering consumer: org.apache.qpid.AMQConnectionClosedException:
Error: NOT_IMPLEMENTED - active=false [error code 540: not implemented]
> 	at org.apache.qpid.client.AMQSession.toJMSException(AMQSession.java:3504)
> 	at org.apache.qpid.client.AMQSession$4.execute(AMQSession.java:2043)
> 	at org.apache.qpid.client.AMQSession$4.execute(AMQSession.java:1995)
> 	at org.apache.qpid.client.AMQConnectionDelegate_8_0.executeRetrySupport(AMQConnectionDelegate_8_0.java:333)
> 	at org.apache.qpid.client.AMQConnection.executeRetrySupport(AMQConnection.java:625)
> 	at org.apache.qpid.client.failover.FailoverRetrySupport.execute(FailoverRetrySupport.java:102)
> 	at org.apache.qpid.client.AMQSession.createConsumerImpl(AMQSession.java:1993)
> 	at org.apache.qpid.client.AMQSession.createConsumer(AMQSession.java:942)
> 	at org.apache.qpid.example.Hello.runTest(Hello.java:58)
> 	at org.apache.qpid.example.Hello.main(Hello.java:40)
> 	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
> 	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 	at java.lang.reflect.Method.invoke(Method.java:606)
> 	at com.intellij.rt.execution.application.AppMain.main(AppMain.java:134)
> Caused by: org.apache.qpid.AMQConnectionClosedException: Error: NOT_IMPLEMENTED - active=false
[error code 540: not implemented]
> 	at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
> 	at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57)
> 	at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
> 	at java.lang.reflect.Constructor.newInstance(Constructor.java:526)
> 	at org.apache.qpid.AMQException.cloneForCurrentThread(AMQException.java:134)
> 	at org.apache.qpid.client.protocol.AMQProtocolHandler.writeCommandFrameAndWaitForReply(AMQProtocolHandler.java:682)
> 	at org.apache.qpid.client.protocol.AMQProtocolHandler.syncWrite(AMQProtocolHandler.java:719)
> 	at org.apache.qpid.client.protocol.AMQProtocolHandler.syncWrite(AMQProtocolHandler.java:713)
> 	at org.apache.qpid.client.AMQSession_0_8.sendConsume(AMQSession_0_8.java:465)
> 	at org.apache.qpid.client.AMQSession_0_8.sendConsume(AMQSession_0_8.java:62)
> 	at org.apache.qpid.client.AMQSession.consumeFromQueue(AMQSession.java:2589)
> 	at org.apache.qpid.client.AMQSession.registerConsumer(AMQSession.java:2924)
> 	at org.apache.qpid.client.AMQSession.access$400(AMQSession.java:98)
> 	at org.apache.qpid.client.AMQSession$4.execute(AMQSession.java:2020)
> 	... 13 more
> {noformat}
> On the Rabbit side I see:
> {noformat}
> =ERROR REPORT==== 19-Jul-2014::14:32:33 ===
> AMQP connection <0.884.0> (running), channel 1 - error:
> {amqp_error,not_implemented,"active=false",'channel.flow'}
> =INFO REPORT==== 19-Jul-2014::14:32:33 ===
> closing AMQP connection <0.884.0> (10.211.55.2:61875 -> 10.211.55.13:5672)
> {noformat}
> Setting IMMEDIATE_PREFETCH prevents the client from producing the channel.flow and this
allows the consumer to be created properly and messages to flow.



--
This message was sent by Atlassian JIRA
(v6.2#6252)

---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@qpid.apache.org
For additional commands, e-mail: dev-help@qpid.apache.org


Mime
View raw message