Re: ActiveMQ: How to retain inflight messages post consumer restart

2017-06-06 Thread Tim Bain
Unsubscribing a topic consumer means that the broker should discard all messages for that consumer, and not retain any future messages for it. If the consumer later subscribes again, that is a new subscription that starts at that time, so only messages sent after that point will be delivered to the

Re: ActiveMQ: How to retain inflight messages post consumer restart

2017-06-06 Thread khandelwalanuj
> That sounds like the remaining inflight messages are getting acknowledged > during the process of shutting down gracefully; even though your consumer > never received them. Is that accurate? If so, that still sounds like a > bug. My durable consumer received them in client ack mode and didn't

Re: JDBC persistence for postgresql

2017-06-06 Thread Tim Bain
Bill, You've forwarded a link to documentation for an unrelated product, so I want to make sure you're doing this the ActiveMQ way and not the IBM MessageSight way. Are you saying that you configured the RetainedMessageSubscriptionRecoveryPolicy subscription recovery policy as described in http://

Re: JDBC persistence for postgresql

2017-06-06 Thread Bill Chen
Hi, Tim I'm not sure the retained flag is the same as the persistent flag. About the retained flag as follows: https://www.ibm.com/support/knowledgecenter/en/SSCGGQ_1.0.0/com.ibm.ism.doc/Overview/ov00033.html I publish to a message to a topic, not to a queue. So, I don't have any information in t

Re: Artemis Address Message Count

2017-06-06 Thread Justin Bertram
When you get the message count for an address it sums the message count for all the queues bound directly to that address. In the case of a multicast address that would be, for example JMS subscriptions, explicitly configured queues (from broker.xml), etc. This does not include queues receivin

Re: ActiveMQ: How to retain inflight messages post consumer restart

2017-06-06 Thread Tim Bain
That sounds like the remaining inflight messages are getting acknowledged during the process of shutting down gracefully; even though your consumer never received them. Is that accurate? If so, that still sounds like a bug. On Jun 6, 2017 3:34 AM, "khandelwalanuj" wrote: > My bad Tim. > > I was

Re: AW: Measurement points of "enqueue time" metric

2017-06-06 Thread Tim Bain
EnqueueTime (which really should have been called EnqueueDuration) = TimeOfDequeue - TimeOfEnqueue, which correspond to the two events I described in my first response. TimeOfDequeue is when the message is acked by the consumer, which depending on how you're configured might be before the consumer

Artemis Address Message Count

2017-06-06 Thread abhijith
Hi, We are monitoring Artemis via JMX. We have a topic(address with multicast) which has a divert to a queue. If I send messages to this address messages gets diverted correctly to queue. But if I query address mbean both messageCount and noOfMessages is 0. Is this expected? I think address

Re: NettyConnector explicitly initializes SSLContext instead of using default

2017-06-06 Thread Justin Bertram
What version are you using? There is an option in 2.1 to use the default SSL context. See https://issues.apache.org/jira/browse/ARTEMIS-590. Justin - Original Message - From: "mevans7" To: users@activemq.apache.org Sent: Tuesday, June 6, 2017 3:17:43 PM Subject: NettyConnector explic

NettyConnector explicitly initializes SSLContext instead of using default

2017-06-06 Thread mevans7
BOTTOM LINE: I need a secure way to initialize the SSLContext in org.apache.activemq.artemis.core.remoting.impl.netty.NettyConnector. (No keystore password in system properties.) USE CASE: I'm trying to configure a client to read JMS messages from Wildfly using SSL. This works ONLY if I speci

Re: Can fsync() ensure data is flushed to disk?

2017-06-06 Thread Clebert Suconic
I will remove that from the docs... In a previous version, we just had libaio to perform a write on Linux, and never to call fdatasync... you would require to disable write-cache to make sure the data would be synchronized on disk. With the latest version we now call fsync... you would save som

Re: Migrating storage from 5.10.0 to 5.14.5

2017-06-06 Thread christopher
The issue we have is that we have a number of scheduled tasks in the old queue. What I ended up doing was writing a program to read out of the old queue and then manually enqueue the tasks in the new queue. It was a little awkward, but it got the job done. On Mon, Jun 5, 2017, at 10:04 PM, Tim Bai

Re: How to monitor artemis ?

2017-06-06 Thread Justin Bertram
You can using JConsole, JVisualVM, or any other GUI JMX tool to monitor Artemis. Currently there is no web console. Justin - Original Message - From: "wangqinghuan" <1095193...@qq.com> To: users@activemq.apache.org Sent: Tuesday, June 6, 2017 4:30:17 AM Subject: How to monitor artemis

Re: JDBC persistence for postgresql

2017-06-06 Thread Tim Bain
What's the retained flag? So to be sure I'm understanding correctly: you publish a message to the queue (or are you publishing to a topic?), you do not consume it, and you can see the message in that queue on the web console, but it's not in the database table. Is that all correct? When you click

Re: JDBC persistence for postgresql

2017-06-06 Thread Bill Chen
Thanks Tim. I have set the retained flag for message when producer publish. But the message still not stored in the activemq_msgs table. May I need to modify my configuration in activemq.xml? -- View this message in context: http://activemq.2283324.n4.nabble.com/JDBC-persistence-for-postgresq

Re: artemis 2.2.0 logging disaster

2017-06-06 Thread hwaastad
Sorry, forgot the stack: 11:26:05,418 WARN [io.netty.channel.DefaultChannelPipeline] An exceptionCaught() event was fired, and it reached at the tail of the pipeline. It usually means the last handler in the pipeline did not handle the exception.: io.netty.util.internal.OutOfDirectMemoryError: fa

How to monitor artemis ?

2017-06-06 Thread wangqinghuan
I has installed artemis, but I couldn't monitor it in a web UI , like the ActiveMQWeb for ActiveMQ.Has web UI for artemis? -- View this message in context: http://activemq.2283324.n4.nabble.com/How-to-monitor-artemis-tp4727071.html Sent from the ActiveMQ - User mailing list archive at Nabble.c

Re: ActiveMQ: How to retain inflight messages post consumer restart

2017-06-06 Thread khandelwalanuj
My bad Tim. I was normally shutting down the consumer instead of kill -9 It works fine with kill -9 Thanks, Anuj -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-How-to-retain-inflight-messages-post-consumer-restart-tp4727027p4727070.html Sent from the ActiveM

Re: artemis 2.2.0 logging disaster

2017-06-06 Thread hwaastad
Hi, it did'nt change anything. Stille heap usage ok but OutOfDirectMemoryError /hw -- View this message in context: http://activemq.2283324.n4.nabble.com/artemis-2-1-0-logging-disaster-tp4726922p4727069.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: artemis 2.2.0 logging disaster

2017-06-06 Thread Michael André Pearce
I note your on a Linux platform and epoll is activated as such buffers are direct (offheap), On the acceptors can you set useEpoll to false, you set this a url param. And see what this does for you? This should change the heap memory usage as buffers will be on heap but will help in finding t

Re: artemis 2.2.0 logging disaster

2017-06-06 Thread hwaastad
Hi, did'nt help my setup. I've done similar testing with activemq 5.14.2 and I have no issues. Testing last 2.2.0-SNAPSHOT, with: JAVA_ARGS=" -XX:+PrintClassHistogram -XX:+AggressiveOpts -XX:+UseFastAccessorMethods -Xms512M -Xmx512M" Used Heap is kept low (max ~147M) But still: 10:44:56,616 WAR

Can fsync() ensure data is flushed to disk?

2017-06-06 Thread wangqinghuan
hi http://activemq.apache.org/artemis/docs/2.1.0/persistence.html. This article tells me that even after syncing from the operating system there is no guarantee the data has actually made it to disk. we must disable disk cache to ensure data integrity . https://linux.die.net/man/2/fsync This tells