Re: Ongoing queue troubles

First figure out if your problem is that the messages are not getting into the CommandQueue or if it's that they're not getting from there to the consumer. To do that, attach a JMX viewer such as JConsole to the broker process, and then in the MBeans tab navigate down to the MBean for the queue

Re: ActiveMQ DLQ issues

This tells you that the messages were discarded by ActiveMQ because they had expired. Are your producers setting a time to live when sending messages? Tim On Fri, Sep 15, 2017 at 5:42 PM, mtod wrote: > I'm running ActiveMQ 5.10.0 with an embedded camel route. It's been

Re: Temp Store is Full - False Positive?

I finally got some time to look into this, and several parts of what I told you were wrong. I had said that the temp store was a KahaDB instance. That was true, but imprecise and I didn't know it. Technically, the temp store is any store that implements org.apache.activemq.store.PListStore, and

Re: ActiveMQMessageConsumer dispatch

> > java.lang.RuntimeException: Failed to invoke > public org.apache.activemq.command.ActiveMQDestination() with no args > java.lang.RuntimeException: Failed to invoke public > org.apache.activemq.command.ActiveMQDestination() with no args > This error message means that Gson is trying to

Re: ActiveMQ broker OOM

1) All the overhead data structures of the broker, including the running threads. 2) The memory store, which is used for both non-persistent messages and for paging persistent messages back in from the persistent store. The paging is done per-queue if I remember correctly, so if you have lots of

Re: Cleanup Pending messages using JMX remove message

Just to confirm: when your subscribers are all offline, how many objects are returned in the List from getSubscriptions()? Tim On Wed, Oct 18, 2017 at 10:18 AM, Hitesh < hitesh.hotchand...@contentsphere.com> wrote: > > > Hi all, > I have a very peculiar and weird usecase with ActiveMQ 5.13 > >

Re: Kahadb index updates taking too much time on ActiveMQ 5.11

I'm glad you got it working, and from the synonyms I'm not surprised that NFS ended up being the root cause. Tim On Oct 19, 2017 6:24 AM, "Devlin" wrote: > Thank you, Tim. > > We finally figured out the issue; NFS "noac" option was killing > performance. > >

Re: org.apache.activemq.SERIALIZABLE_PACKAGES property affecting Map Messages

The default value of that property (if it's not set) is "java.lang,javax.security,java.util,org.apache.activemq,org.fusesource.hawtbuf,com.thoughtworks.xstream.mapper" (see ClassLoadingAwareObjectInputStream.java), and the org.fusesource.hawtbuf class in question looks like a UTF8Buffer since

Re: Clustering ActiveMQ in an Amazon ECS/Docker/Weave environment

Leave the transportConnector's uri property alone as the original value of tcp://0.0.0.0:61618; that's the IP for brokers to use when talking to each other, but doesn't play when they're finding out about one another. The way this is supposed to work (follow along at

Re: Kahadb index updates taking too much time on ActiveMQ 5.11

Sorry for the delay in responding. I've got a number of follow-up questions/suggestions: 1. Can you take screenshots sorted by all four non-percentage columns (Self Time, Self Time (CPU), Total Time, Total Time (CPU))? The ones with CPU measure CPU time, while the ones without measure

Re: Running several instances of ActiveMQ behind a proxy/load balancer

I've used ActiveMQ and AWS ELBs, but not the two together, so this response is based solely on what I know about the two products and on prior posts on this mailing list. I don't believe you'll be able to make this work using AWS ELBs. As you said, ELBs have a pretty simple model of unhealthy

Re: Message redelivery when producer broker killed (without persistence)

ActiveMQ 5.x allows messages to be delivered to local consumers over remote ones via the decreaseNetworkConsumerPriority property as described at http://activemq.apache.org/networks-of-brokers.html. JMSXGroupID will not achieve this goal for the reasons you described. Also, I dispute your claim

Re: SQL Server Error - Cannot load JDBC driver class

>From the logs, it looks like it's failing to drop the primary key and then failing to create it (because it failed to drop it). For now let's assume that we're ending up in a good place (the table exists, the index exists), though we may have to reexamine that assumption if we find evidence of

Re: SQL Server Error - Cannot load JDBC driver class

The StackOverflow post I got it from indicated that Microsoft may have changed their package structure at some point, so the correct package may be tied to which version of the JAR you use. But I don't have any more info than that. On Oct 18, 2017 6:32 AM, "ubaid"

Re: SQL Server Error - Cannot load JDBC driver class

Does that JAR contain a class named com.microsoft.jdbc.sqlserver.SQLServerDriver as you specified in your config file? Or is it actually com.microsoft.sqlserver.jdbc.SQLServerDriver? Tim On Oct 18, 2017 2:37 AM, "ubaid" wrote: > Following are my configurations for SQL

Re: Incorrect store percent used

Keep in mind that the store limits don't prevent you from crossing the threshold, they prevent you from accepting new messages once you've crossed the threshold. So if you're sending messages that are >= 4% of the memory store, it's very possible that this was in fact correct behavior (though not

Re: Message redelivery when producer broker killed (without persistence)

I agree. The fundamental problem you're hitting is that in ActiveMQ 5.x, a message can exist in only one active broker, so networks of brokers move messages around via store-and-forward, as you described. For a message to be available to multiple brokers at the same time (such that it would still

Re: Should master/slave brokers share tmp_storage directory?

No, it should not be shared between brokers. The temp store is for holding content that overflows from the memory store. The memory store contains only non-persistent messages, which do not survive a broker restart (or a failover), so the temp store should not either. Tim On Oct 11, 2017 6:04

Re: Unable to to consume all messages from queeue.

For the logs you posted, they show no indication of any ActiveMQ-specific problem, so the initial question is really a Mule question (best posed to their mailing list, not ours): what does this particular Mule-specific log line mean, and what if anything does it indicate about the behavior of the

Re: Two brokers mirrored

Look at the Stuck Messages section of http://activemq.apache.org/networks-of-brokers.html for how to allow messages to come back to Broker1 after being forwarded to Broker2. Tim On Oct 10, 2017 11:07 AM, "serkm" wrote: > Hi. I have two brokers (broker1 and broker2) with

Re: org.apache.activemq.SERIALIZABLE_PACKAGES property affecting Map Messages

Try org.apache.activemq, since that's where MapMessage lives. On Oct 11, 2017 12:47 AM, "khandelwalanuj" wrote: > Ok. I am able to make it work by adding "org" in the serializable package > property. > > Details: > >

Re: msg.getJMSReplyTo().toString() and Session.createQueue(replyString)

Session.createQueue() is defined as part of the JMS spec, and it's not a bug when it doesn't do things beyond the requirements of the spec. Just strip off the prefix yourself before you call it. Tim On Oct 2, 2017 5:15 AM, "boekhold" wrote: Hi, The following code fails:

Re: Can't subscribe to advisories for producer and consumers...

Thanks for sharing the answer you found; hopefully it'll help someone else who's wondering the same thing. On Sep 29, 2017 1:42 PM, "Raffi" wrote: > OK, so I discovered ActiveMQPooledConnectionFactor uses pooled, anonymous > producers, for which advisories are not

Re: Log files not being cleaned up

The question I asked Lionel applies to you ad well. On Sep 29, 2017 9:12 AM, "GlenWard" wrote: > Facing the same problem. I had done all possible solutions but still > problem > remains unsolved > > > >

Re: Durable subscribers (for topic) and Network of brokers

https://issues.apache.org/jira/browse/AMQ-5290 sounds like it should have eliminated this issue, but the fact that you're seeing this using MQTT (or are you using STOMP?) on 5.15.0 means something else is going on. One question: have you enabled conduitSubscriptions between A and B? Tim On Sep

Re: "allowLinkStealing" as a client configuration

Hmmm, interesting. That means one of two things: 1. Following the broker restart, multiple client processes/threads are trying to connect using the same client ID. For a given client ID, the first process/thread to attempt the connection will succeed, and the later ones will fail. I would expect

Re: "allowLinkStealing" as a client configuration

Does restarting the broker without enabling link stealing also let you work around the problem? Based on what you've described as working vs. not, I would expect that to be a viable workaround. And if it's not, that might give more information about what's actually going on. Tim On Sep 27, 2017

Re: ActiveMQ Cluster in Docker Swarm

Since you're looking for clustered operation, ActiveMQ Artemis sounds like a better fit for your needs than ActiveMQ 5.x would be. Tim On Sep 27, 2017 3:49 PM, "Nick Stolwijk" wrote: > Hi, > > We are just starting with Docker Swarm and we have 2 services that need to >

Re: java.lang.IllegalStateException: Timer already cancelled

As luck would have it, I ran into an instance of this issue myself (but against 5.10.0) after we were unable to allocate a thread because we hit the OS's process (thread) limit. Several other people commented that the same thing happened to them

Re: Kahadb index updates taking too much time on ActiveMQ 5.11

I've not seen anyone describe this set of symptoms, so I don't have anything to suggest right from the outset, but I may be able to help you figure out what's going on. Could you attach a CPU sampler such as JVisualVM to the broker process and capture CPU sampling (not profiling if this is an

Re: ActiveMQ Config to purge 'persistent' messages in DLQ.

You've probably already tried this and found it out, but persistent messages are the normal case for the SharedDeadLetterStrategy, so they'll be processed even if processExpired is false. Non-persistent messages are not sent to the DLQ by default, which is why you've explicitly enabled that via

Re: Receiving NetworkBroker seems to be stuck

It's possible to run top in batch mode and then pipe that to a file, which would let you test your theory that CPU usage is high. It's also possible to configure the JVM to output GC activity to a log file, which would let you see if heavy GC activity is the root cause of any unresponsiveness.

Re: "allowLinkStealing" as a client configuration

I finally got time on a computer (not my phone) to look at this. First, the reason that you're not seeing a stack trace is our fault, not the result of the JVM optimizing away the stack trace. If you look at line 858 of

Re: What is the use case of BrokerService in ActiveMQ and how to use it correctly

As you said, the purpose of BrokerService is to run a broker, either as a standalone process or embedded within your application. A standalone broker is the most common configuration, because it more easily supports multiple client processes, but if all your producers and consumers run in the same

Re: Restarting ActiveMq removes/cleans all persisted messages/queues/topics

Are you also using MS SQL Server like the previous posters? Can you confirm that messages exist in the database prior to and after the restart even though they're not available in the broker? What version of ActiveMQ are you using? On Sep 22, 2017 9:52 AM, "camix" wrote: > I'm

Re: ActiveMQ failover + jmeter : JVM crash abd queue in error after failover

If you send just 1 message (still via JMeter) and then graceful shut down broker1, is that message visible in broker2? What about if you send 10, or 100? What is the behavior if you send 500 messages but with a sleep (200 ms, let's say) between each one? Does the broker still run out of memory?

Re: wildfly-10.1.0.Final integration for MQTT not working

I think there's still value in you determining whether this use case works in standalone Artemis. If your existing code works as expected against standalone Artemis but not against Artemis embedded in Wildfly, you'll have demonstrated that the problem is within Wildfly, which might make it more

Re: Multiple SSL Context Elements

The same question has been asked before ( http://activemq.2283324.n4.nabble.com/Is-it-possible-to-keep-two-certificates-in-activemq-ssl-context-tp4725736.html) and never got a response, so I believe it's not currently possible. On Sep 19, 2017 4:41 PM, "kai" wrote:

Re: AMQ SCHEDULED DELAY

On Sep 19, 2017 1:44 PM, "srramu45" wrote: Yes scheduled messages are not working .We have requirement to set message schedule for 60 sec to 1 hour , message should come in to queue or it should be consumed after given time and not sure if this scheduled messages are going

Re: Stuck messages

1) I've always found far more value in the information exposed via JMX than in the content shown on the web console. The web console is great for basic system monitoring, but anytime you want to understand what's actually going on inside the broker, I've always found that JMX was far more useful.

Re: "allowLinkStealing" as a client configuration

Do you get a stack trace after that line in the logs? I spent a small amount of time trying to figure out where that InvalidClientIDException is thrown so I could look at why that null might be getting in there, but it wasn't immediately obvious so a stack trace would help. Note that the JRE will

Re: AMQ SCHEDULED DELAY

I'm sorry, the only thing I understand from your question is that scheduled messages aren't working for you, but I didn't understand the rest of what you were saying. Can you please explain further? And can you please explain what behavior you expect and what behavior you see instead? Can you

Re: Stuck messages

In addition, read and follow the Stuck Messages section of the Network of Brokers page I linked to earlier to avoid stranding messages. On Sep 18, 2017 12:42 PM, "Raffi" wrote: > Remove "rebalanceClusterClients=true", it distributes connections across > brokers, likely

Re: javax.jms.JMSException: Cannot send, channel has already failed: tcp://127.0.0.1:61616

I suspect that multiple things can cause these symptoms. One of them (according to https://serverfault.com/questions/550735/activemq-cannot-send-channel-has-already-failed-every-2-seconds) is having a TCP port check of the sort you might use to monitor whether a broker is alive. I expect that

Re: Upgrading One Broker At A Time

We don't explicitly test cross-version compatibility so we can't make any guarantees, but we try not to do anything that would break compatibility and I haven't heard of any cases where anyone has found an incompatibility. But as always, test in a non-operational environment before you do it live.

Re: Stuck messages

When a message is stuck on a given queue, have you confirmed that there is at least one consumer for that queue connected to the broker on which the message resides? A JMX viewer such as JConsole is ideal for determining this. I haven't used the rebalanceClusterClients option before, but I expect

Re: Subscriber consumption not registering in AMQ Log

I wasn't proposing that you modify the source, only that you use it for debugging. It's possible that someone else will have experienced this problem and will respond with an explanation; I hope someone does. But if you look back through the ActiveMQ 5.x threads on this list over the past six

Re: Log files not being cleaned up

Have you run the troubleshooting procedures in http://activemq.apache.org/why-do-kahadb-log-files-remain-after-cleanup.html? What did they indicate? On Sep 12, 2017 8:27 PM, "Lionel van den Berg" wrote: Hi all, ActiveMQ 5.14.4 running on Suse enterprise 11 sp4 I'm having

Re: wildfly-10.1.0.Final integration for MQTT not working

The plan/hope is that Artemis will become ActiveMQ 6.x succeeding ActiveMQ 5.x, but for right now they are sibling products within the overarching ActiveMQ project. On Sep 13, 2017 7:03 AM, "thomas.houtek...@barco.com" < thomas.houtek...@barco.com> wrote: > Thanks for the input! > Yes indeed, it

Re: wildfly-10.1.0.Final integration for MQTT not working

It appears from your stack trace that this is embedded Artemis, not embedded ActiveMQ 5.x. Is that right? On Sep 13, 2017 4:36 AM, "thomas.houtek...@barco.com" < thomas.houtek...@barco.com> wrote: > Hi, > > I'm trying to get MQTT working on wildfly-10.1.0.Final. WF10 contains > activemq embedded

Re: JMX MemoryPercentUsage Not Changing

If I recall correctly, there were a number of bugs related to statistics and JMX status that were fixed in the 5.6-5.9 range, so it's possible that this issue has already been fixed in a later version. (Did you search JIRA before posting this question?) Because of that possibility, it's unlikely

Re: ActiveMQv5.14 ObjectMessage Issues

Here is the source of that class in 5.11.1: http://grepcode.com/file/repo1.maven.org/maven2/org.apache.activemq/activemq-all/5.11.1/org/apache/activemq/util/ClassLoadingAwareObjectInputStream.java?av=f If you look at line 112 (the one from your stack trace), you can see that it doesn't log the

Re: ActiveMQv5.14 ObjectMessage Issues

What specific version of 5.11 is your client running? The security fix that added this check (https://issues.apache.org/jira/browse/AMQ-6013) was back-ported to 5.11.3, so if you're using that version of 5.11 or later, then you have that change. Tim On Tue, Sep 12, 2017 at 12:19 AM,

Re: ActiveMQ Config to purge 'persistent' messages in DLQ.

I believe the problem is that your current configuration has your messages expire after 24 hours on the DLQ, only to be deleted and sent to. the DLQ. I believe this is what is referred to by the warning in the Setting Expiration on Messages in the DLQ section of

Re: Broker doesn't seem to work correct

Are we talking about 204 No Content, or 404 Not Found? Your first sentence seems to have put one error code and a different error message together, though your last sentence makes it seem like you're talking about a 204. What URL are you hitting when you get this response? And I assume you're

Re: kahaDB archiveCorruptedIndex

That attribute was added in 5.6.0 under https://issues.apache.org/jira/browse/AMQ-3634. Tim On Sep 11, 2017 1:00 PM, "bbuzzard" wrote: > I'm using ActiveMQ-5.5.1 (Yes I know it's very old). I'm trying to set > archiveCorruptedIndex to true, but I get the error

RE: How to put "properties" on a message so they are accessible later

To be clear, you're asking about doing this in Artemis, not ActiveMQ 5.x, right? What version of Artemis? On Sep 11, 2017 2:48 PM, "Harrison Tarr" wrote: > I just wanted to follow up: Does anyone know how to put an > attribute/property on a message in an

Re: Consumers connected to several brokers

Do you need to have access to messages published to the first broker when it goes down? If so, you should be looking at a master/slave pair instead of two active brokers. If not, you should network the two brokers to allow messages published on either one to be delivered to a consumer on any

Re: Message repetition consumption：Four consumers consume the same queue message, with two consumers receiving the same message at the same time, receiving a gap of 1ms

onsume the same > queue message, with two consumers receiving the same message at the same > time, receiving a gap of 1ms > > > Also, I'd want to know if the two messages had the same JMSMessageID (i.e. > were they the same message, or were they two different messages with the > sam

Re: Subscriber consumption not registering in AMQ Log

You could grab the ActiveMQ source code and set a breakpoint at the line where the logging should be occurring and see whether you're actually getting to that line. Tim On Sep 11, 2017 8:59 AM, "peakey" wrote: > Hi all, > > I have a strange issue with AMQ, i have

Re: Message repetition consumption：Four consumers consume the same queue message, with two consumers receiving the same message at the same time, receiving a gap of 1ms

Also, I'd want to know if the two messages had the same JMSMessageID (i.e. were they the same message, or were they two different messages with the same content). On Sep 11, 2017 7:50 AM, "Tim Bain" <tb...@alumni.duke.edu> wrote: > Do you see the same behavior if you switc

Re: Message repetition consumption：Four consumers consume the same queue message, with two consumers receiving the same message at the same time, receiving a gap of 1ms

Do you see the same behavior if you switch to KahaDB or JDBC? As Tim Bish said on that JIRA bug, LevelDB is no longer supported, so you're only going to get a fix if you can demonstrate that it's still a problem if you switch to one of the supported store types. Tim On Sep 11, 2017 7:05 AM,

Re: Network Connector question

If you're talking about queues, that's expected behavior. A queue message exists on only one broker in an NoB, so the two on-prem brokers will complete for queue messages from your us-east master. If you're talking about topics, then that's very unexpected behavior and we should dig deeper. And

Re: Does apollo support cluster deployment?

Even if Apollo did, would you want to use a product that never reached any meaningful level of maturity and is no longer actively developed? Take Clebert's (implied) advice and use Artemis instead. Tim On Sep 6, 2017 9:41 PM, "Clebert Suconic" wrote: > Artemis is

Re: Adding Network connectors dynamically

h what you have in mind. That would let you quickly figure out whether it's feasible without sinking too much time into it. Tim On Sep 1, 2017 10:52 PM, "Tim Bain" <tb...@alumni.duke.edu> wrote: > The code you're envisioning could only work if run within the broker > process;

Re: Adding Network connectors dynamically

The code you're envisioning could only work if run within the broker process; to the best of my knowledge, you can't do what you're describing from a client process. That begs the question of how you'd give your code control to be able to run in the first place; maybe a custom broker plugin that

Re: Broken Pipe Connecting

A broken pipe means that the other side of the socket closed it and then your side tried to write to it. So the question is then, what do you see in the broker's logs when this is happening? That might indicate why it's disconnecting you right after sending the ConnectionControl message to you.

Re: Updating version

Are you uploading files via BlobMessages ( http://activemq.apache.org/blob-messages.html), or are you referring to something else? Assuming you're using BlobMessages, can you please show the code where you create and send the message, and the code or configuration where you set the BLOB transfer

Re: Slow consumers not detected with ?consumer.prefetchSize=1

Does it work for prefetchSize=2, just not 1? (Sorry, I won't be able to try running the code till sometime next week, otherwise I'd just try it myself rather than ask.) Tim On Thu, Aug 31, 2017 at 7:40 AM, art.licis wrote: > I'm sorry, I sent a wrong link; Unit test is

Re: ActiveMQ: Temp Store location

Can you please post the activemq.xml content you used when it didn't work, along with the results of ls - al on the directory you want to use for the temp store? Also, I assume there's nothing relevant in the logs? Tim On Aug 22, 2017 4:32 AM, "khandelwalanuj"

Re: Possible to create broker-specific topic subscriber in broker network?

What if you have you have a single consumer that lives outside the brokers and that connects to one broker in the mesh and gets all advisories (from all brokers) from that one broker? There are no selectors involved, no composite destinations, and no duplication, and the only downsides are 1) you

Re: ActiveMQ 5.14.5 bridge intermittent reconnect issue

Thanks for figuring out the VPN thing. Otherwise, you and I were going to have a fruitless (and frustrating) series of emails. My only suggestion for your configs is to reduce duplication by putting all your topics in a single element instead of repeating it for each one. Otherwise it looks

Re: ActiveMQ is not starting on Linux system and gives error

If that doesn't solve your problem, can you please tell us if a log file gets created, and if so what content is written to it? On Aug 28, 2017 1:31 PM, "Giovanni Parodi" wrote: > Hi, please try starting the activemq application in 64 bit subfolder. > For me, it

Re: JOB | Permanent Database Engineer (the Netherlands or remote)

This is an inappropriate use of the Apaxhe user mailing lists; do not use mailing lists to advertize job offers (or anything else, for that matter) elsewhere. On Aug 28, 2017 12:48 AM, "James Tobin" wrote: > Hello, I'm working with an employer that is looking to hire

Re: Slow consumer acknowledgment timeout

No slow consumer strategy is enabled by default, so if you haven't configured anything, then the answer is "never." If you choose to use the strategy you referenced, configuration details (including defaults) are at https://dzone.com/articles/coming-activemq-59-new-way. Or you can use the

Re: JAVA ActiveMQ JMX browse messages on Topic

You're right and I was wrong: it is indeed possible to browse a topic. I learned something new today; thanks. It looks to me like your problem may be that you don't have the right ObjectName. What you wrote appears to be for the broker, not for the topic. I'd expect something more like this:

Re: How to stop retry continously

OK, so if your goal is simply to allow the producer to detect that the broker is unavailable, you can get the behavior you want by using the sendTimeout setting ( https://stackoverflow.com/questions/15315631/activemqconnectionfactory-sendtimeout) instead of the closeTimeout setting (whose purpose

Re: How to stop retry continously

If you don't want to try to reconnect, you could use the static transport in place of the failover transport. That would mean that any inability to connect to the broker (either at initial connection time or due to a connectivity loss later on) would result in the producer being permanently

Re: ActiveMQ: Temp Store location

Use the broker's tmpDataDirectory attribute, as described in http://activemq.2283324.n4.nabble.com/Changing-disk-location-of-tempUsage-td4668124.html . On Aug 16, 2017 1:31 AM, "khandelwalanuj" wrote: > Hi, > > I am using replicated levelDB with ActiveMQv5.14. >

Re: Temp Store is Full - False Positive?

On Aug 18, 2017 7:34 AM, "khandelwalanuj" wrote: I am a bit confused here. Few questions, 1. Even if we are using levelDB for persistent store, does temp store is still kahadb ? FilePendingMessageCursor.store (

Re: Close message listener decoupled

One other problem with the implementation: you provided a MessageListener of your own definition, which doesn't do anything, which means your consumer has no way to get the messages. A better alternative would be to have your register method take the MessageListener object (of the consumer's

Re: JAVA ActiveMQ JMX browse messages on Topic

that that thread's OP does when trying that approach. Tim On Aug 18, 2017 8:01 PM, "Tim Bain" <tb...@alumni.duke.edu> wrote: > You can browse queues, but not topics. > > Tim > > On Aug 18, 2017 12:15 PM, "Hitesh" <hitesh.hotchand...@contentsphere.com> >

Re: JAVA ActiveMQ JMX browse messages on Topic

You can browse queues, but not topics. Tim On Aug 18, 2017 12:15 PM, "Hitesh" wrote: > Hi all, > > The following question is for ActiveMQ 5.13. > > I have 2 durable subscribers listening to a topic, lets say ExampleTopic. > I need to delete all the

Re: Temp Store is Full - False Positive?

By "persistent store," did you really mean "temp store"? If what you gave is the persistent store (LevelDB, according to your other post), that wasn't what I was asking for, and I meant the size of the KahaDB-backed temp store. On Aug 18, 2017 7:09 AM, "khandelwalanuj"

Re: Delete/Purge Topic

On Aug 17, 2017 7:39 AM, "meghaauti" wrote: Hi I am sorry there was a mistake in the previous question Using jolokia api I am able to delete a topic but when topic(with the same name that was deleted) is again created somehow subscribers are not getting registered. Do

Re: Temp Store is Full - False Positive?

When this happens, how much disk space is used for KahaDB data files for the temp store? And what temp store limit are you using? Tim On Aug 16, 2017 1:29 AM, "khandelwalanuj" wrote: > Hi, > > We have also faced the same issue with ActiveMQv5.14.5 recently

Re: Interaction APIs with Standalone ActiveMQ

On Aug 14, 2017 7:22 AM, "Juleian" wrote: Hello, I am new to ActiveMQ and try to figure out how to implement certain interactions with the service. I want to use ActiveMQ to implement a JMS service. By now the classic consumer producer is running. However, I want to find

Re: ActiveMQ Master / Slave Fall Back Master

There's nothing built-in to do this. On Aug 14, 2017 10:31 AM, "mtod" wrote: > 5.x ActiveMQ > > > > -- > View this message in context: http://activemq.2283324.n4. > nabble.com/ActiveMQ-Master-Slave-Fall-Back-Master-tp4729663p4729668.html > Sent from the ActiveMQ - User mailing

Re: Network of brokers and destination policies

t; > Anyway, you answered my question, I think: if we have destination policies > in broker 1 to prevent that problem, we need a similar destination policy > in broker 3. > > Thanks again for the help. > > > > On Thu, Aug 10, 2017 at 11:00 PM, Tim Bain <tb...@alumni.d

Re: ActiveMq composite queues

Yes, as long as you can actually make the connection (i.e. the IP is routeable, firewalls don't block traffic, etc.) and you configure the network connector properly. Network connectors allow messages to be passed among brokers within a Network of Brokers, no matter where the brokers are hosted.

Re: How to execute purge operation on topic?

Compare http://activemq.apache.org/maven/5.12.2/apidocs/org/apache/activemq/broker/jmx/TopicViewMBean.html with http://activemq.apache.org/maven/5.12.2/apidocs/org/apache/activemq/broker/jmx/QueueViewMBean.html. There is no purge() method for topics, so what you're requesting can't be done,

Re: Network of brokers and destination policies

What resources are you concerned about? Are you trying to load-balance the work across the two applications (i.e. you're concerned about CPU and about pre-allocating messages to a particular application), or are you worried about running out of space in the brokers' message stores? Or something

Re: Delete/Purge Topic

I don't understand what you're saying is wrong, so I'm not sure how to help. On Aug 10, 2017 10:14 AM, "meghaauti" wrote: Hi Using the REST API I already posted, able to delete the topic Now the problem is, when again start our code, producer and subscribers are created but

Re: JRE 9 Support

Thanks for sharing that info, including the fact that LevelDB (which is deprecated within ActiveMQ) was the specific source of the dependency. Tim On Aug 9, 2017 12:20 AM, "mprakash" wrote: > When we ran jdeps on activemq-5.15.0 jar, we saw that there were > dependencies

Re: Re: how is topic implemented?

It doesn't use temporary queues. Rather, each consumer results in a TopicSubscription being created, and each message sent to the topic has a reference handed to

Re: JRE 9 Support

Also, can you describe how you determined that there was such a dependency? On Tue, Aug 8, 2017 at 7:28 AM, Justin Bertram wrote: > Are you talking about the ActiveMQ 5.x broker or the ActiveMQ Artemis > broker? > > > Justin > > On Tue, Aug 8, 2017 at 6:04 AM, mprakash

Re: Queue Consumers have pending messages but they are not getting processed

That explanation sounds plausible. One possible alternative would be to use the PooledConnectionFactory instead. To clear out the unwanted consumers with your current code, you'd need to restart whatever process they're running in. But of course they will probably come back eventually. Tim On

Re: Does ActiveMQQueueBrowser let us access prefetched messages as well?

ActiveMQQueueBrowser returns only messages that are not pending, and I'm not aware of any other way to browse the pending ones. However, because the pending messages are still on the broker, it would be possible for you to write custom code that browses the pending messages, and if you do a good

Re: How can I speed up read message from queue

One possible reason is that with a consumer reading messages as they are published, it's sometimes possible for the consumer to consume and ack the message before it's written to the persistent store, which eliminates the need to write it at all and eliminates the need to read it from the

Re: [Fixed] Programatically setting up a proxying broker

activemq-artemis/pull/1293 On Fri, Aug 4, 2017 at 9:08 AM, Tim Bain <tb...@alumni.duke.edu> wrote: > Clebert, which feature were you referring to? > > On Aug 3, 2017 9:44 PM, "Clebert Suconic" <clebert.suco...@gmail.com> wrote: > >> There is a pending pull reque

<    3   4   5   6   7   8   9   10   11   12   >