activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Rob Davies <rajdav...@gmail.com>
Subject Re: ActiveMQConnection.createConnectionConsumer bug?
Date Tue, 06 Feb 2007 08:25:06 GMT
Good catch! - committed to trunk  SVN revision 504023

On 6 Feb 2007, at 02:33, elliottjf wrote:

>
> can somebody confirm if this is really a bug?  if it is, it looks  
> like a
> pretty serious one.
>
>
> elliottjf wrote:
>>
>> Okay, from what I can tell, when using the ra activation spec driven
>> consumer construction, the ConsumerInfo options where getting lost.
>>
>> Upon removing the errant 'this.' and rebuilding the activemq-core  
>> module,
>> things are now working for me.
>>
>> snippet from org.apache.activemq.ActiveMQConnection.java:
>>
>>     public ConnectionConsumer createConnectionConsumer(Destination
>> destination, String messageSelector, ServerSessionPool  
>> sessionPool, int
>> maxMessages, boolean noLocal) throws JMSException {
>>
>>         checkClosedOrFailed();
>>         ensureConnectionInfoSent();
>>
>>         ConsumerId consumerId = createConsumerId();
>>         ConsumerInfo info = new ConsumerInfo(consumerId);
>>
>> info.setDestination 
>> (ActiveMQMessageTransformation.transformDestination(destination));
>>         info.setSelector(messageSelector);
>>         info.setPrefetchSize(maxMessages);
>>         info.setNoLocal(noLocal);
>>         info.setDispatchAsync(dispatchAsync);
>>
>>         // Allows the options on the destination to configure the
>> consumerInfo
>>         if( info.getDestination().getOptions()!=null ) {
>>             HashMap options = new
>> HashMap(info.getDestination().getOptions());
>> //            IntrospectionSupport.setProperties(-->this.info<--,  
>> options,
>> "consumer.");
>> //JE 07.02.01 removed the 'this' from info.  seems to fix the  
>> honoring of
>> consumer.exclusive option for a jencks jcaconnectior managed consumer
>>             IntrospectionSupport.setProperties(info, options,
>> "consumer.");
>>         }
>>
>>         return new ActiveMQConnectionConsumer(this, sessionPool,  
>> info);
>>     }
>>
>>
>
> -- 
> View this message in context: http://www.nabble.com/How-can-I- 
> configure-an-%22Exclusive-Consumer%22-queue-with-a-Jencks- 
> JCAConnector--tf3159712.html#a8819449
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>


Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message