Message should be delivered to two brokers at the same time those are managed by a HAProxy load balancer

2017-06-07 Thread gauravgoelcs3
Hi, I have to implement a scenario in which i need to configure two artemis live servers without any backup servers. Both of these two live servers are connected through a load balancer so that i have to give a single ip address in my java application to connect to artemis broker. And both live se

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 wrote: > You ca

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 pagi

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 information

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: http://active

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 Nabble.c

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 - User

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 residi

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 to

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 configur

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 integration pretty soon? Any >

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 maili

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 t

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 ou

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 to add the RetainedMes

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 a

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: http://activemq.2283324.n4.nabble.com/ARTEMIS-java-lang-NullPointerException-sw

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 hav

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 messages.