Re: Consumer throttling

klog and > protect the broker regardless of the reason for message accumulation, > whether that is slow consumers, throttled consumption or consumers > being down for some reason. Having prefetch limit of 1 is good > suggestion though, thanks. > > > > On 30 January 2016 at 21

Re: Messages dequeued but not consumed

You can use JConsole to browse the JMX beans to see which consumers are connected to your queue, which may help you figure out if you do have multiple consumers. The web console will show you some of that information, but there's far more info in the JMX beans so I'd strongly recommend using JCons

Re: How fileCursor works? AMQ5.9.1

Which messages do you lose when the topic becomes full? Does the broker discard the just-received message or the earliest non-dispatched message? On Feb 10, 2016 3:54 AM, "Gary Tully" wrote: > any chance persistent=false is set on the broker? post your full xml config > and peek at the unit test

Re: Standalone ActiveMQ address settings

"Currently my DLQ and Expirery Queue are not working correctly." We can only help you fix the problem if you tell us what the problem is... On Feb 9, 2016 10:58 AM, "mhemple" wrote: > Okay I see I was looking at an at an ActiveMQ/Artimus guide. I guess that > wont work. What I'm trying to do i

Re: Unable to consume all messages from the existing connection

If you have a reference to an existing Connection and you want to reuse it, just use that instead of calling connectionFactory.createConnection() to create a new connection (as stated right in the method name). Nothing requires you to create a new Connection if you already have one that will meet

Re: Messages dequeued but not consumed

My suggestion to use JConsole to see if you have (only) the consumers you expect and my question about whether messages might be expiring both still stand. Tim On Feb 10, 2016 1:23 PM, "mhemple" wrote: > I added more ActiveMQ configuration information. Please let me know if I > am > missing som

Re: Messages dequeued but not consumed

What message type are you using? Only ActiveMQObjectMessages ( http://activemq.apache.org/maven/apidocs/org/apache/activemq/command/ActiveMQObjectMessage.html) would use serialization, so if that's what you're using then try sending an ActiveMQTextMessage instead and see if it makes it through. A

Re: Messages dequeued but not consumed

I don't know the HornetQ code to know if there are differences (maybe someone from the Artemis side knows the answer), though I'd expect them to be very similar. That does sound like serialization is part of the problem, though I'd expect to see errors (or at least DEBUGs, if you change the Log4J

Re: Messages dequeued but not consumed

Yep, if getObject() throws an exception, that explains what you're seeing, so now it's just a matter of figuring out what's causing the exception. I'd check that there is only one copy of your class on the classpath, and that it's the same class definition on both the producer and the consumer. get

Re: java.lang.OutOfMemoryError: GC overhead limit exceeded

First, for a question about GC problems, you should probably tell us what GC strategy you're using, and why you chose it. Second, you made the claim that "to increase the memory to 2Gb ... only delaying the issue from happening," which implies that you believe you're running out of memory because

Re: Messages dequeued but not consumed

Happy to help, and sorry I didn't think of that recent change as a likely explanation. You should understand that the command line option you quoted is a security vulnerability that you've explicitly opened in your own broker, which can allow a malicious user to execute code on your system. The r

Re: Messages dequeued but not consumed

OK, I'll create an enhancement request for it. Thanks for confirming. Tim On Feb 12, 2016 12:58 PM, "mhemple" wrote: > Yes I do understand. I already switched to a white list. > > No. when I start the broker (with everything white listed) there are no > warnings about the security vulnerabilit

Re: Messages dequeued but not consumed

I think the issue has been resolved by whitelisting the classes that will be deserialized as part of the ActiveMQObjectMessage, and the remaining issue (for which I'll submit an enhancement request) is that we should look for wide-open wildcards (i.e. "*" by itself as an element in the list) and wa

Re: Reliable, persistent, scheduled or delayed queue processing in cluster

I don't believe the JMS spec provides a mechanism for guaranteed once-and-only-once delivery, nor how you'd provide such a guarantee in any system. Consider what happens when you're in the middle of processing message A when the consuming process crashes. A hasn't been acknowledged as successfull

Re: resend ：how to config the max number of message that activemq keeped

The section of http://activemq.apache.org/slow-consumer-handling.html about ConstantPendingMessageLimitStrategy says "This strategy uses a constant limit for all consumers (above their prefetch size)". What is your consumer's prefetch size? On Feb 2, 2016 6:03 PM, "wuwufen" <1767549...@qq.com> wro

Re: Destination wildcards or consumer selectors – advice needed

If n was large enough and your message volume was large enough, the overhead of evaluating the selectors against each message might be a disadvantage to using selectors, but your description makes it sound like those numbers are small enough that that's not a concern. So I agree that you should us

Re: ActiveMQ InactivityMonitor Weird Issue

The log line says that it's been very little time since we sent the previous message, so if you're seeing it many times in a row it means you're sending lots of messages in rapid succession. Which will probably result in high network utilization. Why are you running Log4J at DEBUG? You should ru

Re: Exception encounter ActiveMQ with Replicated LevelDB

I can't help you (I've never used LevelDB) and this list doesn't have a resident LevelDB expert, but this sounds like a real bug so please submit a bug in JIRA if you haven't already. Can you reliably reproduce the problem? On Jan 31, 2016 11:33 PM, "Sunil Vishwanath" wrote: > Hello, > I am ve

Re: Announcement mailing list?

Announcement messages to the users group have subjects that begin with "[ANNOUNCE]", so you could filter down to only the announcements if you wanted. On Feb 8, 2016 7:50 AM, "Christopher Shannon" < christopher.l.shan...@gmail.com> wrote: > There isn't a specific announcement mailing list. Announ

Re: Failover very slow with kahadb while restart of master is fast

You could use a profiler such as JVisualVM to tell you what work is being done. You could get some of that information from thread dumps via jstack, but I think a profiler would give much more useful and detailed information for less effort. Tim On Feb 15, 2016 5:37 AM, "Jean-Baptiste Onofré" wr

Re: Queue hanging with n to n network of brokers

After you get into a "hung" state, if you restart all brokers does everything work correctly? In other words, is the problem with the dynamic refresh of the configuration, or is the configuration itself the problem? When you're in the "hung" state on a particular broker, how many consumers do you

Re: Exception encounter ActiveMQ with Replicated LevelDB

quirement > to duplicate the bug. > > > On Feb 13, 2016, at 12:50 PM, Tim Bain wrote: > > > > I can't help you (I've never used LevelDB) and this list doesn't have a > > resident LevelDB expert, but this sounds like a real bug so please > submit a >

Re: How spool messages to disk when using Non-Durable Topics?

We're aware of your existing thread on this subject. Don't start duplicate threads just because you haven't gotten an answer yet. On Feb 15, 2016 11:05 AM, "fengcanyue" <153133...@qq.com> wrote: > http://activemq.apache.org/slow-consumers.html > here write: > Non-durable topics are the scenario w

Re: Identify ActiveMQ asyncrhonous message failures?

Remember that you can always call a private or protected method (or field) via reflection. You pay a price in terms of both performance and maintainability, but neither price is so high that you shouldn't at least consider the option if you don't have a better one. On Feb 19, 2016 9:16 AM, "Timoth

Re: Destination wildcards or consumer selectors – advice needed

Why does performance scale exponentially as consumers increase? The need to iterate over a larger list for each message should result in linear, not exponential, growth. Tim On Feb 20, 2016 9:12 PM, "artnaseef" wrote: > For the consumer-specific messages, why not use a queue for each? That > s

Re: Help with a Failover testing that shows missing messages

Were you missing those messages for all topic consumers, or only for one but not the other three? What ack mode does your Camel route use? What would it do if the broker was unavailable when it came time to publish to the topic? Tim On Feb 21, 2016 7:39 PM, "mtod" wrote: > I setup a fail-over

Re: Rfresh org.apache.activemq.broker.SslContext from disk/jks content

You may get a better response about whether anyone plans to work on this from the dev mailing list. But there's a good chance that no one has plans to implement the feature, but if you felt like implementing it yourself and contributing the code we'd gladly take the contribution (and from that poi

Re: Help with a Failover testing that shows missing messages

In your route you're only catching org.apache.camel.ValidationException; what would happen if some other exception was thrown? Also, I assume you've already checked the DLQ and your invalid.schema queue and the missing messages aren't in either place? Can you correlate the times the messages are

Re: No performance improvement using PooledConnectionFactory (AMQ 5.12.1).

It's also possible that 8 isn't the optimal pool size for your test driver, and that a different (presumably larger) value would give better throughput. Tuning the pool size of any pooling technology (ActiveMQ, JDBC, etc.) is an iterative and experimental process, and your first guess often won't

Re: Message processed in wrong order

Are the messages persistent? If not, maybe async sends ( http://activemq.apache.org/async-sends.html) are allowing messages to be sent in parallel on separate threads. Does the behavior change if you make your from endpoint transacted (?transacted=true), which forces synchronous sends by producer

RE: Daily Message Count - HELP

Until https://issues.apache.org/jira/browse/AMQ-3978 is implemented, the KahaDB fragmentation issue won't be fixed. On Feb 27, 2016 12:18 AM, "artnaseef" wrote: > So, slow consumption is a major anti-pattern for ActiveMQ. > > By definition, a queue with no consumers and with messages stored has a

Re: activemq consumer does not return data even when queue not empty

Are you hitting your catch block? Add logging before you re-throw to find out. Also, a thread dump could help determine if you're stuck in a blocking call or bombing out early, though it won't tell you why you bombed out (that's what the logging in the catch block is for). What are the queue sta

Re: Slave health check

What do you mean by "slave is ... listening to master"? It's my understanding that the slave doesn't connect to the master, it only watches a lock file on a shared filesystem. I believe the slave's webconsole should be up and responding, though I've never run a master/slave configuration myself s

Re: Recommendation for vendor independent strategy

I'm not aware of a plan to implement JMS 2.0 in ActiveMQ 5.x. I believe Artemis implements JMS 2.0, but you'd have to convince your potential customer to switch to it and it's not a simple drop-in replacement so they might not be willing to do that just to use your "thingy." I'm not aware of anyo

Re: Production ConnectionFactory configuration with Spring

I'd say using a PooledConnectionFactory is a far more common configuration in production environments than using SingleConnectionFactory. Allowing each application to use anywhere from 0 to M (pool size) connections based on its current load sounds better than having N apps using 1 connection each

Re: Help with a Failover testing that shows missing messages

Also, can you shut off the chaos monkey script and confirm that they really aren't related? Knowing that answer will limit the problem space so we don't waste time on things that aren't relevant. What do the enqueue and dequeue counts on both destinations tell you? Are all N messages getting enq

Re: question for users of NFS master/slave setups

Are you sure that the code will ensure a graceful and speedy shutdown when the broker loses a lock but stays up? Last time I looked at this (admittedly, not in all that much detail, and I've meant to make time for that ever since and haven't done so), I came away with the impression that the locki

Re: question for users of NFS master/slave setups

That's better than the impression I'd gotten last time I investigated the question. Do you get more useful information at DEBUG? And do you get the same behavior if you wait to start 2c till 2a is fully up? On Mon, Feb 29, 2016 at 7:08 PM, artnaseef wrote: > Something sounds very wrong there.

Re: ActiveMQ not starting

Asking the obvious question: do all of the paths in that command exist? If not, which ones don't? In particular, does /home/nico/activemq/apache-activemq-5.13.1//../lib/ exist? (Check them all, but that one in particular looks fishy.) On Mar 1, 2016 1:26 AM, "OrangeJuice" wrote: > I've tried s

Re: ActiveMQ not starting

Look in the start script to determine how that path is built. On Mar 1, 2016 8:19 AM, "OrangeJuice" wrote: > I've just checked the paths. The ../lib/ one indeed doesn't exist, as that > one would be outside the folder where I extracted ActiveMQ to. > I've tried copying the lib folder to that path

Re: question for users of NFS master/slave setups

Another possibility: the paths that each broker uses to reach the lock file don't resolve to the same file in NFS. On Mar 1, 2016 8:29 AM, "artnaseef" wrote: > So something is very wrong then. NFS should *not* allow two NFS clients to > obtain the same lock. > > Three possible explanations come

Re: 5.13.1 message blocked

Tell us more about "they're no longer communicating to each other." In a JMX viewer, for a particular queue (pick one, doesn't matter which) on each broker, which consumers are present on that queue before and after the restart? Also, what's in the logs of the brokers immediately before, during,

Re: Help with a Failover testing that shows missing messages

Excellent catch, Art. On Mar 1, 2016 8:38 AM, "artnaseef" wrote: > I missed something critical here - Topics. > > Topic flow across a network of brokers with non-durable subscriptions only > is not reliable. Brokers subscribe to one-another in the same manner that > end-clients subscribe to a br

Re: Help with a Failover testing that shows missing messages

Did you read Art's post where he suggested that your problem is that you're breaking the network connection between brokers with non-durable topic subscriptions, which is expected to lose messages? To test the theory, temporarily change your consumers to use durable subscriptions and see if the me

Re: Help with a Failover testing that shows missing messages

You can quickly test that by inspecting the subscription via JMX on the broker; it'll have a flag that tells you whether it's durable. If not, submit a bug in JIRA. On Mar 1, 2016 8:08 PM, "mtod" wrote: > Sorry yes I did read his post. > > I was already using a durable subscription. > > C# code.

Re: Help with a Failover testing that shows missing messages

gaps, your problem is in Camel, and if not then it's in ActiveMQ. On Mar 1, 2016 9:44 PM, "Tim Bain" wrote: > You can quickly test that by inspecting the subscription via JMX on the > broker; it'll have a flag that tells you whether it's durable. If not, > subm

Re: Embedded Broker Monitoring

Those web interfaces are hosted in Jetty, so you'll need to embed it as well. I've never done that, but there appear to be instructions here: http://www.eclipse.org/jetty/documentation/current/embedded-examples.html On Mar 1, 2016 9:38 AM, "Pat0675" wrote: > Hi, > > in my application (its a stan

Re: Embedded Broker Monitoring

Oh, and you can do JMX monitoring of multiple brokers per JVM as long as you configure unique ports. On Mar 2, 2016 8:13 AM, "Tim Bain" wrote: > Those web interfaces are hosted in Jetty, so you'll need to embed it as > well. I've never done that, but there appear to be

Re: Configuration Questions

1. The more typical client-server architecture is to have clients connect directly to the hub broker, but there are valid reasons for using a client-side broker in a hub-and-spoke topology. Slow or unstable network connections are the typical reasons I'm aware of; is that why you've chosen to use

Re: identify the topic basing on message content

You can use an embedded Camel route to consume messages from an input queue and publish them to the topic to which you want the message published. Camel also allows you to transform the body of the message, eliminating any portions you no longer need if they were present only for routing to the rig

Re: sendfailifnospaceaftertimeout

I believe it applies to any usage limit you set, not specifically the storeUsage one in the context of KahaDB. This example shows its use against the memory store: http://sensatic.net/activemq/activemq-producer-flow-control-with-timeout.html On Wed, Mar 2, 2016 at 7:42 AM, mikigur wrote: > hi i

Re: Unable to start fileserver webapp

Would you be willing to submit a bug in JIRA for this? Tim On Mar 4, 2016 6:36 AM, "Nicolas V." wrote: > Ok, so I nearly found the issue. > > I tried a lot of release to find when did the fileserver stop working. > > My procedure : > - Download a windows .zip release archive. > - Extract this fi

Re: Unable to start fileserver webapp

Great, thank you for doing that! On Mar 4, 2016 7:15 AM, "Nicolas V." wrote: > Yes I can, it is done : https://issues.apache.org/jira/browse/AMQ-6195 > > Best regards. > > > > -- > View this message in context: > http://activemq.2283324.n4.nabble.com/Unable-to-start-fileserver-webapp-tp4708873p47

Re: ActiveMQ duplex network connector dead lock [5.13.1, 5.11.1]

You can use two non-duplex connections, one from each broker. This is advantageous in some network configurations (e.g a pair of brokers) because it lets you reuse the same configuration on multiple brokers (with a little placeholder substitution) and disadvantageous in others (e.g. a hub-and-spok

Re: ActiveMQ duplex network connector dead lock [5.13.1, 5.11.1]

You have to do what you described, and attempt to connect to all the client brokers from the hub, which means you have to list them all out up front and then live with the log messages when the hub can't connect to a spoke broker because the spoke is offline. That's the more-complicated configurat

Re: activemq with leveldb is not stable on hp-unix

Unless you have a stack trace indicating that ActiveMQ called a native method that led to this seg fault (which is the only way we might possibly be involved or able to help), this appears to be a problem between Oracle (maker of the HotSpot JVM) and HP (maker of the OS), so you'll want to pursue t

Re: Failed network connector can not be re-established

"JDBC Failure: Borrow prepareStatement from pool failed" Your problem is in the JDBC store (specifically the connection pool), whose configuration you didn't post or tell us anything about. One possible workaround would be to simply tell the DataSource to not pool prepared statements via https://

Re: Queue hanging with n to n network of brokers

It sounds like you've found a bug. Please submit a bug report in JIRA, including config files and test steps required to reproduce the problem. Please reduce the config files to the smallest form that still reproduces the problem; eliminate anything that's not required, to make it easier for whoev

Re: Queue hanging with n to n network of brokers

connected to before, during, and after you restart the broker that causes the problem. Tim On Mar 9, 2016 7:37 AM, "Tim Bain" wrote: > It sounds like you've found a bug. Please submit a bug report in JIRA, > including config files and test steps required to reproduce the pro

Re: Failed network connector can not be re-established

I've never run ActiveMQ with the JDBC persistence store, so I can't answer that question directly, and I don't get the sense that most of the people on this mailing list have either, so you may not be able to answer that question other than by trying it. With that being said, I wouldn't expect it

Re: ActiveMQ / JMS “losing” messages - what am I missing?

Use a JMX viewer to look at the stats for the queue; how many enqueues and dequeues do you see? How many consumers are there? On Wed, Mar 9, 2016 at 1:11 PM, swift99 wrote: > What am I missing? > > This is cross-posted from > > http://stackoverflow.com/questions/35896002/activemq-jms-losing-mes

Re: ActiveMQ / JMS “losing” messages - what am I missing?

You got some, not all, of what JMX would have told you. But it's enough. DEBUG org.apache.activemq.broker.region.Queue - queue://Stuff via SQL.401, subscriptions=2, memory=0%, size=2, pending=0 toPageIn: 1, Inflight: 1, pagedInMessages.size 1, pagedInPendingDispatch.size 0, enqueueCount: 2, deque

Re: java deserialization vulnerability details for activemq

Is there a blacklist somewhere of known gadgets (JAR/version plus specific classes) so developers can check that they're not whitelisting known gadgets? Most developers aren't intimately versed in what classes are exploitable, and most aren't going to take the time to search if it's not easy, so ha

Re: Failed network connector can not be re-established

I think the current behavior of stopping the networkConnector when it will be impossible for it to do any work (because we can't write to the persistent store) is the right behavior; having a zombie networkConnector hanging around just hoping for the store to become available sounds like an awful o

Re: ActiveMQ-CPP Exception connecting to broker

I thought TIME_WAIT was the state after the application had closed the socket but before the OS had disposed it, so this may be a Solaris question. On Mar 11, 2016 4:55 AM, "spamtrap" wrote: > On Thu, 10 Mar 2016 16:13:32 +, "James A. Robinson" > wrote: > > It happens infrequently and unpred

Re: Get transport connector for connectionId

If memory serves, you can see a subscription's connector by examining the subscription via JMX. I don't currently have s broker I can try that out on, but poke around with a JMX viewer such as JConsole and I think you'll find it. On Mar 10, 2016 10:10 AM, "bimsimsala" wrote: > Hi all, > > i'm tr

Re: Message not redirected to DLQ when exception thrown by MDB

What acknowledgement mode are you using? If it's AUTO_ACK, I'd expect that you've already acknowledged the message when the exception is thrown, which would make this expected behavior, but I'd expect you could use a different ack mode to get the behavior you want. On Mar 11, 2016 7:27 AM, "THMayr

Re: ActiveMQ / JMS “losing” messages - what am I missing?

With only one consumer, do all messages now get consumed? Is there anything we can explain to help with using JMX in the future? On Mar 11, 2016 8:46 AM, "swift99" wrote: > Thank you Tim, > > In the Receiver Setup code, note that the beforeStep() method is annotated > with @BeforeStep. I think t

Re: Message not redirected to DLQ when exception thrown by MDB

I've never used MDBs, but I would expect DUPS_OK_ACKNOWLEDGE mode to use CLIENT_ACKNOWLEDGE mode under the covers. You could test that by setting a breakpoint in your MDB's body (before whatever throws the exception) and checking that the dequeue count doesn't increase until you resume. You could

Re: Failed network connector can not be re-established

Other possibilities are a bug in ActiveMQ code where we fail to close() our PreparedStatements in certain cases, and a bug in the connection pool. On Mar 12, 2016 11:13 PM, "artnaseef" wrote: > Any idea what is causing "Borrow prepareStatement from pool failed"? > > The only possible cause coming

Re: Failed network connector can not be re-established

Art, it's always been my understanding that static TCP transports would reconnect when used as a networkConnector, and that the only reason to use failover is if you have multiple brokers. Is that not accurate? On Mar 12, 2016 11:17 PM, "artnaseef" wrote: > Ahh, here it is from the original post

Re: ActiveMQ duplex network connector dead lock [5.13.1, 5.11.1]

As Art said, the typical configuration is to have one standalone broker that all clients (producers and consumers) connect to, that is available even when the clients are not. This won't work if the clients frequently are up but don't have network connectivity, or if no one is willing to host and

Re: Sending multiple files in a single message into messaging queue

How about using an archive (tar, zip, 7z, etc.) to turn many files into one? On Mar 18, 2016 8:04 AM, "Subbu" wrote: > Hi, > > > As part of requirement i need to send multiple files in a single message > into messaging queue. > > Please help to suggest me if any way to achieve using blobmessage o

Re: ActiveMQ Queue TTL

activemq.apache.org/stomp.html specifically in > *"Stomp extensions for JMS message semantics"* > > BR > > Shahbour > > On Fri, Mar 18, 2016 at 1:21 PM Tim Bain [via ActiveMQ] < > ml-node+s2283324n4709675...@n4.nabble.com> wrote: > > > I thought (assume

Re: Configuring Virtual Destinations via Jolokia REST Api in ActiveMQ 5.13.2

In non-embedded Camel, it's possible to define routes at runtime via the Java API; see for example http://nigap.blogspot.com/2012/02/camel-create-routes-dynamically.html?m=1 I'm not sure if it would work for an embedded Camel context, but it might. Tim On Mar 17, 2016 5:45 PM, "Quinn Stevenson"

Re: NFS v4 locks "given up" w/o any logging?

I'd say it's more likely that either 1) NFS gave away the lock when it shouldn't have, or 2) network conditions were such that your master lost connectivity and NFS rightly allowed the slave to take it. In either case, useful logging could only come from your NFS server. Separately from the quest

Re: Exception in createSesson() inside an EJB user transaction

I see java.lang.AbstractMethodError: org.apache.activemq.ra.ManagedConnectionProxy.createSession()Ljavax/jms/Session; in the logs, which implies that the version of that class at runtime is different than what you compiled against. (source: http://stackoverflow.com/questions/17969365/why-i-am-getti

Re: ActiveMQ Queue TTL

n.html > > On 03/18/2016 12:38 AM, Tim Bain wrote: > >> Time to live must be set by the producer; I'm not aware of a built-in way >> to set it from the broker. The one thing you might be able to do is use >> an >> embedded Camel route to set that attribute o

Re: ActiveMQ Queue TTL

Time to live must be set by the producer; I'm not aware of a built-in way to set it from the broker. The one thing you might be able to do is use an embedded Camel route to set that attribute on each message as they are received by the broker, but I've never tried that so I can't promise it'll wor

Re: Unable to set Jetty httpClient option

This looks like a question for the Camel mailing list. On Mar 17, 2016 7:47 AM, "mluckam" wrote: > I am attempting to set my own httpClient in the url of the camel producer > but > it does not appear to be taking effect. Looking at the JettyHttpComponent > it appears that the endpoint options be

Re: ActiveMQ Queue TTL

6:53 AM, "shahbour" wrote: > Thanks i intercepted the message and added an expires header to the STOMP , > ActiveMQ stomp doesn't support ttl right ? > > On Fri, Mar 18, 2016 at 4:38 AM Tim Bain [via ActiveMQ] < > ml-node+s2283324n4709663...@n4.nabble.com> wrot

Re: Message not redirected to DLQ when exception thrown by MDB

Sorry if you've said this already (it rings a bell but I couldn't find it when I scanned this thread), but why is the AuthorizationInterceptor saying that your onMessage() method is disallowed? EJB Invocation failed on component TestMessageBeanLow for method public void de.adesso.tma.test.ejb. ic

Re: How to test prefetch size is actually working

You're misunderstanding what the prefetch size is. It doesn't mean the broker dispatches messages in groups of N, it means that the broker dispatches messages individually until there are N outstanding, and when a message is acknowledged then another individual message will be dispatched to get ba

Re: Proposal: ability to install features in different regions in single command

Isn't this a question for the Karaf mailing list? https://karaf.apache.org/index/community/mailing-lists.html On Mar 21, 2016 3:33 AM, "Владимир Коньков" wrote: > Hi there! > > Use case: > > Environment: clean Karaf 4.x instance. > > Requirements: > > Multiple software modules should be install a

Re: How to test prefetch size is actually working

I believe that's correct, though I've never tried it myself so I don't have firsthand knowledge. On Mar 21, 2016 8:12 AM, "Raffi" wrote: > Tim, > > Wow, thank you; my assumption was totally wrong. > > On the flip side, to ensure my understand of optimizedAcknowlege="true" > isn't wrong either, do

Re: Error getting Queue size

Topics aren't queues, they're topics. Try casting to Topic instead (though you won't be able to browse it, because you can only browse queues). On Mar 21, 2016 10:01 AM, "Ravi1978" wrote: > Hi > > We are upgraded ActiveMQ 5.6 to 5.12.2. We are defining a queue > (destination > type as "Topic") a

Re: 'AllowLinkStealing' does not work for TCP transport with leveldb persistent store

Rob's comment on https://issues.apache.org/jira/plugins/servlet/mobile#issue/AMQ-4719 shows it being set via a URI parameter; can you see if it works when specified that way? On Mar 22, 2016 9:33 AM, "khandelwalanuj" wrote: > Hi, > > Broker config is attached in last update. > > I have also verif

Re: Error getting Queue size

Is there a reason why you're not doing what the error message implies and changing your code to cast to (and therefore use) org.apache.activemq.broker.region.virtual.MappedQueueFilter instead of Queue? That seems like the obvious answer, unless there's more to your question than what you've asked.

Re: Exception in createSesson() inside an EJB user transaction

Here's part of the stack trace: "at de.adesso.tma.test.ejb.TestMessageBean.onMessage(TestMessageBean.java:212)" Can you tell us what is at line 212 and the types of any objects referenced in it (including packages)? I'd also try to figure out what version of org.apache.activemq.ra.ManagedConnecti

Re: external ActiveMQ 5.13.2 + WildFly 9.0.2

The best way to create a queue is to subscribe to it or to publish a message to it. The broker will create the queue automatically when either of those two things happen. On Mar 17, 2016 12:24 PM, "zappee" wrote: > Hi, > > I am preparing my first ActiveMQ environment with WildFly App Server. > I

Re: Exception in createSesson() inside an EJB user transaction

It looks like you're compiling against JMS 2.0, but ActiveMQ only implements JMS 1.1. Here is the 1.1 version of the Connection interface: http://grepcode.com/file/repository.springsource.com/javax.jms/com.springsource.javax.jms/1.1.0/javax/jms/Connection.java#Connection. Notice that the only crea

Re: 'AllowLinkStealing' does not work for TCP transport with leveldb persistent store

Tim, is it expected that it would only work as a URI parameter and that we would ignore the value if it's set on the transportConnector in XML? That feels like a bug to me; is there something I'm overlooking? Tim On Wed, Mar 23, 2016 at 9:48 AM, Timothy Bish wrote: > On 03/23/2016 02:45 AM, kh

Re: Active MQ - OutOfMemory in JbossFuse 6.2 context

What are your systemLimits, especially your storeUsage and memoryUsage? Why is producerFlowControl="false"? The sole purpose of PFC is to prevent the broker from OOMing when given more messages than it can store; you should have this on. What are the units for the number 4 that you quoted?

Re: Active MQ - OutOfMemory in JbossFuse 6.2 context

Also, are you seeing the first error (involving PooledConnectionFactory) on the broker or on the client? On Mar 25, 2016 9:18 PM, "Tim Bain" wrote: > What are your systemLimits, especially your storeUsage and memoryUsage? > > Why is producerFlowControl="false"?

Re: ActiveMQ hangs and i don't understand why

Keep in mind that large numbers unconsumed messages stuck in the DLQ count as a slow consumer and will use broker memory. Is Producer Flow Control enabled? If so, what limits are you using? What's your heap size? And how much of it is being used right after the broker restarts? On Mar 27, 2016

Re: ActiveMQ with KahaDB as persistent store becomes very slow (almost unresponsive) after creating large no (25000+) of Topics

AbstractRegion.lookup()

Re: Activemq HA without shared Database or Shared file system

There used to be a share-nothing master-slave configuration but it was buggy and never worked right and has since been removed. Replicated LevelDB is the only option that doesn't have a singleton resource, though you could make the argument that the Zookeeper cluster is a singleton resource spread

Re: Is there a way to be notified when a durable subscriber receives a MQTT message?

Just to highlight something that might or might not already be obvious: the message consumed advisories are triggered when the message is acknowledged, which might happen before or after the consumer actually processes the message, depending on your ack mode. On Apr 1, 2016 5:12 AM, "Christopher Sh

Re: Reloading users and groups properties on change

Yes, file a JIRA, and attach a minimal configuration to reproduce the problem. BTW, from what you describe, I'd expect that this would happen for any client (including a tiny Java test app you could write), which would take Nagios out of the equation. Can you confirm that that's the case? Once y

Re: Measures to improve the throughput

I think he's using European-style formatting, and that those numbers are forty-five thousand, ninety thousand, etc. Those numbers sound great to me; I was always getting numbers in the order of magnitude of 1000 like Quinn said, even though I expected to go faster since we only did non-persistent

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