activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From elliottjf <...@pobox.com>
Subject Re: ActiveMQConnection.createConnectionConsumer bug?
Date Tue, 06 Feb 2007 02:33:48 GMT

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
View raw message