Hi Charith,
Getting following. Check for a concurrent or synchronized alternative
for TreeMap.
java.util.ConcurrentModificationException
at
java.util.TreeMap$NavigableSubMap$SubMapIterator.nextEntry(TreeMap.java:1572)
at
java.util.TreeMap$NavigableSubMap$SubMapKeyIterator.next(TreeMap.java:1633)
at
org.wso2.andes.server.store.CassandraMessageStore$ContentRemoverTask.run(CassandraMessageStore.java:1769)
at java.lang.Thread.run(Thread.java:680)
Also got lot of logs with
2012-05-11 12:29:40,849] INFO {org.wso2.andes.server.AMQChannel} -
Unsubscribing all consumers on channel [/127.0.0.1:63572(admin):1]
[2012-05-11 12:29:40,850] INFO {org.wso2.andes.server.AMQChannel} -
Unsubscribing consumer '1' on channel [/127.0.0.1:63572(admin):1]
[2012-05-11 12:29:40,881] INFO {org.wso2.andes.server.AMQChannel} -
Unsubscribing all consumers on channel [/127.0.0.1:63563(admin):1]
[2012-05-11 12:29:40,882] INFO {org.wso2.andes.server.AMQChannel} -
Unsubscribing consumer '1' on channel [/127.0.0.1:63563(admin):1]
[2012-05-11 12:29:40,882] INFO {org.wso2.andes.server.AMQChannel} -
No consumers to unsubscribe on channel [/127.0.0.1:63584(admin):9]
[2012-05-11 12:29:40,882] INFO {org.wso2.andes.server.AMQChannel} -
No consumers to unsubscribe on channel [/127.0.0.1:63580(admin):10]
[2012-05-11 12:29:40,896] INFO
{org.wso2.andes.server.protocol.AMQProtocolEngine} - Closing
connection due to: org.wso2.andes.AMQConnectionException: Broker is
shutting down [error code 541: internal error]
I am testing by running 10 consumers and publishers from my machine.
--Srinath
On Fri, May 11, 2012 at 8:54 AM, Charith Wickramarachchi
<[email protected]> wrote:
>
>
> On Fri, May 11, 2012 at 6:35 AM, Srinath Perera <[email protected]> wrote:
>>
>> Please see comments inline. I think this is good, apart from few minor
>> things I mentioned.
>>
>>
>> On Thu, May 10, 2012 at 4:50 PM, Charith Wickramarachchi
>> <[email protected]> wrote:
>> > Hi Srinath ,
>> >
>> > Please find the svn urls for the important classes with small detail on
>> > the
>> > usage
>> >
>> > org.wso2.andes.server.subscription.SubscriptionImpl.AckSubscription
>> >
>> > (https://svn.wso2.org/repos/wso2/carbon/platform/trunk/dependencies/andes/java/broker/src/main/java/org/wso2/andes/server/subscription/SubscriptionImpl.java)
>> >
>> > In the send method of this we send the messages
>>
>> At "System.out.println("false");" here put a debug message with more
>> detials
>>
>
> Sorry about the sys out. i thought i removed all the sysouts
> before committing.
>
>>
>> >
>> > org.wso2.andes.server.output.amqp0_9_1.ProtocolOutputConverterImpl
>> >
>> > (https://svn.wso2.org/repos/wso2/carbon/platform/trunk/dependencies/andes/java/broker/src/main/java/org/wso2/andes/server/output/amqp0_9_1/ProtocolOutputConverterImpl.java)
>> > writeMessageDelivery in this (Line number 104 ) got that while loop
>> > which
>> > ended up in a infinite loop
>> >
>> >
>> > org.wso2.andes.server.cassandra.QueueSubscriptionAcknowledgementHandler
>> >
>> > (https://svn.wso2.org/repos/wso2/carbon/platform/trunk/dependencies/andes/java/broker/src/main/java/org/wso2/andes/server/cassandra/QueueSubscriptionAcknowledgementHandler.java)
>> > Is the onc which handle the acks It also have a inner class which does
>> > the
>> > clean up.
>>
>> In if(timeStampAckedMessageIdMap.firstKey() + ackedMessageTimeOut <
>> currentTime) {, lets make ackedMessageTimeOut 2X ackedMessageTimeOut
>> to be safe.
>>
>> In checkAndRegisterSent(), we should be able to move "if (cleanupJob
>> == null) {" block to a constructor
>>
>>
>>
>
>
> Thanks for the feedback. Will do the suggested changes.
>
>
> regards,
> Charith
>
>>
>> >
>> > org.wso2.andes.server.AMQChanne
>> >
>> > (https://svn.wso2.org/repos/wso2/carbon/platform/trunk/dependencies/andes/java/broker/src/main/java/org/wso2/andes/server/AMQChannel.java)
>> >
>> > Method acknowledgeMessage handle the ack
>> >
>> > thanks,
>> > Charith
>> >
>> >
>> >
>> > --
>> > Charith Dhanushka Wickramarachchi
>> > Software Engineer
>> > WSO2 Inc
>> > http://wso2.com/
>> > http://wso2.org/
>> >
>> > blog
>> > http://charithwiki.blogspot.com/
>> >
>> > twitter
>> > http://twitter.com/charithwiki
>> >
>> > Mobile : 0776706568
>> >
>> >
>>
>>
>>
>> --
>> ============================
>> Srinath Perera, Ph.D.
>> Senior Software Architect, WSO2 Inc.
>> Visiting Faculty, University of Moratuwa
>> Member, Apache Software Foundation
>> Research Scientist, Lanka Software Foundation
>> Blog: http://srinathsview.blogspot.com/
>> Photos: http://www.flickr.com/photos/hemapani/
>> Phone: 0772360902
>
>
>
>
> --
> Charith Dhanushka Wickramarachchi
> Software Engineer
> WSO2 Inc
> http://wso2.com/
> http://wso2.org/
>
> blog
> http://charithwiki.blogspot.com/
>
> twitter
> http://twitter.com/charithwiki
>
> Mobile : 0776706568
>
>
--
============================
Srinath Perera, Ph.D.
Senior Software Architect, WSO2 Inc.
Visiting Faculty, University of Moratuwa
Member, Apache Software Foundation
Research Scientist, Lanka Software Foundation
Blog: http://srinathsview.blogspot.com/
Photos: http://www.flickr.com/photos/hemapani/
Phone: 0772360902
_______________________________________________
Dev mailing list
[email protected]
http://wso2.org/cgi-bin/mailman/listinfo/dev
