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.
