Re: ActiveMQ JMS consumer unduly checking msg expiration and ignoring msgs? (issue with consumer clock ahead of broker clock NOT solvable via TimeStampingBrokerPlugin)

2014-10-22 Thread Fred Moore
. I'll leave the specifics of the questions to someone familiar with the code. Robbie On 21 October 2014 16:14, Fred Moore fred.moor...@gmail.com wrote: Hi folks, I found a situation where the handling of timestamps/expirations by ActiveMQ 5.10 appears not to be correct

Re: ActiveMQ JMS consumer unduly checking msg expiration and ignoring msgs? (issue with consumer clock ahead of broker clock NOT solvable via TimeStampingBrokerPlugin)

2014-10-22 Thread Fred Moore
a moment to make a test and patch even better. something like jms.consumerExiryCheck=false (and leave the default as is (true) The ActiveMQ .NET client has this option to solve similar complaints, so you can look there for inspiration. On 22 October 2014 12:04, Fred Moore fred.moor...@gmail.com

ActiveMQ JMS consumer unduly checking msg expiration and ignoring msgs? (issue with consumer clock ahead of broker clock NOT solvable via TimeStampingBrokerPlugin)

2014-10-21 Thread Fred Moore
Hi folks, I found a situation where the handling of timestamps/expirations by ActiveMQ 5.10 appears not to be correct, and unfortunately -- being this a consumer side issue -- it does not appear to be solvable via classic TimeStampingBrokerPlugin tweaks. Scenario: S1\ Broker B1 runs on HOST1

War stories plus Hints Tips wanted for ActiveMQ in a JBoss clustering context

2011-06-07 Thread Fred Moore
Hi folks, I need to design an ActiveMQ deploy in a JBoss clustered environment, where ActiveMQ MUST NOT be the weakest link in the chain, in terms of high availability provided to the [clustered] critical MDBs. Can anyone provide any war stories and hints tips on this particular scenario?

Fwd: Can I use Active MQ in this Regard?

2011-04-10 Thread Fred Moore
...my 2 cent worth: 1\ Messages can be processed transactionally (similarly to ACID database transactions, minus the I: no isolation is guaranteed, but no isolation is required; e.g. think about fast paralled message consumption by independedent consumer applications under independent units of

How to subscribe to multiple topics not having an underlying naming convention (e.g. same prefix or suffix)?

2011-03-01 Thread Fred Moore
Hi folks, is there a way to subscribe to multiple topics that do *not* have a naming convention (e.g. same prefix or suffix) allowing the use of wildcards? For example: STOCK.ACME + DEALS.NYC Cheers, F.

Re: Working C example?

2010-06-08 Thread Fred Moore
Hi bcmoney, did you eventually manage to have your C app running w/openwire? ...we are about to try something similar and are currently looking for hints gotchas. Cheers, F. On Tue, Jun 1, 2010 at 1:11 PM, bcmoney bryan.copel...@nrc.ca wrote: We have a need to control a legacy application

Re: How to run ActiveMQ on z/OS in EBCDIC without setting default file.encoding=ISO8859-1?

2010-03-26 Thread Fred Moore
:56, Fred Moore fred.moor...@gmail.com wrote: Gary, All, with your hints we made some progress on this by creating an java explicit broker configuration (available here http://pastebin.com/7rJjV93r, see BrokerInit()) that we believe is equivalent to the original activemq.xml (available

Re: How to run ActiveMQ on z/OS in EBCDIC without setting default file.encoding=ISO8859-1?

2010-03-19 Thread Fred Moore
text, it will be binary data which should avoid encoding, no? Have a go and report back with the next problem and we will take if from there. On 5 February 2010 08:51, Fred Moore fred.moor...@gmail.com wrote: Hi Gary, thanks for your answer. I guess you could run without xml

Re: best approach to transfer large File, modify content on receive

2010-03-03 Thread Fred Moore
Hi Marc, We are sending files 1GB around using the ActiveMQ's BlobMessage. ...mmh you have an interesting real-life use case: can you give us a few more details? Things like the side protocol you use (FTP? WebDAV?), daily volumes, any special other ActiveMQ tuning you performed etc Cheers, F.

Re: How to run ActiveMQ on z/OS in EBCDIC without setting default file.encoding=ISO8859-1?

2010-02-05 Thread Fred Moore
without xml configuration and set any non default values via code... BrokerService broker = new BrokerService(); broker.addConnector(tcp://...); etc. On 4 February 2010 15:21, Fred Moore fred.moor...@gmail.com wrote: Hi folks, we have an application hosting an embedded broker instance

How to run ActiveMQ on z/OS in EBCDIC without setting default file.encoding=ISO8859-1?

2010-02-04 Thread Fred Moore
Hi folks, we have an application hosting an embedded broker instance which needs to run on z/OS box. Unfortunately the application heavily relies on EBCDIC I/O, so passing -Dfile.encoding=ISO8859-1 to the JVM (as suggested in http://activemq.apache.org/zos.html is not viable). We several things

How to set alwaysSyncSend=true on a VM connector via URI? (vm://MyBrk?alwaysSyncSend=true does not work)

2010-02-01 Thread Fred Moore
Hi Folks, we are trying to create a 5.3 connection factory with this URI vm://MyBrk?alwaysSyncSend=true expecting to see alwaysSyncSend=true in the resulting ActiveMQConnectionFactory object... but this does not happen. What are we missing? FWIW: 1\ Setting alwaysSyncSend=true via Java code in

Re: How to minimize send() latency for persistent msgs in transacted sessions keeping JMSExceptions synchronuos?

2010-01-29 Thread Fred Moore
an ExceptionListener then the default (asyncSend for messages in a transaction) will work fine. Also set copuMsgOnSend=false to save some cycles on each send. On 28 January 2010 16:47, Fred Moore fred.moor...@gmail.com wrote: Hi folks, we have a fast producer sending persistent messages

How to minimize send() latency for persistent msgs in transacted sessions keeping JMSExceptions synchronuos?

2010-01-28 Thread Fred Moore
Hi folks, we have a fast producer sending persistent messages in transaction and committing them every X msgs or Y seconds, our requirements are: 1\ ability to minimize the send() latency (and overall performance) 2\ ability to detect any JMSExceptions at commit() time (or at send() time) and

Re: How to configure 5.3 broker over KahaDB to support lots of unconsumed persistent msgs?

2010-01-26 Thread Fred Moore
Hi, going back to Cursors and http://activemq.apache.org/how-do-i-configure-activemq-to-hold-100s-of-millions-of-queue-messages-.html ... ...can anyone shed some light on the actual role of memoryLimit in: policyEntry topic= producerFlowControl=false memoryLimit=1mb policyEntry queue=

Re: OOM with high KahaDB index time

2010-01-25 Thread Fred Moore
Hi Joe, can you post your whole activemq.xml for this good enough test on 5.3? ...I'm still missing something and getting OOMs. TIA, F. On Fri, Jan 22, 2010 at 9:07 PM, Joe Fernandez joe.fernan...@ttmsolutions.com wrote: I ran my 5.3 test with the following systemUsage

Re: OOM with high KahaDB index time

2010-01-25 Thread Fred Moore
/ /transportConnectors /broker import resource=jetty.xml/ /beans Fred Moore-3 wrote: Hi Joe, can you post your whole activemq.xml for this good enough test on 5.3? ...I'm still missing something and getting OOMs. TIA, F. On Fri, Jan 22, 2010 at 9:07 PM, Joe

How to configure 5.3 broker over KahaDB to support lots of unconsumed persistent msgs?

2010-01-22 Thread Fred Moore
Hi folks, we have a 5.3 embedded KahaDB based broker with just a VM connector on it (see activemq.xml here http://pastebin.com/f492ec856), our producers continuously send persistent messages while the consumers run intermittently (because they are bound to the availability of an external and

Any publicly available code to create human readable dumps of broker internal state and queue contents?

2010-01-20 Thread Fred Moore
Hi folks, after having embededded an ActiveMQ broker into our application, we wanted to provide simple command line use cases to help problem determination/troubleshooting, things like: 1\ Dumping the broker internal state (just dumping MBeans attributes should suffice) to a text file 2\ Dumping

Re: Trivial embedded broker not shutting down cleanly because of lingering threads

2010-01-14 Thread Fred Moore
...sounds related to this. On Thu, Jan 14, 2010 at 12:59 AM, Rob Davies rajdav...@gmail.com wrote: oops - sry Fred - read your first email too quick - could you post the ThreadExplorer class too ? thanks, Rob On 13 Jan 2010, at 22:24, Fred Moore wrote: Hi Rob, If you could post

Re: Trivial embedded broker not shutting down cleanly because of lingering threads

2010-01-14 Thread Fred Moore
- might make more sense for it not to be static. The [Timer-0] thread - I'm not seeing that - though I'm working from trunk cheers, Rob On 14 Jan 2010, at 11:51, Fred Moore wrote: Hi Rob, FWIW here is the ThreadExplorer class: http://pastebin.com/f1aa2a099 Do you actually call stop

Trivial embedded broker not shutting down cleanly because of lingering threads

2010-01-13 Thread Fred Moore
Hi folks, we have a 5.3.0 embedded broker that refuses to shutdown cleanly because of lingering threads. We reproduced this with a very very basic configuration: with just vm jmx connectors, no producers and no consumers and and this extremely simple main() program:

Re: Trivial embedded broker not shutting down cleanly because of lingering threads

2010-01-13 Thread Fred Moore
actually call stop() on the broker ? - Have you disabled the shutdownHook from the broker ? If you could post your code - or sample of it - might help identify why your main isn't shutting down On 13 Jan 2010, at 17:50, Fred Moore wrote: Hi folks, we have a 5.3.0 embedded broker that refuses

Re: How can we obtain automatic removal of expired messages from queues?

2009-12-10 Thread Fred Moore
bruce.sny...@gmail.com wrote: On Fri, Dec 4, 2009 at 9:38 AM, Fred Moore fred.moor...@gmail.com wrote: Hi folks, this is probably easy but we not able to figure it out: we have producers setting msg expiration and msgs ending up in DLQ upon expiration (with their expiration reset

How can we obtain automatic removal of expired messages from queues?

2009-12-04 Thread Fred Moore
Hi folks, this is probably easy but we not able to figure it out: we have producers setting msg expiration and msgs ending up in DLQ upon expiration (with their expiration reset to never). How can I set things up in a way such that expired msgs will simply disappear for good automatically

How do I remove a queue in an embedded broker without having it listen on a tcp/ip port?

2009-12-01 Thread Fred Moore
Hi folks, I have a completely embedded broker instance running in the same JVM as my JMS applications, all applications use a VM transport connector so the TCP/IP footprint (i.e. used ports) of this system is currently zero. Now my additional requirement is to be able to remove some [unused]

Broker-to-Broker Authentication and Authorization vs Duplex network connectors

2009-10-24 Thread Fred Moore
Hi folks, in a hubspoke scenario where: 1\ both the hub broker and the spoke brokers are secured 2\ each spoke broker uses a duplex network connector to establish a two way msg exchange w/hub I understand from http://cwiki.apache.org/confluence/display/ACTIVEMQ/Security that the network

WebSphere MQ veteran new to ActiveMQ questions

2009-10-23 Thread Fred Moore
Hi folks, I'm an IBM WebSphere MQ veteran new to ActiveMQ, I recently started exploring ActiveMQ: great product, really great features... with some aspects just a little bit confusing for senior citizens like me :-) coming from years dwelling in WMQ-land. My general question here is: are there

Re: WebSphere MQ veteran new to ActiveMQ questions

2009-10-23 Thread Fred Moore
Hi Rob, many thanks for the very prompt and comprehensive answer, which encourages me to venture into a second round of questions :-) ... Hi Folks, 1\ Can someone shed some light on the actual role of the brokerName in a network of brokers scenario? (by reading the docs it looks like it does