Closed michaelandrepearce closed 7 years ago
Can one of the admins verify this patch?
I think something is wrong with this setup - I'm getting 3 messages/second :)
annoyingly without access to see what, nor any logs its hard to work out, no doubt its something obvious, or my scala code for the producer, as there are nuances between scala and java. maybe too many changes in one go.
With lack of access, i guess best option will be for me to send a PR with just a subset of the changes and we can go from there. (I've also just pinged someone else to cross check in case i made a silly mistake)
someone else's eagle eyes (thanks @franz1981) just spotted we changed the journal from asyncio to mapped and turned off fsync, but forgot to change the buffer timeout to 1 as we don't need this when running in this setup.
Can you change this from:
<journal-buffer-timeout>736000</journal-buffer-timeout>
To:
<journal-buffer-timeout>1</journal-buffer-timeout>
Also I think it could be my Scala code in jms2mq. As such the pr i sent makes artemismq extend jmsmq (sync send) just to eliminate that
@adamw
I think something is wrong with this setup - I'm getting 3 messages/second :)
Probably it is due to an unlucky mix of configurations, with a Raspberry 3 I'm getting order of magnitude more eheh In order to help better on it and just to summarize:
I'm expecting OS and HW are the same of the post, right? Anyway thanks for the time spent on it :+1:
@franz1981 i spotted/debugged the issue, its my async client Scala code i added, using latches that is the cause.
I update a PR for @adamw which moves him back to sync style code, but keeps all the basic bits. Move to use Artemis Client Mapped datasync false
I did enable transaction so will do batch transaction send (as noted clebert already advised this, but i don't think clebert noticed @adamw was using the 5.x client not the artemis one - which is important).
As noted on that PR @adamw if you could merge and run.
I will have to look at my async code, but tbh with artemis client, batch transaction, mapped, data sync false it should have some improvement.
Ive created an ArtemisMQ which uses the ActiveMQ Artemis JMS Client. Also have made the code use async sending with completion listener (jms 2.0 feature). And some hopefully broker side tunings.
I am not a Scala expert as such please let me know if any scala issues.