Re: How to monitor artemis ?

2017-06-07 Thread Brett Delle Grazie
You can also use HawtIO and this plugin: https://github.com/rh-messaging/artemis-hawtio Its not as complete as JConsole etc. but it only requires access to the Jolokia port, not direct JMX so works more easily over firewalls / proxies etc. On 6 June 2017 at 14:05, Justin Bertram

Re: why AvtiveMq is slowly than Kafka?

2017-06-07 Thread Clebert Suconic
I think you are confusing memory cache with paging on the message system. Messages are kept in the memory for fast delivery unless you page then. The message broker can be configured to start writing messages on disk for later reading. In a sense paging becomes like Kafka partition when

Re: why AvtiveMq is slowly than Kafka?

2017-06-07 Thread nigro_franz
wangqinghuan wrote > why artemis maintains amounts of msgs in jvm space and needs to enable > paging to page messages into and out jvm memory? Because each have different purposes and information about the messages: - the journal is a commit log -> it doesn't contain all the runtime

Re: why AvtiveMq is slowly than Kafka?

2017-06-07 Thread wangqinghuan
I understand that mmap against page cache , os helps swap page between memory and disk.So less memory will be used by jvm. why artemis maintains amounts of msgs in jvm space and needs to enable paging to page messages into and out jvm memory? -- View this message in context:

Re: Artemis Address Message Count

2017-06-07 Thread abhijith
Thanks for the information Justin. I am counting numbers on all the diverts now and will continue with that. -- View this message in context: http://activemq.2283324.n4.nabble.com/Artemis-Address-Message-Count-tp4727127p4727162.html Sent from the ActiveMQ - User mailing list archive at

Re: Artemis HA cluster with replication

2017-06-07 Thread praneethg
So can we go in to production using replication ? want to make sure Artemis is production ready , is any one using this in Production? -- View this message in context: http://activemq.2283324.n4.nabble.com/Artemis-HA-cluster-with-replication-tp4725734p4727161.html Sent from the ActiveMQ -

Re: Artemis Address Message Count

2017-06-07 Thread Justin Bertram
> But IMHO it is misleading behavior..right? I don't think it's misleading. > As publisher I would like to get count of no of messages sent to an address. We don't currently track the total number of messages sent to an address. The message count is just the number of message currently

Re: Artemis Address Message Count

2017-06-07 Thread abhijith
Thanks Justin. But IMHO it is misleading behavior..right? As publisher I would like to get count of no of messages sent to an address. Publisher won't worry about how many queues or diverts are associated to an address. Right now if queues are not associated with an address, there is no way

Re: NettyConnector explicitly initializes SSLContext instead of using default

2017-06-07 Thread Justin Bertram
I just noticed that you said you were attempting to connect to Artemis in Wildfly, and I believe that's going to be a 1.5.x version (or perhaps earlier) without this new feature. FWIW whether you set the values in system properties on the command line or programmatically or whether you

Re: Artemis HA cluster with replication

2017-06-07 Thread Clebert Suconic
Performance over replication is only due to network latencies. There is a wish at the moment. But I am not aware of planning yet. It will happen but I don't know when yet. On Wed, Jun 7, 2017 at 9:51 AM praneethg wrote: > Are you planning to include ZooKeeper

Re: Artemis HA cluster with replication

2017-06-07 Thread praneethg
Are you planning to include ZooKeeper integration pretty soon? Any timeline? And would that improve performance over replication? -- View this message in context: http://activemq.2283324.n4.nabble.com/Artemis-HA-cluster-with-replication-tp4725734p4727132.html Sent from the ActiveMQ - User

Re: why AvtiveMq is slowly than Kafka?

2017-06-07 Thread Clebert Suconic
You need to enable paging if you don't want a consumer. Artemis is a messaging system. It's meant to be fast delivery with messages passing. If you want to store. No consumers. Enable paging. On Wed, Jun 7, 2017 at 5:01 AM wangqinghuan <1095193...@qq.com> wrote: > @clebertsuconic > I run

Re: o.s.jms.listener.DefaultMessageListenerContainer-Number of scheduled consumers has dropped below concurrentConsumers limit, probably due to tasks having been rejected. Check your thread pool confi

2017-06-07 Thread Tim Bain
Does your thread pool allow you to create up to 500 threads? This question really doesn't have anything to do with ActiveMQ, so although you might get an answer here, I'd strongly suggest that you post it on the Spring mailing list and on StackOverflow (since lots of people who know Spring hang

Re: JDBC persistence for postgresql

2017-06-07 Thread Tim Bain
On Jun 7, 2017 4:14 AM, "Bill Chen" wrote: Tim, I'm sorry that confused you about the reference link. I'm doing the ActiveMQ way, and I have encountered some questions. First, how to set the ActiveMQ.Retain property? You call Message.setBooleanProperty(). Second, I try

Re: JDBC persistence for postgresql

2017-06-07 Thread Bill Chen
Tim, I'm sorry that confused you about the reference link. I'm doing the ActiveMQ way, and I have encountered some questions. First, how to set the ActiveMQ.Retain property? Second, I try to add the RetainedMessageSubscriptionRecoveryPolicy in my configuration, but that occurred exception when

Re: ARTEMIS - java.lang.NullPointerException switching subscription with #

2017-06-07 Thread francesco81
Attached you can find a junit to replicate the issue. Cheers. Francesco PahoMQTTWildcardTest.java -- View this message in context:

Re: why AvtiveMq is slowly than Kafka?

2017-06-07 Thread nigro_franz
Hi! Just to understand...you've run a producer with no consumers? -- View this message in context: http://activemq.2283324.n4.nabble.com/why-AvtiveMq-is-slowly-than-Kafka-tp4726911p4727139.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

o.s.jms.listener.DefaultMessageListenerContainer-Number of scheduled consumers has dropped below concurrentConsumers limit, probably due to tasks having been rejected. Check your thread pool configura

2017-06-07 Thread Chester_Zheng
Hi, AllI met a problem. I used the "DefaultMessageListenerContainer" to increase the consumer count, but when the app run awhile, the log shows that "o.s.jms.listener.DefaultMessageListenerContainer-Number of scheduled consumers has dropped below concurrentConsumers limit, probably due to tasks

Re: why AvtiveMq is slowly than Kafka?

2017-06-07 Thread wangqinghuan
@clebertsuconic I run the demo in document "fast_messaging_with_artemis". Just started, the producer takes less 2s to send 100k messages. But as the number of messages stored in journal file increasing (more than 1 millions in journal file). Producer takes more than 30s to send 100k