I am using apache-activemq-4.1.0-incubator
Did these get fixed ?
James.Strachan wrote:
>
> BTW which version of ActiveMQ are you using? We did find some gremlins
> on Acks that were fixed in 4.1
>
> On 1/16/07, miniman <[EMAIL PROTECTED]> wrote:
>>
>> All i have created an MDB that sits inside jboss and listens to the
>> queue/testQueue when a message gets posted to that queue it then calls
>> another method which posts the message to a topic. When i do this i get
>> an
>> error that comes back.
>>
>> code is
>>
>> in the onMessage method
>>
>> onMessage(Message message){
>> System.out.println("Received: " + message);
>> PublishToTopic(message);
>> }
>>
>> Then PublishToTopic looks like
>>
>> private void PublishToTopic(Message msg){
>>
>> try {
>> ActiveMQConnectionFactory factory = new
>> ActiveMQConnectionFactory(url);
>> connection = factory.createConnection();
>> session = connection.createSession(false,
>> Session.AUTO_ACKNOWLEDGE);
>> topic = session.createTopic("topic/testTopic");
>> //control =
>> session.createTopic("topictest.control");
>>
>> publisher = session.createProducer(topic);
>>
>> publisher.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
>>
>>
>> //session.createConsumer(control).setMessageListener(this);
>> connection.start();
>>
>> //request shutdown
>> publisher.send(msg);
>>
>> connection.stop();
>> connection.close();
>> } catch (JMSException e) {
>> // TODO Auto-generated catch block
>> e.printStackTrace();
>> }
>> }
>>
>>
>> The error i get is
>>
>> 18:26:50,523 INFO [PrefetchSubscription] Could not correlate
>> acknowledgment
>> with dispatched message
>> : MessageAck {commandId = 6, responseRequired = false, ackType = 2,
>> consumerId = ID:test1-489
>> 6-1168971769034-3:5:-1:2, firstMessageId =
>> ID:test1-4896-1168971769034-3:6:1:1:1, lastMessage
>> Id = ID:test1-4896-1168971769034-3:6:1:1:1, destination =
>> queue://queue/testQueue, transactio
>> nId = XID:257:64626c6f6e777331393830302f3137:31, messageCount = 1}
>>
>> Am i doing something wrong ?
>>
>>
>> --
>> View this message in context:
>> http://www.nabble.com/Trouble-with-posting-messages-to-topic-tf3022650.html#a8395964
>> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>>
>>
>
>
> --
>
> James
> -------
> http://radio.weblogs.com/0112098/
>
>
--
View this message in context:
http://www.nabble.com/Trouble-with-posting-messages-to-topic-tf3022650.html#a8405701
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
