activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Namrata Patel <namrata.pa...@synergytechservices.com>
Subject Re: Apollo MQ : when sending messages in transaction, producers count keeps increasing
Date Wed, 28 Aug 2013 07:17:34 GMT
Ya, sorry missed the screenshots.

*apollo_broker_queues_producers.JPG* - Queue producers list that shows are
still connected. And after some 233268 producers, it stops accepting
messages

For test file, I would like to help you with a test file, but I am PHP user
and looks like it might take me a lot more time to come up with a scala
test. So attaching a php test file and log of STOMP commands.
The stomp commands should be good start, as they are independent of any
programming language :-) . Its a simple program that connect()  ->
beginTransaction() -> send(), send(), send() -> commit() -> disconnect()
nothing fancy there. Other configurations are:
Stomp lib: FuseSource
Stomp version: 1.2
Apollo version: apache-apollo-1.6
Store Type: LevelDB

Do let me know if you need any more info. I will try downloading latest
Apollo server and see, if there was some fix after 1.6. Will update if I
find some solution/workaround.

Thanks.
Namrata



On Wed, Aug 28, 2013 at 12:25 AM, Christian Posta <christian.posta@gmail.com
> wrote:

> So i didn't see any screenshots that you attached. Please try attaching
> again.
> I cannot reproduce this as you've described. Maybe you can try creating a
> unit test. Start with this code here:
>
>
> https://github.com/apache/activemq-apollo/blob/trunk/apollo-stomp/src/test/scala/org/apache/activemq/apollo/stomp/test/StompParallelTest.scala
>
>
> On Tue, Aug 27, 2013 at 5:37 AM, Namrata Patel <
> namrata.patel@synergytechservices.com> wrote:
>
> > Did anyone try Apollo MQ with transactions? Did it give you this issue
> with
> > producers keep getting added and wont get disconnected even after
> commit()
> > and disconnect() ?
> >
> > Thanks
> >
> >
> > On Fri, Aug 23, 2013 at 11:20 AM, Namrata Patel <
> > namrata.patel@synergytechservices.com> wrote:
> >
> > > Sorry but I don't think so, though I wish it was just that :)
> > >
> > > On the admin console http://192.168.31.70:61780/console/index.html , I
> > > cannot even open the queue (click on the name) now. It wont open to see
> > > those Message, Producer and Consumers tabs.
> > >
> > >
> > > But when i go to the old broker portal:
> > >
> >
> http://192.168.31.70:61780/broker/virtual-hosts/youtubeNotification/queues/videoQ.html
> > > It shows (attached the full screenshot..) and open to see "Current
> > > Producers", the list keeps going on... So was thinking, it definitely
> > > cannot be just statistics count, as all are diff ports.
> > >
> > >> Producers
> > >>
> > >> producers: 232,408
> > >>
> > >> total producers ever : 232,410
> > >>
> > > Also,
> > >
> > > While doing some more tests, found that if I don't use transaction, ie
> > > remove BEGIN & COMMIT and transaction-id in MESSAGE.. all works fine.
> The
> > > producers count goes from 0 to 1 and back to 0 when the script stops..
> > >
> > > Hope this info will be helpful to re-produce/test.
> > >
> > > Thanks.
> > >
> > >
> > > On Thu, Aug 22, 2013 at 8:11 PM, Hiram Chirino <hiram@hiramchirino.com
> > >wrote:
> > >
> > >> Your just talking about the statistics counters?
> > >>
> > >> On Thu, Aug 22, 2013 at 8:06 AM, Namrata Patel
> > >> <namrata.patel@synergytechservices.com> wrote:
> > >> > Hello,
> > >> >
> > >> > I am using Apollo MQ Version: 1.6 with STOMP 1.2 protocol. I was
> > trying
> > >> to
> > >> > send couple of messages in an transactional manner using "BEGIN" and
> > >> > "COMMIT" stomp commands. This works as expected and all messages get
> > to
> > >> the
> > >> > queue correctly but the producers count keeps increasing. Attached
> > >> > screenshot of the Apollo admin console. The count wont go away even
> > if i
> > >> > delete the queue. I have to stop the broker and restart for it to
> > >> reset, but
> > >> > that is a bad idea for production environment.
> > >> >
> > >> > These are the set of STOMP commands that get fired in background:
> > >> >>
> > >> >> CONNECT
> > >> >> login:admin
> > >> >> passcode:password
> > >> >> accept-version:1.2
> > >> >> host:mybroker
> > >> >>
> > >> >> BEGIN
> > >> >> transaction:tx130822113902
> > >> >>
> > >> >> SEND
> > >> >> transaction:tx130822113902
> > >> >> persistent:true
> > >> >> destination:/queue/videoQ
> > >> >>
> > >> >> {"mymessage":"hello"}
> > >> >>
> > >> >> SEND
> > >> >> transaction:tx130822113902
> > >> >> persistent:true
> > >> >> destination:/queue/videoQ
> > >> >>
> > >> >> {"mymessage":"bwk2323"}
> > >> >>
> > >> >> SEND
> > >> >> transaction:tx130822113902
> > >> >> persistent:true
> > >> >> destination:/queue/videoQ
> > >> >>
> > >> >> {"mymessage":"dummy"}
> > >> >>
> > >> >>
> > >> >> COMMIT
> > >> >> transaction:tx130822113902
> > >> >> receipt:0125d425c2b845844c5532dfc4535b72
> > >> >>
> > >> >> DISCONNECT
> > >> >
> > >> >
> > >> >
> > >> >
> > >> > Do you think there is some issue with the code, as it looks pretty
> > >> straight
> > >> > forward :-)
> > >> >
> > >> > Thanks.
> > >> >
> > >> > Namrata Patel
> > >> >
> > >> >
> > >> >
> > >> > Disclaimer: The information contained in this electronic message and
> > any
> > >> > attachments to this message are intended for the exclusive use of
> the
> > >> > addressee(s) and may contain confidential or privileged information.
> > >>  If you
> > >> > are not the intended recipient or have received this email in error
> > you
> > >> are
> > >> > notified that disclosing, copying, distributing or taking any action
> > in
> > >> > reliance on the contents of this information is strictly prohibited.
> > >>
> > >>
> > >>
> > >> --
> > >> Hiram Chirino
> > >>
> > >> Engineering | Red Hat, Inc.
> > >>
> > >> hchirino@redhat.com | fusesource.com | redhat.com
> > >>
> > >> skype: hiramchirino | twitter: @hiramchirino
> > >>
> > >> blog: Hiram Chirino's Bit Mojo
> > >>
> > >
> > >
> > >
> > > --
> > >
> > > *Namrata Patel** *| Software Engineer
> > > Synergy Technology Services
> > >
> > > t+91-22-407-51999 | f +91-22-2925-1003 | m +91-9967585155
> > > *namrata.patel@synergytechservices.com*<
> > namrata.patel@synergytechservices.com>|
> > > www.synergytechservices.com <http://synergytechservices.com/>
> > >
> > > 701 Acropolis, Military Road, Marol, Andheri (East), Mumbai - 400 059
> > >
> > >
> >
> >
> > --
> >
> > *Namrata Patel** *| Software Engineer
> > Synergy Technology Services
> >
> > t+91-22-407-51999 | f +91-22-2925-1003 | m +91-9967585155
> > *namrata.patel@synergytechservices.com*<
> > namrata.patel@synergytechservices.com>|
> > www.synergytechservices.com <http://synergytechservices.com/>
> >
> > 701 Acropolis, Military Road, Marol, Andheri (East), Mumbai - 400 059
> >
> > --
> >
> >
> > *Disclaimer: The information contained in this electronic message and any
> > attachments to this message are intended for the exclusive use of the
> > addressee(s) and may contain confidential or privileged information.  If
> > you are not the intended recipient or have received this email in error
> you
> > are notified that disclosing, copying, distributing or taking any action
> in
> > reliance on the contents of this information is strictly prohibited.*
> >
>
>
>
> --
> *Christian Posta*
> http://www.christianposta.com/blog
> twitter: @christianposta
>



-- 

*Namrata Patel** *| Software Engineer
Synergy Technology Services

t+91-22-407-51999 | f +91-22-2925-1003 | m +91-9967585155
*namrata.patel@synergytechservices.com*<namrata.patel@synergytechservices.com>|
www.synergytechservices.com <http://synergytechservices.com/>

701 Acropolis, Military Road, Marol, Andheri (East), Mumbai - 400 059

-- 
 

*Disclaimer: The information contained in this electronic message and any 
attachments to this message are intended for the exclusive use of the 
addressee(s) and may contain confidential or privileged information.  If 
you are not the intended recipient or have received this email in error you 
are notified that disclosing, copying, distributing or taking any action in 
reliance on the contents of this information is strictly prohibited.*

Mime
View raw message