problem with onException call
Hi, I am getting a problem with jms ExceptionListeners onException() call. When I AMQ server is down on a remote host my client disconnects and onException() is called but it wraps a EOFException(). And because of some odd reason, that exception is not returned to my application for handling. Any one has any idea? Thanks! Vik
JMX high port question
Hi, When I am using JConsole to connect to AMQ server running on a remote host, I am using port 1099 to connect. And once I am connected I notice that it transfers the communication to another port I noticed this port was 44344. And when I restarted the AMQ that port was changed to 52136. My remote host is behind the firewall and ports needs to be opened explicitly for any communication. Is there a way I can configure a port for AMQ to use every time. Thanks! Vik
how to set rmiServerPort
Hi, I was looking at the AMQ code for ManagementContext.java and found the following code. // Create the JMXConnectorServer String rmiServer = ; if (rmiServerPort != 0) { // This is handy to use if you have a firewall and need to // force JMX to use fixed ports. rmiServer = localhost: + rmiServerPort; } String serviceURL = service:jmx:rmi://+rmiServer+/jndi/rmi://localhost:+connectorPort+connec torPath; JMXServiceURL url=new JMXServiceURL(serviceURL); connectorServer=JMXConnectorServerFactory.newJMXConnectorServer(url,null,mbe anServer); actually I am running in the exact situation as the comment says FIREWALL. I was trying to find out how to set rmiServerPort haven't found anything yet. Any help will be appreciated. Thanks! Vik
RE: [VOTE] Release Apache ActiveMQ 4.0.2 (RC 6)
Hi Hiram, I am still having trouble with message selector using STOMP C. it works fine in the 4.0.1 release. Thanks! -Original Message- From: [EMAIL PROTECTED] [mailto:[EMAIL PROTECTED] On Behalf Of Hiram Chirino Sent: Sunday, October 29, 2006 9:54 PM To: activemq-dev@geronimo.apache.org; general@incubator.apache.org Subject: [VOTE] Release Apache ActiveMQ 4.0.2 (RC 6) Some last minute NOTICE issues were still present in the 5th release candidate of the 4.0.2 build. We have also received confirmation from Apache legal discuss that it's ok to include work covered by the Creative Commons Attribution license. I have cut and RC 6 of the 4.0.2 build with the fixes and it's available here: http://people.apache.org/~chirino/incubator-activemq-4.0.2-RC6/maven1/in cubator-activemq/distributions/ Maven 1 and Maven 2 repos for this release can be found at: http://people.apache.org/~chirino/incubator-activemq-4.0.2-RC6 Here's the wiki page for the release notes: http://incubator.apache.org/activemq/activemq-402-release.html Please vote to approve this release binary [ ] +1 Release the binary as Apache ActiveMQ 4.0.2 [ ] -1 Veto the release (provide specific comments) This vote is being cross posted to the general incubator mailing list also to expedite the voting process. Here's my +1 -- Regards, Hiram Blog: http://hiramchirino.com
RE: New ActiveMQ 4.0.2 RC6 is up for evaluation.
Hey Hiram, I ran few tests on RC6, and it appears to me that earlier issue I reported for STOMP C, when prefetchSize was affecting consumers by the prefetchSize limit, is FIXED. Now my consumer is not hanging when I am trying to receive and ack messages in a loop. I have noticed another problem though, it appears to me that message Selector stopped working once again now for STOMP C. Just to make sure my client code is stable I ran it against AMQ 4.0.1 and it worked just fine. Thanks! Vik -Original Message- From: [EMAIL PROTECTED] [mailto:[EMAIL PROTECTED] On Behalf Of Hiram Chirino Sent: Tuesday, October 24, 2006 6:05 PM To: activemq-dev@geronimo.apache.org; activemq-users@geronimo.apache.org Subject: New ActiveMQ 4.0.2 RC6 is up for evaluation. Since the (1) The Apache download servers are down (2) We needed to re-cut a new release candidate for 4.0.2 (3) lots of folks have been look to see where they can download the latest version of ActiveMQ at I've posted the RC6 cut of the ActiveMQ 4.0.2 up on: http://hiramchirino.com/~chirino/incubator-activemq-4.0.2-RC6/maven1/inc ubator-activemq/distributions/ maven 1 repo is at: http://hiramchirino.com/~chirino/incubator-activemq-4.0.2-RC6/maven1 maven 2 repo is at: http://hiramchirino.com/~chirino/incubator-activemq-4.0.2-RC6/maven2 I'll follow this note up with an official vote thread tomorrow. -- Regards, Hiram Blog: http://hiramchirino.com
AMQ SNAPSHOT download link is still not working
Any one has any idea why people.apache.org is giving a Gateway timeout error when I am trying to click on the latest SNAPSHOT download link? Thanks! Vik
activemq download server is giving gateway timeout
Hi, I am trying to download the latest SNAPSHOT of AMQ, download server is giving me Gateway timeout error. Any ideas? Thanks! Vik
RE: activemq.prefetchSize behavior concerns in STOMP C client
Hi Hiram, Thanks for the quick response and the fix. I am in process of testing it today and will let you know how it goes. James: thanks for describing the prefetch behavior for me. Vik -Original Message- From: [EMAIL PROTECTED] [mailto:[EMAIL PROTECTED] On Behalf Of Hiram Chirino Sent: Friday, October 20, 2006 9:39 AM To: activemq-dev@geronimo.apache.org Subject: Re: activemq.prefetchSize behavior concerns in STOMP C client Hey.. I just made some fixes recently to the stomp acking.. see: http://svn.apache.org/viewvc?view=revrevision=465990 This may fix it for ya. On 10/20/06, James Strachan [EMAIL PROTECTED] wrote: Some background on prefetch... http://incubator.apache.org/activemq/what-is-the-prefetch-limit-for.html Is the Stomp client either accurately specifying auto-ack mode or acknowledging the messages? Irrespective of the client used; if you don't acknowledge the messages in the prefetch buffer, the broker refuses to send more when the buffer is full until it receives acknowledgements. On 10/19/06, Dhawan, Vikram (LNG-DAY) [EMAIL PROTECTED] wrote: Hi, I am using STOMP C client with latest build available of AMQ (pre 4.0.2 10/17 build). I have some questions about how prefetchSize is affecting my client working. My STOMP C consumer is implemented in a way that once it connected to the AMQ server it loops and reads all the messages in the particular queue. And once all the messages are read it disconnects. What I am seeing here is if I have a prefetchSize value set then it only reads messages up to the prefetchSize value and then it blocks at the stomp_read call. If I don't have any prefetchSize value set then it loops and stomp_read reads all the messages in the queue. But my Openwire java client doesn't behave similarly. Even if I have a prefetchSize set to a small value in java client every nextMessage() call gives me a message if there is any message in the queue. I am not sure why there is different in prefetchSize working in STOMP and java client. Is this expected behavior? Any help would be appreciated. Thanks! Vik -- James --- http://radio.weblogs.com/0112098/ -- Regards, Hiram Blog: http://hiramchirino.com
activemq.prefetchSize behavior concerns in STOMP C client
Hi, I am using STOMP C client with latest build available of AMQ (pre 4.0.2 10/17 build). I have some questions about how prefetchSize is affecting my client working. My STOMP C consumer is implemented in a way that once it connected to the AMQ server it loops and reads all the messages in the particular queue. And once all the messages are read it disconnects. What I am seeing here is if I have a prefetchSize value set then it only reads messages up to the prefetchSize value and then it blocks at the stomp_read call. If I don't have any prefetchSize value set then it loops and stomp_read reads all the messages in the queue. But my Openwire java client doesn't behave similarly. Even if I have a prefetchSize set to a small value in java client every nextMessage() call gives me a message if there is any message in the queue. I am not sure why there is different in prefetchSize working in STOMP and java client. Is this expected behavior? Any help would be appreciated. Thanks! Vik
RE: Openwire C++ client for AMQ
Thanks Tim, And I assume this open wire client code is a tested :). Thanks! Vik -Original Message- From: Timothy Bish [mailto:[EMAIL PROTECTED] Sent: Tuesday, October 17, 2006 5:43 PM To: activemq-dev@geronimo.apache.org Subject: RE: Openwire C++ client for AMQ Yes, that folder contains the only cpp openwire client at the moment. -Original Message- From: Dhawan, Vikram (LNG-DAY) [mailto:[EMAIL PROTECTED] Sent: Tuesday, October 17, 2006 5:30 PM To: activemq-dev@geronimo.apache.org Subject: Openwire C++ client for AMQ Importance: High I saw some discussion around Openwire C++ client is available now (with Queue's and Topic's support). I will appreciate if some one can tell me where to download it from? I was trying to find out on svn and there is a directory called openwire-cpp is this the directory for openwire-cpp client? Thanks! Vik
RE: how to use failover url protocol in STOMP C client
James, Thanks for heads up. Will keep you posted. Thanks! Vik -Original Message- From: James Strachan [mailto:[EMAIL PROTECTED] Sent: Tuesday, October 03, 2006 10:22 AM To: activemq-dev@geronimo.apache.org Subject: Re: how to use failover url protocol in STOMP C client BTW Stomp based failover should also re-submit any in-progress operations - e.g. to resume any SUBSCRIBE's. If you are supporting transactions, you should replay any non-complete transactions too. On 10/2/06, Hiram Chirino [EMAIL PROTECTED] wrote: Just checked again .. and yep it's there. Follow the use of the reliable variable. when set to true, it acts very similar to how failover acts. When a failure occurs it keeps trying to reconnect to the broker. And that's basically the hard part of faiover, the only other thing that failover does is on failure it chooses a different host to connect to from a list. On 10/2/06, Dhawan, Vikram (LNG-DAY) [EMAIL PROTECTED] wrote: I looked into the ruby code; it looks to me plain STOMP message implementation. I don't see any specific implementation to failover protocol. Any idea? Vik -Original Message- From: [EMAIL PROTECTED] [mailto:[EMAIL PROTECTED] On Behalf Of Hiram Chirino Sent: Monday, October 02, 2006 11:55 AM To: activemq-dev@geronimo.apache.org Subject: Re: how to use failover url protocol in STOMP C client Seems that the ruby code was moved recently so it could be independently released.. here's where it lives now: http://svn.codehaus.org/stomp/ruby/trunk/ On 10/2/06, Dhawan, Vikram (LNG-DAY) [EMAIL PROTECTED] wrote: Hiram, I can't access the Ruby code on STOMP's website. When I click on source link on the Stomp Client for Ruby page it gives me a Not Found error. Please let me know, I was getting ready to work on failover for STOMP C client and wanted to see how it is implemented in Ruby client. Thanks! Vik -Original Message- From: Dhawan, Vikram (LNG-DAY) [mailto:[EMAIL PROTECTED] Sent: Monday, September 25, 2006 10:18 AM To: activemq-dev@geronimo.apache.org Subject: RE: how to use failover url protocol in STOMP C client Hi Hiram, I will do that. BTW I had another question and haven't got any response yet... this is about message selector in STOMP C clients. Because of some reason I can't get it work. Can you provide me some sample? As far as my understanding I am setting the selector at the SUBSCRIBE command and it should work. Thanks! Vik -Original Message- From: [EMAIL PROTECTED] [mailto:[EMAIL PROTECTED] On Behalf Of Hiram Chirino Sent: Friday, September 22, 2006 7:37 PM To: activemq-dev@geronimo.apache.org Subject: Re: how to use failover url protocol in STOMP C client Hi Vikram, Not implemented in the stomp C client yet. If you want to take a cracked at implementing it yourself, you might want to peek at how it was implemented in the stomp ruby client. On 9/22/06, Dhawan, Vikram (LNG-DAY) [EMAIL PROTECTED] wrote: Hi, I want to know can I use same failover protocol URL syntax in STOMP C clients. And will it work the way failover is described in the AMQ documentation. Thanks! Vik -- Regards, Hiram Blog: http://hiramchirino.com -- Regards, Hiram Blog: http://hiramchirino.com -- Regards, Hiram Blog: http://hiramchirino.com -- James --- http://radio.weblogs.com/0112098/
how to setup failover URI in STOMP C client
Hi, I want to know how to setup failover URI in STOMP C client. Can I use failover:(uri1,...,uriN)?transportOptions in STOMP C client? If there is other way to achieve failover using STOMP C client please let me know. Thanks! Vik
RE: how to setup failover URI in STOMP C client
I found out this was already answered. Thanks! Vik -Original Message- From: Dhawan, Vikram (LNG-DAY) [mailto:[EMAIL PROTECTED] Sent: Monday, October 02, 2006 11:06 AM To: activemq-dev@geronimo.apache.org Subject: how to setup failover URI in STOMP C client Hi, I want to know how to setup failover URI in STOMP C client. Can I use failover:(uri1,...,uriN)?transportOptions in STOMP C client? If there is other way to achieve failover using STOMP C client please let me know. Thanks! Vik
RE: how to use failover url protocol in STOMP C client
Hiram, I can't access the Ruby code on STOMP's website. When I click on source link on the Stomp Client for Ruby page it gives me a Not Found error. Please let me know, I was getting ready to work on failover for STOMP C client and wanted to see how it is implemented in Ruby client. Thanks! Vik -Original Message- From: Dhawan, Vikram (LNG-DAY) [mailto:[EMAIL PROTECTED] Sent: Monday, September 25, 2006 10:18 AM To: activemq-dev@geronimo.apache.org Subject: RE: how to use failover url protocol in STOMP C client Hi Hiram, I will do that. BTW I had another question and haven't got any response yet... this is about message selector in STOMP C clients. Because of some reason I can't get it work. Can you provide me some sample? As far as my understanding I am setting the selector at the SUBSCRIBE command and it should work. Thanks! Vik -Original Message- From: [EMAIL PROTECTED] [mailto:[EMAIL PROTECTED] On Behalf Of Hiram Chirino Sent: Friday, September 22, 2006 7:37 PM To: activemq-dev@geronimo.apache.org Subject: Re: how to use failover url protocol in STOMP C client Hi Vikram, Not implemented in the stomp C client yet. If you want to take a cracked at implementing it yourself, you might want to peek at how it was implemented in the stomp ruby client. On 9/22/06, Dhawan, Vikram (LNG-DAY) [EMAIL PROTECTED] wrote: Hi, I want to know can I use same failover protocol URL syntax in STOMP C clients. And will it work the way failover is described in the AMQ documentation. Thanks! Vik -- Regards, Hiram Blog: http://hiramchirino.com
RE: how to use failover url protocol in STOMP C client
I looked into the ruby code; it looks to me plain STOMP message implementation. I don't see any specific implementation to failover protocol. Any idea? Vik -Original Message- From: [EMAIL PROTECTED] [mailto:[EMAIL PROTECTED] On Behalf Of Hiram Chirino Sent: Monday, October 02, 2006 11:55 AM To: activemq-dev@geronimo.apache.org Subject: Re: how to use failover url protocol in STOMP C client Seems that the ruby code was moved recently so it could be independently released.. here's where it lives now: http://svn.codehaus.org/stomp/ruby/trunk/ On 10/2/06, Dhawan, Vikram (LNG-DAY) [EMAIL PROTECTED] wrote: Hiram, I can't access the Ruby code on STOMP's website. When I click on source link on the Stomp Client for Ruby page it gives me a Not Found error. Please let me know, I was getting ready to work on failover for STOMP C client and wanted to see how it is implemented in Ruby client. Thanks! Vik -Original Message- From: Dhawan, Vikram (LNG-DAY) [mailto:[EMAIL PROTECTED] Sent: Monday, September 25, 2006 10:18 AM To: activemq-dev@geronimo.apache.org Subject: RE: how to use failover url protocol in STOMP C client Hi Hiram, I will do that. BTW I had another question and haven't got any response yet... this is about message selector in STOMP C clients. Because of some reason I can't get it work. Can you provide me some sample? As far as my understanding I am setting the selector at the SUBSCRIBE command and it should work. Thanks! Vik -Original Message- From: [EMAIL PROTECTED] [mailto:[EMAIL PROTECTED] On Behalf Of Hiram Chirino Sent: Friday, September 22, 2006 7:37 PM To: activemq-dev@geronimo.apache.org Subject: Re: how to use failover url protocol in STOMP C client Hi Vikram, Not implemented in the stomp C client yet. If you want to take a cracked at implementing it yourself, you might want to peek at how it was implemented in the stomp ruby client. On 9/22/06, Dhawan, Vikram (LNG-DAY) [EMAIL PROTECTED] wrote: Hi, I want to know can I use same failover protocol URL syntax in STOMP C clients. And will it work the way failover is described in the AMQ documentation. Thanks! Vik -- Regards, Hiram Blog: http://hiramchirino.com -- Regards, Hiram Blog: http://hiramchirino.com
RE: how to use failover url protocol in STOMP C client
Got it! Thanks! Vik -Original Message- From: [EMAIL PROTECTED] [mailto:[EMAIL PROTECTED] On Behalf Of Hiram Chirino Sent: Monday, October 02, 2006 1:01 PM To: activemq-dev@geronimo.apache.org Subject: Re: how to use failover url protocol in STOMP C client Just checked again .. and yep it's there. Follow the use of the reliable variable. when set to true, it acts very similar to how failover acts. When a failure occurs it keeps trying to reconnect to the broker. And that's basically the hard part of faiover, the only other thing that failover does is on failure it chooses a different host to connect to from a list. On 10/2/06, Dhawan, Vikram (LNG-DAY) [EMAIL PROTECTED] wrote: I looked into the ruby code; it looks to me plain STOMP message implementation. I don't see any specific implementation to failover protocol. Any idea? Vik -Original Message- From: [EMAIL PROTECTED] [mailto:[EMAIL PROTECTED] On Behalf Of Hiram Chirino Sent: Monday, October 02, 2006 11:55 AM To: activemq-dev@geronimo.apache.org Subject: Re: how to use failover url protocol in STOMP C client Seems that the ruby code was moved recently so it could be independently released.. here's where it lives now: http://svn.codehaus.org/stomp/ruby/trunk/ On 10/2/06, Dhawan, Vikram (LNG-DAY) [EMAIL PROTECTED] wrote: Hiram, I can't access the Ruby code on STOMP's website. When I click on source link on the Stomp Client for Ruby page it gives me a Not Found error. Please let me know, I was getting ready to work on failover for STOMP C client and wanted to see how it is implemented in Ruby client. Thanks! Vik -Original Message- From: Dhawan, Vikram (LNG-DAY) [mailto:[EMAIL PROTECTED] Sent: Monday, September 25, 2006 10:18 AM To: activemq-dev@geronimo.apache.org Subject: RE: how to use failover url protocol in STOMP C client Hi Hiram, I will do that. BTW I had another question and haven't got any response yet... this is about message selector in STOMP C clients. Because of some reason I can't get it work. Can you provide me some sample? As far as my understanding I am setting the selector at the SUBSCRIBE command and it should work. Thanks! Vik -Original Message- From: [EMAIL PROTECTED] [mailto:[EMAIL PROTECTED] On Behalf Of Hiram Chirino Sent: Friday, September 22, 2006 7:37 PM To: activemq-dev@geronimo.apache.org Subject: Re: how to use failover url protocol in STOMP C client Hi Vikram, Not implemented in the stomp C client yet. If you want to take a cracked at implementing it yourself, you might want to peek at how it was implemented in the stomp ruby client. On 9/22/06, Dhawan, Vikram (LNG-DAY) [EMAIL PROTECTED] wrote: Hi, I want to know can I use same failover protocol URL syntax in STOMP C clients. And will it work the way failover is described in the AMQ documentation. Thanks! Vik -- Regards, Hiram Blog: http://hiramchirino.com -- Regards, Hiram Blog: http://hiramchirino.com -- Regards, Hiram Blog: http://hiramchirino.com
STOMP C prefetchSize question
Hi, On STOMP webpage where it says ActiveMQ extensions to STOMP. It says activemq.prefetchSize expects a int type value. But from my earlier question we can only set string value to a header property using STOMP C client. Will prefetchSize still work if I set it as a string form number? Some thing like as follows apr_hash_set(frame.headers, activemq.prefetchSize, APR_HASH_KEY_STRING, 1); Thanks! Vik
STOMP C selector problem
Hi, I tried few more things for STOMP C client's selector. What I have seen is unbelievable, if I have properties name anything other then name and age (case sensitive, only all small case works) then my producer runs fine but consumer throws a core dump. I looked at the core dump in the Sun Workshop and it was talking about strlen() function, segmentation fault. So it only works for two magic properties name and age, am I totally confused :-)? Thanks! Vik
RE: STOMP C selector problem
This is a non issue. I think I am getting tired and not looking at the right thing. Vik -Original Message- From: Dhawan, Vikram (LNG-DAY) [mailto:[EMAIL PROTECTED] Sent: Monday, September 25, 2006 4:03 PM To: activemq-dev@geronimo.apache.org Subject: STOMP C selector problem Hi, I tried few more things for STOMP C client's selector. What I have seen is unbelievable, if I have properties name anything other then name and age (case sensitive, only all small case works) then my producer runs fine but consumer throws a core dump. I looked at the core dump in the Sun Workshop and it was talking about strlen() function, segmentation fault. So it only works for two magic properties name and age, am I totally confused :-)? Thanks! Vik
RE: how to use failover url protocol in STOMP C client
Hi Hiram, I will do that. BTW I had another question and haven't got any response yet... this is about message selector in STOMP C clients. Because of some reason I can't get it work. Can you provide me some sample? As far as my understanding I am setting the selector at the SUBSCRIBE command and it should work. Thanks! Vik -Original Message- From: [EMAIL PROTECTED] [mailto:[EMAIL PROTECTED] On Behalf Of Hiram Chirino Sent: Friday, September 22, 2006 7:37 PM To: activemq-dev@geronimo.apache.org Subject: Re: how to use failover url protocol in STOMP C client Hi Vikram, Not implemented in the stomp C client yet. If you want to take a cracked at implementing it yourself, you might want to peek at how it was implemented in the stomp ruby client. On 9/22/06, Dhawan, Vikram (LNG-DAY) [EMAIL PROTECTED] wrote: Hi, I want to know can I use same failover protocol URL syntax in STOMP C clients. And will it work the way failover is described in the AMQ documentation. Thanks! Vik -- Regards, Hiram Blog: http://hiramchirino.com
how to use failover url protocol in STOMP C client
Hi, I want to know can I use same failover protocol URL syntax in STOMP C clients. And will it work the way failover is described in the AMQ documentation. Thanks! Vik
RE: JMX inteface is not running on latest release of AMQ 4.0.1
I still have a old release on my computer 4.0-SNAPSHOT (4/18/2006), and interesting thing is with the exactly same activemq.xml and on exactly same computer JMX is working with that and not working with 4.0.1. I am not sure what's going on here. Thanks! Vik -Original Message- From: Dhawan, Vikram (LNG-DAY) [mailto:[EMAIL PROTECTED] Sent: Friday, September 22, 2006 5:10 PM To: activemq-dev@geronimo.apache.org Subject: RE: JMX inteface is not running on latest release of AMQ 4.0.1 Hi Aaron, Thanks for your input here I am attaching the activemq.xml I am using. Please let me know if there is any change needed. This is the same activemq.xml I was using for previous release and it worked fine. I am using Java 5. Vik -Original Message- From: [EMAIL PROTECTED] [mailto:[EMAIL PROTECTED] On Behalf Of Aaron Mulder Sent: Friday, September 22, 2006 2:39 PM To: activemq-dev@geronimo.apache.org Subject: Re: JMX inteface is not running on latest release of AMQ 4.0.1 I didn't have that problem in ActiveMQ 4.0.1. Are you sure you have broker useJmx=true in your config file? Also, if you're running under Java 5, you may be using the JMX environment from the JVM which would prevent ActiveMQ from emitting the message about how its binding JMX to port such-and-such (because it doesn't create it's own JMX listener if it uses the JVM MBeanServer). You can force ActiveMQ to use its own JMX listener with the managementContext settings, if you want to. Thanks, Aaron On 9/22/06, Dhawan, Vikram (LNG-DAY) [EMAIL PROTECTED] wrote: Hi, I think this is a real problem; I looked over few times before I am posting it. In the activemq.xml I uncommented the managementContext section too. On my activemq console I don't see a message which used to be there saying that JMX connection be made. Thanks! Vik
latest Mavan SNAPSHOT giving error
Hi, I just downloaded the latest mavan SNAPSHOT release and when I am trying to run this its giving me the following exceptions. Any Idea why? Loading message broker from: xbean:activemq.xml ERROR: java.lang.RuntimeException: Failed to execute start task. Reason: java.la ng.IllegalArgumentException: The configuration has no BrokerService instance for resource: xbean:activemq.xml java.lang.RuntimeException: Failed to execute start task. Reason: java.lang.Ille galArgumentException: The configuration has no BrokerService instance for resour ce: xbean:activemq.xml at org.apache.activemq.console.command.StartCommand.runTask(StartCommand .java:70) at org.apache.activemq.console.command.AbstractCommand.execute(AbstractC ommand.java:50) at org.apache.activemq.console.command.ShellCommand.runTask(ShellCommand .java:65) at org.apache.activemq.console.command.AbstractCommand.execute(AbstractC ommand.java:50) at org.apache.activemq.console.command.ShellCommand.main(ShellCommand.ja va:46) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl. java:39) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAcces sorImpl.java:25) at java.lang.reflect.Method.invoke(Method.java:585) at org.apache.activemq.console.Main.runTaskClass(Main.java:136) at org.apache.activemq.console.Main.main(Main.java:68) Caused by: java.lang.IllegalArgumentException: The configuration has no BrokerSe rvice instance for resource: xbean:activemq.xml at org.apache.activemq.xbean.XBeanBrokerFactory.createBroker(XBeanBroker Factory.java:62) at org.apache.activemq.broker.BrokerFactory.createBroker(BrokerFactory.j ava:57) at org.apache.activemq.console.command.StartCommand.startBroker(StartCom mand.java:82) at org.apache.activemq.console.command.StartCommand.runTask(StartCommand .java:47) ... 10 more ERROR: java.lang.Exception: java.lang.IllegalArgumentException: The configuratio n has no BrokerService instance for resource: xbean:activemq.xml java.lang.Exception: java.lang.IllegalArgumentException: The configuration has n o BrokerService instance for resource: xbean:activemq.xml at org.apache.activemq.console.command.StartCommand.runTask(StartCommand .java:71) at org.apache.activemq.console.command.AbstractCommand.execute(AbstractC ommand.java:50) at org.apache.activemq.console.command.ShellCommand.runTask(ShellCommand .java:65) at org.apache.activemq.console.command.AbstractCommand.execute(AbstractC ommand.java:50) at org.apache.activemq.console.command.ShellCommand.main(ShellCommand.ja va:46) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl. java:39) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAcces sorImpl.java:25) at java.lang.reflect.Method.invoke(Method.java:585) at org.apache.activemq.console.Main.runTaskClass(Main.java:136) at org.apache.activemq.console.Main.main(Main.java:68) Caused by: java.lang.IllegalArgumentException: The configuration has no BrokerSe rvice instance for resource: xbean:activemq.xml at org.apache.activemq.xbean.XBeanBrokerFactory.createBroker(XBeanBroker Factory.java:62) at org.apache.activemq.broker.BrokerFactory.createBroker(BrokerFactory.j ava:57) at org.apache.activemq.console.command.StartCommand.startBroker(StartCom mand.java:82) at org.apache.activemq.console.command.StartCommand.runTask(StartCommand .java:47) ... 10 more Vik
RE: latest Mavan SNAPSHOT giving error
Please ignore this problem report, it's a non issue. I had some error in my activemq.xml file. Thanks! Vik -Original Message- From: Dhawan, Vikram (LNG-DAY) [mailto:[EMAIL PROTECTED] Sent: Friday, September 22, 2006 1:00 PM To: activemq-dev@geronimo.apache.org Subject: latest Mavan SNAPSHOT giving error Hi, I just downloaded the latest mavan SNAPSHOT release and when I am trying to run this its giving me the following exceptions. Any Idea why? Loading message broker from: xbean:activemq.xml ERROR: java.lang.RuntimeException: Failed to execute start task. Reason: java.la ng.IllegalArgumentException: The configuration has no BrokerService instance for resource: xbean:activemq.xml java.lang.RuntimeException: Failed to execute start task. Reason: java.lang.Ille galArgumentException: The configuration has no BrokerService instance for resour ce: xbean:activemq.xml at org.apache.activemq.console.command.StartCommand.runTask(StartCommand .java:70) at org.apache.activemq.console.command.AbstractCommand.execute(AbstractC ommand.java:50) at org.apache.activemq.console.command.ShellCommand.runTask(ShellCommand .java:65) at org.apache.activemq.console.command.AbstractCommand.execute(AbstractC ommand.java:50) at org.apache.activemq.console.command.ShellCommand.main(ShellCommand.ja va:46) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl. java:39) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAcces sorImpl.java:25) at java.lang.reflect.Method.invoke(Method.java:585) at org.apache.activemq.console.Main.runTaskClass(Main.java:136) at org.apache.activemq.console.Main.main(Main.java:68) Caused by: java.lang.IllegalArgumentException: The configuration has no BrokerSe rvice instance for resource: xbean:activemq.xml at org.apache.activemq.xbean.XBeanBrokerFactory.createBroker(XBeanBroker Factory.java:62) at org.apache.activemq.broker.BrokerFactory.createBroker(BrokerFactory.j ava:57) at org.apache.activemq.console.command.StartCommand.startBroker(StartCom mand.java:82) at org.apache.activemq.console.command.StartCommand.runTask(StartCommand .java:47) ... 10 more ERROR: java.lang.Exception: java.lang.IllegalArgumentException: The configuratio n has no BrokerService instance for resource: xbean:activemq.xml java.lang.Exception: java.lang.IllegalArgumentException: The configuration has n o BrokerService instance for resource: xbean:activemq.xml at org.apache.activemq.console.command.StartCommand.runTask(StartCommand .java:71) at org.apache.activemq.console.command.AbstractCommand.execute(AbstractC ommand.java:50) at org.apache.activemq.console.command.ShellCommand.runTask(ShellCommand .java:65) at org.apache.activemq.console.command.AbstractCommand.execute(AbstractC ommand.java:50) at org.apache.activemq.console.command.ShellCommand.main(ShellCommand.ja va:46) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl. java:39) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAcces sorImpl.java:25) at java.lang.reflect.Method.invoke(Method.java:585) at org.apache.activemq.console.Main.runTaskClass(Main.java:136) at org.apache.activemq.console.Main.main(Main.java:68) Caused by: java.lang.IllegalArgumentException: The configuration has no BrokerSe rvice instance for resource: xbean:activemq.xml at org.apache.activemq.xbean.XBeanBrokerFactory.createBroker(XBeanBroker Factory.java:62) at org.apache.activemq.broker.BrokerFactory.createBroker(BrokerFactory.j ava:57) at org.apache.activemq.console.command.StartCommand.startBroker(StartCom mand.java:82) at org.apache.activemq.console.command.StartCommand.runTask(StartCommand .java:47) ... 10 more Vik
JMX inteface is not running on latest release of AMQ 4.0.1
Hi, I think this is a real problem; I looked over few times before I am posting it. In the activemq.xml I uncommented the managementContext section too. On my activemq console I don't see a message which used to be there saying that JMX connection be made. Thanks! Vik
RE: JMX inteface is not running on latest release of AMQ 4.0.1
Hi Aaron, Thanks for your input here I am attaching the activemq.xml I am using. Please let me know if there is any change needed. This is the same activemq.xml I was using for previous release and it worked fine. I am using Java 5. Vik -Original Message- From: [EMAIL PROTECTED] [mailto:[EMAIL PROTECTED] On Behalf Of Aaron Mulder Sent: Friday, September 22, 2006 2:39 PM To: activemq-dev@geronimo.apache.org Subject: Re: JMX inteface is not running on latest release of AMQ 4.0.1 I didn't have that problem in ActiveMQ 4.0.1. Are you sure you have broker useJmx=true in your config file? Also, if you're running under Java 5, you may be using the JMX environment from the JVM which would prevent ActiveMQ from emitting the message about how its binding JMX to port such-and-such (because it doesn't create it's own JMX listener if it uses the JVM MBeanServer). You can force ActiveMQ to use its own JMX listener with the managementContext settings, if you want to. Thanks, Aaron On 9/22/06, Dhawan, Vikram (LNG-DAY) [EMAIL PROTECTED] wrote: Hi, I think this is a real problem; I looked over few times before I am posting it. In the activemq.xml I uncommented the managementContext section too. On my activemq console I don't see a message which used to be there saying that JMX connection be made. Thanks! Vik !-- START SNIPPET: example -- beans xmlns=http://activemq.org/config/1.0; !-- Allows us to use system properties as variables in this configuration file -- bean class=org.springframework.beans.factory.config.PropertyPlaceholderConfigurer/ broker useJmx=true brokerName=BROKER_1 !-- Use the following to set the broker memory limit (in bytes) memoryManager usageManager id=memory-manager limit=1048576/ /memoryManager -- !-- Use the following to configure how ActiveMQ is exposed in JMX -- managementContext managementContext connectorPort=1099 jmxDomainName=org.apache.activemq useMBeanServer=true/ /managementContext !-- In ActiveMQ 4, you can setup destination policies -- destinationPolicy policyMap policyEntries policyEntry topic=FOO.gt; dispatchPolicy strictOrderDispatchPolicy/ /dispatchPolicy subscriptionRecoveryPolicy lastImageSubscriptionRecoveryPolicy/ /subscriptionRecoveryPolicy /policyEntry /policyEntries /policyMap /destinationPolicy persistenceAdapter jdbcPersistenceAdapter cleanupPeriod=6 dataSource#mysql-ds/dataSource /jdbcPersistenceAdapter !--journaledJDBC journalLogFiles=5 dataDirectory=${activemq.home}/activemq-data/-- !-- To use a different datasource, use th following syntax : -- !-- journaledJDBC journalLogFiles=5 dataDirectory=../activemq-data dataSource=#postgres-ds/ -- /persistenceAdapter transportConnectors transportConnector name=default uri=tcp://localhost:61616 discoveryUri=multicast://default/ transportConnector name=stomp uri=stomp://localhost:61613/ /transportConnectors networkConnectors !-- by default just auto discover the other brokers -- !--networkConnector name=default uri=multicast://default/-- !-- networkConnector name=host1 and host2 uri=static://(tcp://host1:61616,tcp://host2:61616) failover=true/ -- /networkConnectors /broker !-- This xbean configuration file supports all the standard spring xml configuration options -- !-- Postgres DataSource Sample Setup -- !-- bean id=postgres-ds class=org.postgresql.ds.PGPoolingDataSource property name=serverName value=localhost/ property name=databaseName value=activemq/ property name=portNumber value=0/ property name=user value=activemq/ property name=password value=activemq/ property name=dataSourceName value=postgres/ property name=initialConnections value=1/ property name=maxConnections value=10/ /bean -- !-- MySql DataSource Sample Setup -- bean id=mysql-ds class=org.apache.commons.dbcp.BasicDataSource destroy-method=close property name=driverClassName value=com.mysql.jdbc.Driver/ property name=url value=jdbc:mysql://localhost/activemq?relaxAutoCommit=true/ property name=username value=X/ property name=password value=XX/ property name=poolPreparedStatements value=true/ /bean !-- Embedded Derby DataSource Sample Setup -- !-- bean id=derby-ds class=org.apache.derby.jdbc.EmbeddedDataSource property name=databaseName value=derbydb/ property name=createDatabase value=create/ /bean -- /beans !-- END SNIPPET: example --
RE: is there a character limit in message selector
Hi, I haven't seen any explanation of why AMQ with STOMP C client doesn't respond to the message selectors. It appears to me, even if i have a very small selector (small in character length) in my STOMP C client it doesn't work. But if I have a NULL check in my selector on some message property, it seems to be working. Very Inconsistent I will appreciate if some one can help me with that. This issue is getting critical for me as I am getting ready use AMQ in one of our production system. We may have to re think this decision if there is a serious problem with selectors. Thanks! Vik -Original Message- From: Dhawan, Vikram (LNG-DAY) [mailto:[EMAIL PROTECTED] Sent: Friday, September 15, 2006 9:57 AM To: activemq-dev@geronimo.apache.org Subject: RE: is there a character limit in message selector James, Thanks for your reply. I am not sure where should I look for the bug. APR or STOMP implementation. I have looked at the STOMP client library (which solely rely on APR lib), and I don't see anything there which may have caused that behavior. If the developer of this stomp client (Hiram??), can provide some guidance that will be helpful. Thanks! Vik -Original Message- From: James Strachan [mailto:[EMAIL PROTECTED] Sent: Friday, September 15, 2006 2:53 AM To: activemq-dev@geronimo.apache.org Subject: Re: is there a character limit in message selector Not on the Java side no - there could be in a stomp client's implementation maybe but that should be pretty easy to fix On 9/15/06, vik Dhawan [EMAIL PROTECTED] wrote: Hi, I want to know if there is a AMQ specific character limit in message selector. I am using STOMP C and message selector is working when I am checking a message header value for null/not null. But in another situation I am checking for a string in one of the message header property, the size of the string I am looking for is around 100bytes. So first question came to my mind was is there any size limit there? Thanks!. -- View this message in context: http://www.nabble.com/is-there-a-character-limit-in-message-selector-tf2 275075.html#a6317949 Sent from the ActiveMQ - Dev forum at Nabble.com. -- James --- http://radio.weblogs.com/0112098/
RE: multiple consumer threads in same program in STOMP issue
Thanks James, May be APR is not handling multi threading correctly. STOMP C uses apr lib under the hood. I am wondering lets say both the consumer threads are on same connection do you think that can cause this behavior? Thanks! Vik -Original Message- From: James Strachan [mailto:[EMAIL PROTECTED] Sent: Friday, September 15, 2006 3:25 AM To: activemq-dev@geronimo.apache.org Subject: Re: multiple consumer threads in same program in STOMP issue It could be the stomp c client doesn't do multi threaded consumption too well. You might wanna take a peek at how the consumption code works On 9/14/06, Dhawan, Vikram (LNG-DAY) [EMAIL PROTECTED] wrote: Hi, I am running into a strange issue, I created a consumer program using STOMP C which actually creates two separate consumer threads and both threads are reading from the same queue in the AMQ server using their own selectors on a header property. I was expecting that each thread will keep on consuming messages those who satisfy the selector conditions. But what happening here is at a time only one consumer thread is able to get its messages, another one just hangs. If I call disconnect in the thread which is working then only the hanged thread starts getting its messages. I will appreciate any explanation. Thanks! Vik -- James --- http://radio.weblogs.com/0112098/
how to pass a integer value as a message header in STOMP C
Hi, I am wondering how to pass a integer value to a message header property using the STOMP C. I don't find any other information about how to set a message header with a integer value in the apr hash. Thanks! Vik
RE: how to pass a integer value as a message header in STOMP C
Hi Hiram, Do you know if CMS client for activemq supports it? Thanks! Vik -Original Message- From: [EMAIL PROTECTED] [mailto:[EMAIL PROTECTED] On Behalf Of Hiram Chirino Sent: Thursday, September 14, 2006 12:26 PM To: activemq-dev@geronimo.apache.org Subject: Re: how to pass a integer value as a message header in STOMP C Hi Vik.. I don't think stomp supports it. On 9/14/06, Dhawan, Vikram (LNG-DAY) [EMAIL PROTECTED] wrote: Hi, I am wondering how to pass a integer value to a message header property using the STOMP C. I don't find any other information about how to set a message header with a integer value in the apr hash. Thanks! Vik -- Regards, Hiram Blog: http://hiramchirino.com
multiple consumer threads in same program in STOMP issue
Hi, I am running into a strange issue, I created a consumer program using STOMP C which actually creates two separate consumer threads and both threads are reading from the same queue in the AMQ server using their own selectors on a header property. I was expecting that each thread will keep on consuming messages those who satisfy the selector conditions. But what happening here is at a time only one consumer thread is able to get its messages, another one just hangs. If I call disconnect in the thread which is working then only the hanged thread starts getting its messages. I will appreciate any explanation. Thanks! Vik
how to apply message filters in STOMP
Hi, In a STOMP client what is the way to apply a message filter. In my Consumer code I want to accept only those messages who has a particular header value in one of the message header field. Thanks! Vik
[no subject]
Hi, I have a question regarding receive/acknowledge model in AMQ. If there are 2 consumers (running on separate machines) connected to AMQ server on the same queue. Consumer-1 receives a message and don't send acknowledge. Is consumer-2 will be able to receive this messages ever without consumer-1 explicitly disconnects from the AMQ server. If yes then what is the time out (and how to set it) in AMQ server so after that time reaches the message will market as new again and will be delivered to consumer-2 without disconnecting consumer-1. Thanks! Vik
message ack timeout question.
Hi, I have a question regarding receive/acknowledge model in AMQ. If there are 2 consumers (running on separate machines) connected to AMQ server on the same queue. Consumer-1 receives a message and don't send acknowledge. Is consumer-2 will be able to receive this messages ever without consumer-1 explicitly disconnects from the AMQ server. If yes then what is the time out (and how to set it) in AMQ server so after that time reaches the message will market as new again and will be delivered to consumer-2 without disconnecting consumer-1. Thanks! Vik
RE: message ack timeout question.
Hey James, Thanks for the response, it make sense. Sorry about the empty thread, subject line was dropped in the first one so I thought I should add it and sent it again for better readability. I have noticed another thing though. If I have few messages in a queue (lets say 10) and bring consumer-1 up. If I don't call receive still consumer-1 locks all the 10 messages (and shows in the Dequeue count in JMX console). And now if I bring another consumer-2 and calls receive consumer-2 doesn't get any message. Even if I haven't received any message in consumer-1 and all the messages are still new. Please advice. Thanks! Vik -Original Message- From: James Strachan [mailto:[EMAIL PROTECTED] Sent: Thursday, July 27, 2006 11:30 AM To: activemq-dev@geronimo.apache.org Subject: Re: message ack timeout question. I just responded to the other empty thread - thought I'd resend my reply... On 7/27/06, Dhawan, Vikram (LNG-DAY) [EMAIL PROTECTED] wrote: Hi, I have a question regarding receive/acknowledge model in AMQ. If there are 2 consumers (running on separate machines) connected to AMQ server on the same queue. Consumer-1 receives a message and don't send acknowledge. Is consumer-2 will be able to receive this messages ever without consumer-1 explicitly disconnects from the AMQ server. No - consumer 2 will not receive the message until consumer 1 terminates (or is disconnected from the broker). At some point we could add some kinda inactivity timeout in consumers so that if they grab messages and don't process them we silently disconnect the consumer (so they give their prefetches back). -- James --- http://radio.weblogs.com/0112098/
RE: Should we add large String value support in MapMessage in 4.0.2 ?? re: AMQ-788
Can we set message timeout in a stomp client in the situations where STOMP client is trying to send a message and because of network issues (FIREWALL or something else) it cant not reach to the AMQ server. So instead of trying to send the message indefinitely STOMP client process will terminate. Thanks! Vik -Original Message- From: James Strachan [mailto:[EMAIL PROTECTED] Sent: Friday, July 14, 2006 1:26 PM To: activemq-dev@geronimo.apache.org Subject: Re: Should we add large String value support in MapMessage in 4.0.2 ?? re: AMQ-788 Great! Must be nearly time to cut a 4.0.2 release :) On 7/14/06, Hiram Chirino [EMAIL PROTECTED] wrote: Ok. look like there was not too much opposition to backporting this so.. I'll go ahead and do it later today. On 7/11/06, Rob Davies [EMAIL PROTECTED] wrote: +1 - sounds good to me On 11 Jul 2006, at 16:42, Hiram Chirino wrote: Hi Folks. In 4.1 we added a patch that add support of handling large string values ( 32k ) in map messages. See: http://issues.apache.org/activemq/browse/AMQ-788 I just wanted to see if you guys think we should backport that to 4.0.2also? The only down side is that a slight incompatibility in marshaling is introduced. It only affect messages that use string values 8k. With the patch once a string value is 8k, we now use a different marshaling strategy that allow for marshaling String values up to 2 gigs. So if you have = 4.0.1 clients talking to 4.0.2 clients sending map messages with String values 8k then the = 4.0.1 clients may not be able handle the messages from the 4.0.2 clients. I think it's safe enough to add since we did not support large messages anyways in 4.0.1. -- Regards, Hiram Blog: http://hiramchirino.com -- Regards, Hiram Blog: http://hiramchirino.com -- James --- http://radio.weblogs.com/0112098/
Perl Client
Is any one aware of the location of the ActiveMQ client library in Perl? The one link which is available on activemq website appears to be dead. Thanks! Vik
RE: Perl Client
I tried this link before; it appears to me that zilbo server is having some problems. I was wondering if there is any other location where we maintained a copy of that lib (may be on jira?). Vik -Original Message- From: James Strachan [mailto:[EMAIL PROTECTED] Sent: Thursday, July 13, 2006 10:19 AM To: activemq-dev@geronimo.apache.org Subject: Re: Perl Client The Stomp site has a list of the various language specific Stomp clients... http://stomp.codehaus.org/Perl+Client which points to this client... http://zilbo.com/articles/activeMQ/index.html On 7/13/06, Dhawan, Vikram (LNG-DAY) [EMAIL PROTECTED] wrote: Is any one aware of the location of the ActiveMQ client library in Perl? The one link which is available on activemq website appears to be dead. Thanks! Vik -- James --- http://radio.weblogs.com/0112098/
RE: Openwire C Client.
Hey Sunil, Use the latest AMQ SNAPSHOT and consumer should work fine. There were updates to the STOMP protocol. Consumer uses these updates and AMQ RC2 was released before these changes. Good Luck! Vik -Original Message- From: srodrigues [mailto:[EMAIL PROTECTED] Sent: Thursday, April 27, 2006 12:54 PM To: activemq-dev@geronimo.apache.org Subject: RE: Openwire C Client. The consumer just hangs and does not seem to be receiving any messages. Does anyone else have a similar problem? consumer Connecting..OK Sending connect message.OK Reading Response. -- View this message in context: http://www.nabble.com/Openwire-C-Client.-t1506711.html#a4125129 Sent from the ActiveMQ - Dev forum at Nabble.com.
RE: openwire-cpp question
Hey Hiram, I made some updates to the STOMP C implementation, which will let it build on Solaris Sun Workshop 6 and above compilers. Please let me know where you want me to post that client code. Once Openwire C++ client and CMS are stabilized I will try to do the same with those too. Thanks! Vik -Original Message- From: [EMAIL PROTECTED] [mailto:[EMAIL PROTECTED] On Behalf Of Hiram Chirino Sent: Wednesday, April 19, 2006 2:02 PM To: activemq-dev@geronimo.apache.org Subject: Re: openwire-cpp question Just do a svn co svn://svn.stomp.codehaus.org/stomp/scm stomp And you'll find all the clients under there. On 4/19/06, Dhawan, Vikram (LNG-DAY) [EMAIL PROTECTED] wrote: Hi Hiram, Thanks for the heads up. Can you please tell me where I can find your updated c client? David: are you planning to incorporate these changes in your code soon? Thanks! Vik -Original Message- From: [EMAIL PROTECTED] [mailto:[EMAIL PROTECTED] On Behalf Of Hiram Chirino Sent: Wednesday, April 19, 2006 1:51 PM To: activemq-dev@geronimo.apache.org Subject: Re: openwire-cpp question On 4/19/06, Dhawan, Vikram (LNG-DAY) [EMAIL PROTECTED] wrote: Hey David, I was able to build this code on Sun Workshop 8, I had to put some OS dependant condition checks, like you have for MACOS and have to modify code a little bit here and there nothing major. I am able to run it with AMQ-RC2 but when I tried to run it with latest SNAPSHOT (04/18) it was getting stuck after receiving BROKER_INFO command. Wireformat may have changed a little.. perhaps we need to regenerate the openwire marshaller for c++ I am not sure if latest SNAPSHOT is having issues because I had the same problem with the STOMP C client it was getting stuck after sending the SUB command. There's been a small change to the stomp marshal ling. Before we were inconsistently adding \n after the \0 frame terminator. So I changed the activemq side to all ways consistently add the \n after the frame. It also expects frames that are sent to it to also have the \n. I could rollback the requirement for frames that it receive have a \n, but I think it would be better if the stomp protocol was a bit more consistent and just did things 1 way. So this could be what has broken some of the stomp clients. I've updated the c and ruby ones so that they work once again. Thanks! Vik -Original Message- From: David Fahlander [mailto:[EMAIL PROTECTED] Sent: Wednesday, April 19, 2006 5:03 AM To: activemq-dev@geronimo.apache.org Subject: RE: openwire-cpp question This code compiles and runs on GCC 3, GCC 4 and Visual Studio 2005. We have never tried to compile it with Sun compiler. The code is tested and can communicate with text messages with the broker (as our test code does). Hope to get the time to make the code compile with more C++ compilers as soon as we get to a point where the code becomes complete. David -Original Message- From: Dhawan, Vikram (LNG-DAY) [mailto:[EMAIL PROTECTED] Sent: den 18 april 2006 23:37 To: activemq-dev@geronimo.apache.org Subject: RE: openwire-cpp question Hi David, I tried that code earlier and ran in to build issues, there are lots of things in this code what Sun Compiler didn't liked. Is this code tested? Thanks! Vik -Original Message- From: David Fahlander [mailto:[EMAIL PROTECTED] Sent: Tuesday, April 18, 2006 2:55 AM To: activemq-dev@geronimo.apache.org Cc: Mats Forslöf Subject: RE: openwire-cpp question The latest code is of the openwire cpp client was uploaded as a jira patch at http://issues.apache.org/activemq/browse/AMQ-656. The latest version is called source 060406.zip. It contains the full source tree as well as make files and a test program. /David -Original Message- From: Mittler, Nathan [mailto:[EMAIL PROTECTED] Sent: den 17 april 2006 17:28 To: activemq-dev@geronimo.apache.org Cc: Mats Forslöf Subject: RE: openwire-cpp question Hi Mats, Is the code in svn your latest? I remember you including unit tests and makefiles at some point - did these get lost when the last patch was applied? -Original Message- From: Dhawan, Vikram (LNG-DAY) [mailto:[EMAIL PROTECTED] Sent: Monday, April 17, 2006 11:08 AM To: activemq-dev@geronimo.apache.org Subject: RE: openwire-cpp question There is no test stub either. I am wondering if someone ever tested it? Vik -Original Message- From: Mittler, Nathan [mailto:[EMAIL PROTECTED] Sent: Monday, April 17, 2006 11:01 AM To: activemq-dev@geronimo.apache.org Subject: RE: openwire-cpp question Hmm ... that surprises me - I know the openwire-cpp team had included makefiles in the past. I believe the code should support linux, windows, OSX. Does anyone know where the makefiles are? -Original Message- From: Dhawan
RE: Openwire C Client.
Sunil, I posted the src code for C client on JIRA you can get to it from this link. http://issues.apache.org/activemq/browse/AMQ-693 For this you need to install APR on your solaris server if you don't already have apr on the box. You can get apr from http://apr.apache.org/. Good luck. Vik -Original Message- From: srodrigues [mailto:[EMAIL PROTECTED] Sent: Tuesday, April 25, 2006 1:16 PM To: activemq-dev@geronimo.apache.org Subject: Openwire C Client. I am fairly new to Unix based dev. so pardon me if I ask obvious questions. I am using ActiveMQ 3.1, but could upgrade it if required. We required a C Client for Unix Sun Solaris and I could not get correct documentation. I started at this location: http://stomp.codehaus.org/libstomp+Examples Then, downloaded the main.c example there, I downloaded it's other dependencies files from this location: http://www.activemq.org/OpenWire+C+Client Then, I built a make file for the example sample and required to down load the Apache Portable Runtime library, compiled and installed it at my /usr/local/apr I got a little ahead with these steps and got the example to compile but am still having linking errors. Undefined first referenced symbol in file __umoddi3 /usr/local/apr/lib/libapr-1.so __divdi3/usr/local/apr/lib/libapr-1.so Could someone let me know if I am on the right path or have any other documentation would help me compile this sample code for C Client correctly. Thanks very much in advance. Sunil Rodrigues -- View this message in context: http://www.nabble.com/Openwire-C-Client.-t1506711.html#a4086304 Sent from the ActiveMQ - Dev forum at Nabble.com.
RE: openwire-cpp question
Mats, Where do you want me to post the changes? Please let me know. Thanks! Vik -Original Message- From: Mats Forslöf [mailto:[EMAIL PROTECTED] Sent: Thursday, April 20, 2006 3:50 AM To: activemq-dev@geronimo.apache.org Subject: RE: openwire-cpp question Hi Vik, Just a quick note regarding the OpenWire C++ client; the client is a work in progress, it has not been released yet - so expect bugs! We're playing catch-up with the broker and the C#-client and we didn't have the information on the protocol change until now. We will of course update the client with any protocol changes but we cannot give you a time fram other than as soon as possible. Can you please post the changes you had to make for compiling it on the Sun compiler, thanks. Regards, Mats -Original Message- From: Dhawan, Vikram (LNG-DAY) [mailto:[EMAIL PROTECTED] Sent: den 19 april 2006 19:55 To: activemq-dev@geronimo.apache.org Subject: RE: openwire-cpp question Hi Hiram, Thanks for the heads up. Can you please tell me where I can find your updated c client? David: are you planning to incorporate these changes in your code soon? Thanks! Vik -Original Message- From: [EMAIL PROTECTED] [mailto:[EMAIL PROTECTED] On Behalf Of Hiram Chirino Sent: Wednesday, April 19, 2006 1:51 PM To: activemq-dev@geronimo.apache.org Subject: Re: openwire-cpp question On 4/19/06, Dhawan, Vikram (LNG-DAY) [EMAIL PROTECTED] wrote: Hey David, I was able to build this code on Sun Workshop 8, I had to put some OS dependant condition checks, like you have for MACOS and have to modify code a little bit here and there nothing major. I am able to run it with AMQ-RC2 but when I tried to run it with latest SNAPSHOT (04/18) it was getting stuck after receiving BROKER_INFO command. Wireformat may have changed a little.. perhaps we need to regenerate the openwire marshaller for c++ I am not sure if latest SNAPSHOT is having issues because I had the same problem with the STOMP C client it was getting stuck after sending the SUB command. There's been a small change to the stomp marshal ling. Before we were inconsistently adding \n after the \0 frame terminator. So I changed the activemq side to all ways consistently add the \n after the frame. It also expects frames that are sent to it to also have the \n. I could rollback the requirement for frames that it receive have a \n, but I think it would be better if the stomp protocol was a bit more consistent and just did things 1 way. So this could be what has broken some of the stomp clients. I've updated the c and ruby ones so that they work once again. Thanks! Vik -Original Message- From: David Fahlander [mailto:[EMAIL PROTECTED] Sent: Wednesday, April 19, 2006 5:03 AM To: activemq-dev@geronimo.apache.org Subject: RE: openwire-cpp question This code compiles and runs on GCC 3, GCC 4 and Visual Studio 2005. We have never tried to compile it with Sun compiler. The code is tested and can communicate with text messages with the broker (as our test code does). Hope to get the time to make the code compile with more C++ compilers as soon as we get to a point where the code becomes complete. David -Original Message- From: Dhawan, Vikram (LNG-DAY) [mailto:[EMAIL PROTECTED] Sent: den 18 april 2006 23:37 To: activemq-dev@geronimo.apache.org Subject: RE: openwire-cpp question Hi David, I tried that code earlier and ran in to build issues, there are lots of things in this code what Sun Compiler didn't liked. Is this code tested? Thanks! Vik -Original Message- From: David Fahlander [mailto:[EMAIL PROTECTED] Sent: Tuesday, April 18, 2006 2:55 AM To: activemq-dev@geronimo.apache.org Cc: Mats Forslöf Subject: RE: openwire-cpp question The latest code is of the openwire cpp client was uploaded as a jira patch at http://issues.apache.org/activemq/browse/AMQ-656. The latest version is called source 060406.zip. It contains the full source tree as well as make files and a test program. /David -Original Message- From: Mittler, Nathan [mailto:[EMAIL PROTECTED] Sent: den 17 april 2006 17:28 To: activemq-dev@geronimo.apache.org Cc: Mats Forslöf Subject: RE: openwire-cpp question Hi Mats, Is the code in svn your latest? I remember you including unit tests and makefiles at some point - did these get lost when the last patch was applied? -Original Message- From: Dhawan, Vikram (LNG-DAY) [mailto:[EMAIL PROTECTED] Sent: Monday, April 17, 2006 11:08 AM To: activemq-dev@geronimo.apache.org Subject: RE: openwire-cpp question There is no test stub either. I am wondering if someone ever tested it? Vik -Original Message- From: Mittler, Nathan [mailto:[EMAIL PROTECTED] Sent: Monday, April 17, 2006 11:01 AM To: activemq-dev@geronimo.apache.org Subject: RE: openwire-cpp question Hmm ... that surprises me - I know the openwire-cpp team had included
RE: openwire-cpp question
Hey David, I was able to build this code on Sun Workshop 8, I had to put some OS dependant condition checks, like you have for MACOS and have to modify code a little bit here and there nothing major. I am able to run it with AMQ-RC2 but when I tried to run it with latest SNAPSHOT (04/18) it was getting stuck after receiving BROKER_INFO command. I am not sure if latest SNAPSHOT is having issues because I had the same problem with the STOMP C client it was getting stuck after sending the SUB command. Thanks! Vik -Original Message- From: David Fahlander [mailto:[EMAIL PROTECTED] Sent: Wednesday, April 19, 2006 5:03 AM To: activemq-dev@geronimo.apache.org Subject: RE: openwire-cpp question This code compiles and runs on GCC 3, GCC 4 and Visual Studio 2005. We have never tried to compile it with Sun compiler. The code is tested and can communicate with text messages with the broker (as our test code does). Hope to get the time to make the code compile with more C++ compilers as soon as we get to a point where the code becomes complete. David -Original Message- From: Dhawan, Vikram (LNG-DAY) [mailto:[EMAIL PROTECTED] Sent: den 18 april 2006 23:37 To: activemq-dev@geronimo.apache.org Subject: RE: openwire-cpp question Hi David, I tried that code earlier and ran in to build issues, there are lots of things in this code what Sun Compiler didn't liked. Is this code tested? Thanks! Vik -Original Message- From: David Fahlander [mailto:[EMAIL PROTECTED] Sent: Tuesday, April 18, 2006 2:55 AM To: activemq-dev@geronimo.apache.org Cc: Mats Forslöf Subject: RE: openwire-cpp question The latest code is of the openwire cpp client was uploaded as a jira patch at http://issues.apache.org/activemq/browse/AMQ-656. The latest version is called source 060406.zip. It contains the full source tree as well as make files and a test program. /David -Original Message- From: Mittler, Nathan [mailto:[EMAIL PROTECTED] Sent: den 17 april 2006 17:28 To: activemq-dev@geronimo.apache.org Cc: Mats Forslöf Subject: RE: openwire-cpp question Hi Mats, Is the code in svn your latest? I remember you including unit tests and makefiles at some point - did these get lost when the last patch was applied? -Original Message- From: Dhawan, Vikram (LNG-DAY) [mailto:[EMAIL PROTECTED] Sent: Monday, April 17, 2006 11:08 AM To: activemq-dev@geronimo.apache.org Subject: RE: openwire-cpp question There is no test stub either. I am wondering if someone ever tested it? Vik -Original Message- From: Mittler, Nathan [mailto:[EMAIL PROTECTED] Sent: Monday, April 17, 2006 11:01 AM To: activemq-dev@geronimo.apache.org Subject: RE: openwire-cpp question Hmm ... that surprises me - I know the openwire-cpp team had included makefiles in the past. I believe the code should support linux, windows, OSX. Does anyone know where the makefiles are? -Original Message- From: Dhawan, Vikram (LNG-DAY) [mailto:[EMAIL PROTECTED] Sent: Monday, April 17, 2006 10:08 AM To: activemq-dev@geronimo.apache.org Subject: RE: openwire-cpp question Hey Nate, I don't see any make file or something in there? Do you have any idea what O/S version and C++ complier this code recommends? Thanks! Vik -Original Message- From: Nathan Mittler [mailto:[EMAIL PROTECTED] Sent: Monday, April 17, 2006 6:16 AM To: activemq-dev@geronimo.apache.org Subject: Re: openwire-cpp question The latter - It's a client-side library. The same is true for the Stomp CMS lib and the openwire .NET lib. Regards, Nate On 4/16/06, vik Dhawan [EMAIL PROTECTED] wrote: I wanted to know the use of Development branch on SVN at http://svn.apache.org/repos/asf/incubator/activemq/trunk/openwire-cpp/ Is this a C++ implementation of ActiveMQ? is it complete? or is it can be used as a C++ library so some application can use classes in this library to connect to a remote AMQ server? Thanks! -- View this message in context: http://www.nabble.com/openwire-cpp-question-t1459989.html#a3945792 Sent from the ActiveMQ - Dev forum at Nabble.com.
RE: openwire-cpp question
Hi Hiram, Thanks for the heads up. Can you please tell me where I can find your updated c client? David: are you planning to incorporate these changes in your code soon? Thanks! Vik -Original Message- From: [EMAIL PROTECTED] [mailto:[EMAIL PROTECTED] On Behalf Of Hiram Chirino Sent: Wednesday, April 19, 2006 1:51 PM To: activemq-dev@geronimo.apache.org Subject: Re: openwire-cpp question On 4/19/06, Dhawan, Vikram (LNG-DAY) [EMAIL PROTECTED] wrote: Hey David, I was able to build this code on Sun Workshop 8, I had to put some OS dependant condition checks, like you have for MACOS and have to modify code a little bit here and there nothing major. I am able to run it with AMQ-RC2 but when I tried to run it with latest SNAPSHOT (04/18) it was getting stuck after receiving BROKER_INFO command. Wireformat may have changed a little.. perhaps we need to regenerate the openwire marshaller for c++ I am not sure if latest SNAPSHOT is having issues because I had the same problem with the STOMP C client it was getting stuck after sending the SUB command. There's been a small change to the stomp marshal ling. Before we were inconsistently adding \n after the \0 frame terminator. So I changed the activemq side to all ways consistently add the \n after the frame. It also expects frames that are sent to it to also have the \n. I could rollback the requirement for frames that it receive have a \n, but I think it would be better if the stomp protocol was a bit more consistent and just did things 1 way. So this could be what has broken some of the stomp clients. I've updated the c and ruby ones so that they work once again. Thanks! Vik -Original Message- From: David Fahlander [mailto:[EMAIL PROTECTED] Sent: Wednesday, April 19, 2006 5:03 AM To: activemq-dev@geronimo.apache.org Subject: RE: openwire-cpp question This code compiles and runs on GCC 3, GCC 4 and Visual Studio 2005. We have never tried to compile it with Sun compiler. The code is tested and can communicate with text messages with the broker (as our test code does). Hope to get the time to make the code compile with more C++ compilers as soon as we get to a point where the code becomes complete. David -Original Message- From: Dhawan, Vikram (LNG-DAY) [mailto:[EMAIL PROTECTED] Sent: den 18 april 2006 23:37 To: activemq-dev@geronimo.apache.org Subject: RE: openwire-cpp question Hi David, I tried that code earlier and ran in to build issues, there are lots of things in this code what Sun Compiler didn't liked. Is this code tested? Thanks! Vik -Original Message- From: David Fahlander [mailto:[EMAIL PROTECTED] Sent: Tuesday, April 18, 2006 2:55 AM To: activemq-dev@geronimo.apache.org Cc: Mats Forslöf Subject: RE: openwire-cpp question The latest code is of the openwire cpp client was uploaded as a jira patch at http://issues.apache.org/activemq/browse/AMQ-656. The latest version is called source 060406.zip. It contains the full source tree as well as make files and a test program. /David -Original Message- From: Mittler, Nathan [mailto:[EMAIL PROTECTED] Sent: den 17 april 2006 17:28 To: activemq-dev@geronimo.apache.org Cc: Mats Forslöf Subject: RE: openwire-cpp question Hi Mats, Is the code in svn your latest? I remember you including unit tests and makefiles at some point - did these get lost when the last patch was applied? -Original Message- From: Dhawan, Vikram (LNG-DAY) [mailto:[EMAIL PROTECTED] Sent: Monday, April 17, 2006 11:08 AM To: activemq-dev@geronimo.apache.org Subject: RE: openwire-cpp question There is no test stub either. I am wondering if someone ever tested it? Vik -Original Message- From: Mittler, Nathan [mailto:[EMAIL PROTECTED] Sent: Monday, April 17, 2006 11:01 AM To: activemq-dev@geronimo.apache.org Subject: RE: openwire-cpp question Hmm ... that surprises me - I know the openwire-cpp team had included makefiles in the past. I believe the code should support linux, windows, OSX. Does anyone know where the makefiles are? -Original Message- From: Dhawan, Vikram (LNG-DAY) [mailto:[EMAIL PROTECTED] Sent: Monday, April 17, 2006 10:08 AM To: activemq-dev@geronimo.apache.org Subject: RE: openwire-cpp question Hey Nate, I don't see any make file or something in there? Do you have any idea what O/S version and C++ complier this code recommends? Thanks! Vik -Original Message- From: Nathan Mittler [mailto:[EMAIL PROTECTED] Sent: Monday, April 17, 2006 6:16 AM To: activemq-dev@geronimo.apache.org Subject: Re: openwire-cpp question The latter - It's a client-side library. The same is true for the Stomp CMS lib and the openwire .NET lib. Regards, Nate On 4/16/06, vik Dhawan [EMAIL PROTECTED] wrote: I wanted to know the use of Development branch on SVN at http://svn.apache.org/repos/asf/incubator/activemq/trunk/openwire-cpp
RE: openwire-cpp question
Hi Hiram, I just finished testing 04/18 SNAPSHOT using your latest stomp c client code. I spitted this in to separate producer and consumer. Here are the observations: 1. If I have consumer running and produce messages it works fine now, not getting duplicate messages at consumer. 2. If I queue up the messages (more then 10) and then start the consumer in a loop consumer don't get any of the stored messages. It behaves like there is no message in the queue. I m using MySQL as backend storage for messages. 3. Every now and then I get following warning message on AMQ server console. WARN ManagedTransportConnection - Failed to unregister mbean: org.apache.activemq:BrokerName=localhost,Type=Connection,ConnectorName =stomp,Connection=ID_server_name.com-33921-1145484700831- 3_23 Thanks! Vik -Original Message- From: [EMAIL PROTECTED] [mailto:[EMAIL PROTECTED] On Behalf Of Hiram Chirino Sent: Wednesday, April 19, 2006 2:02 PM To: activemq-dev@geronimo.apache.org Subject: Re: openwire-cpp question Just do a svn co svn://svn.stomp.codehaus.org/stomp/scm stomp And you'll find all the clients under there. On 4/19/06, Dhawan, Vikram (LNG-DAY) [EMAIL PROTECTED] wrote: Hi Hiram, Thanks for the heads up. Can you please tell me where I can find your updated c client? David: are you planning to incorporate these changes in your code soon? Thanks! Vik -Original Message- From: [EMAIL PROTECTED] [mailto:[EMAIL PROTECTED] On Behalf Of Hiram Chirino Sent: Wednesday, April 19, 2006 1:51 PM To: activemq-dev@geronimo.apache.org Subject: Re: openwire-cpp question On 4/19/06, Dhawan, Vikram (LNG-DAY) [EMAIL PROTECTED] wrote: Hey David, I was able to build this code on Sun Workshop 8, I had to put some OS dependant condition checks, like you have for MACOS and have to modify code a little bit here and there nothing major. I am able to run it with AMQ-RC2 but when I tried to run it with latest SNAPSHOT (04/18) it was getting stuck after receiving BROKER_INFO command. Wireformat may have changed a little.. perhaps we need to regenerate the openwire marshaller for c++ I am not sure if latest SNAPSHOT is having issues because I had the same problem with the STOMP C client it was getting stuck after sending the SUB command. There's been a small change to the stomp marshal ling. Before we were inconsistently adding \n after the \0 frame terminator. So I changed the activemq side to all ways consistently add the \n after the frame. It also expects frames that are sent to it to also have the \n. I could rollback the requirement for frames that it receive have a \n, but I think it would be better if the stomp protocol was a bit more consistent and just did things 1 way. So this could be what has broken some of the stomp clients. I've updated the c and ruby ones so that they work once again. Thanks! Vik -Original Message- From: David Fahlander [mailto:[EMAIL PROTECTED] Sent: Wednesday, April 19, 2006 5:03 AM To: activemq-dev@geronimo.apache.org Subject: RE: openwire-cpp question This code compiles and runs on GCC 3, GCC 4 and Visual Studio 2005. We have never tried to compile it with Sun compiler. The code is tested and can communicate with text messages with the broker (as our test code does). Hope to get the time to make the code compile with more C++ compilers as soon as we get to a point where the code becomes complete. David -Original Message- From: Dhawan, Vikram (LNG-DAY) [mailto:[EMAIL PROTECTED] Sent: den 18 april 2006 23:37 To: activemq-dev@geronimo.apache.org Subject: RE: openwire-cpp question Hi David, I tried that code earlier and ran in to build issues, there are lots of things in this code what Sun Compiler didn't liked. Is this code tested? Thanks! Vik -Original Message- From: David Fahlander [mailto:[EMAIL PROTECTED] Sent: Tuesday, April 18, 2006 2:55 AM To: activemq-dev@geronimo.apache.org Cc: Mats Forslöf Subject: RE: openwire-cpp question The latest code is of the openwire cpp client was uploaded as a jira patch at http://issues.apache.org/activemq/browse/AMQ-656. The latest version is called source 060406.zip. It contains the full source tree as well as make files and a test program. /David -Original Message- From: Mittler, Nathan [mailto:[EMAIL PROTECTED] Sent: den 17 april 2006 17:28 To: activemq-dev@geronimo.apache.org Cc: Mats Forslöf Subject: RE: openwire-cpp question Hi Mats, Is the code in svn your latest? I remember you including unit tests and makefiles at some point - did these get lost when the last patch was applied? -Original Message- From: Dhawan, Vikram (LNG-DAY) [mailto:[EMAIL PROTECTED] Sent: Monday, April 17, 2006 11:08 AM To: activemq-dev@geronimo.apache.org Subject: RE: openwire-cpp question
RE: AMQ acting funny
Hi Hiram, Is 04/18 SNAPSHOT is good enough to test this? Thanks! Vik -Original Message- From: [EMAIL PROTECTED] [mailto:[EMAIL PROTECTED] On Behalf Of Hiram Chirino Sent: Tuesday, April 18, 2006 9:10 AM To: activemq-dev@geronimo.apache.org Subject: Re: AMQ acting funny Hi, I recently fix a synchronization bug in the STOMP connector. Please wait for the next SNAPSHOT and test it again. On 4/10/06, vik Dhawan [EMAIL PROTECTED] wrote: Hi, I am noticing a weird behavior in AMQ today, things works fine if i produce one message and consume that message before producing another one. But if i start producing messages faster then a consumer can consume, or if i produce lots of messages and then start consumer to consume messages; some times for a Queue, consumer hangs and do not consume produced messages. I noticed in JConsole JMX interface that its showing me consumer count of 2 where i am only running one consumer. Environment: Running AMQ on Linux box and running simple C STOMP producer and consumer on Solaris box. Thanks! -- View this message in context: http://www.nabble.com/AMQ-acting-funny-t1427411.html#a3849503 Sent from the ActiveMQ - Dev forum at Nabble.com. -- Regards, Hiram
RE: AMQ acting funny
Hi Hiram, I just tried 04/18 snapshot with my STOMP c consumer. Consumer is getting connected and successfully able to send the SUB command. But when it starts reading a message after the SUB command it's giving me internal error can not read frame, instead of waiting for a message to come. Any idea? Thanks! Vik -Original Message- From: [EMAIL PROTECTED] [mailto:[EMAIL PROTECTED] On Behalf Of Hiram Chirino Sent: Tuesday, April 18, 2006 10:31 AM To: activemq-dev@geronimo.apache.org Subject: Re: AMQ acting funny yes I think so. On 4/18/06, Dhawan, Vikram (LNG-DAY) [EMAIL PROTECTED] wrote: Hi Hiram, Is 04/18 SNAPSHOT is good enough to test this? Thanks! Vik -Original Message- From: [EMAIL PROTECTED] [mailto:[EMAIL PROTECTED] On Behalf Of Hiram Chirino Sent: Tuesday, April 18, 2006 9:10 AM To: activemq-dev@geronimo.apache.org Subject: Re: AMQ acting funny Hi, I recently fix a synchronization bug in the STOMP connector. Please wait for the next SNAPSHOT and test it again. On 4/10/06, vik Dhawan [EMAIL PROTECTED] wrote: Hi, I am noticing a weird behavior in AMQ today, things works fine if i produce one message and consume that message before producing another one. But if i start producing messages faster then a consumer can consume, or if i produce lots of messages and then start consumer to consume messages; some times for a Queue, consumer hangs and do not consume produced messages. I noticed in JConsole JMX interface that its showing me consumer count of 2 where i am only running one consumer. Environment: Running AMQ on Linux box and running simple C STOMP producer and consumer on Solaris box. Thanks! -- View this message in context: http://www.nabble.com/AMQ-acting-funny-t1427411.html#a3849503 Sent from the ActiveMQ - Dev forum at Nabble.com. -- Regards, Hiram -- Regards, Hiram
RE: AMQ acting funny
Hi James, I guess I don't understand your question. Do you want me to use some Junit test case for this one? Or you are asking me to put my code as a Junit test case? If earlier is correct I don't have the code for Junit test case. If later is correct then my client stub is written in C for STOMP, please tell me how to do that and I will do it. Thanks! Vik -Original Message- From: James Strachan [mailto:[EMAIL PROTECTED] Sent: Tuesday, April 18, 2006 5:34 AM To: activemq-dev@geronimo.apache.org Subject: Re: AMQ acting funny Any chance you can reproduce this in a JUnit test case? On 4/10/06, vik Dhawan [EMAIL PROTECTED] wrote: Hi, I am noticing a weird behavior in AMQ today, things works fine if i produce one message and consume that message before producing another one. But if i start producing messages faster then a consumer can consume, or if i produce lots of messages and then start consumer to consume messages; some times for a Queue, consumer hangs and do not consume produced messages. I noticed in JConsole JMX interface that its showing me consumer count of 2 where i am only running one consumer. Environment: Running AMQ on Linux box and running simple C STOMP producer and consumer on Solaris box. Thanks! -- View this message in context: http://www.nabble.com/AMQ-acting-funny-t1427411.html#a3849503 Sent from the ActiveMQ - Dev forum at Nabble.com. -- James --- http://radio.weblogs.com/0112098/
RE: STOMP bytes messages
Hey Nate, Where can I get latest working code for your CMS client? Thanks! Vik -Original Message- From: Mittler, Nathan [mailto:[EMAIL PROTECTED] Sent: Monday, April 17, 2006 12:10 PM To: activemq-dev@geronimo.apache.org Subject: RE: STOMP bytes messages Great - keep me posted. At this point, I'll be happy just to see data coming back for the bytes message ... no guarantees as to whether the CMS client processes it correctly :) Regards, Nate -Original Message- From: [EMAIL PROTECTED] [mailto:[EMAIL PROTECTED] On Behalf Of Hiram Chirino Sent: Monday, April 17, 2006 11:45 AM To: activemq-dev@geronimo.apache.org Subject: Re: STOMP bytes messages Hi Nathan, Yep. found a bunch of issues. Next up is trying your c++ client. Regards, Hiram
RE: STOMP bytes messages
Thanks Nate, I will try to build it on Solaris and wait for your fixes. I am just wondering where we are maintaining CMS + Openwire integration. Thanks! Vik -Original Message- From: Mittler, Nathan [mailto:[EMAIL PROTECTED] Sent: Monday, April 17, 2006 12:58 PM To: activemq-dev@geronimo.apache.org Subject: RE: STOMP bytes messages The CMS STOMP client code is here https://svn.apache.org/repos/asf/incubator/activemq/trunk/cms/ I'm currently in the middle of working out a couple of issues (with the help of Hiram), but I'm at work and don't have access to that code at the moment. I should have those fixes posed in a few days or so. Regards, Nate -Original Message- From: Dhawan, Vikram (LNG-DAY) [mailto:[EMAIL PROTECTED] Sent: Monday, April 17, 2006 12:17 PM To: activemq-dev@geronimo.apache.org Subject: RE: STOMP bytes messages Hey Nate, Where can I get latest working code for your CMS client? Thanks! Vik -Original Message- From: Mittler, Nathan [mailto:[EMAIL PROTECTED] Sent: Monday, April 17, 2006 12:10 PM To: activemq-dev@geronimo.apache.org Subject: RE: STOMP bytes messages Great - keep me posted. At this point, I'll be happy just to see data coming back for the bytes message ... no guarantees as to whether the CMS client processes it correctly :) Regards, Nate -Original Message- From: [EMAIL PROTECTED] [mailto:[EMAIL PROTECTED] On Behalf Of Hiram Chirino Sent: Monday, April 17, 2006 11:45 AM To: activemq-dev@geronimo.apache.org Subject: Re: STOMP bytes messages Hi Nathan, Yep. found a bunch of issues. Next up is trying your c++ client. Regards, Hiram
RE: STOMP bytes messages
Nate, This code doesn't support Queues, right? Thanks! Vik -Original Message- From: Mittler, Nathan [mailto:[EMAIL PROTECTED] Sent: Monday, April 17, 2006 12:58 PM To: activemq-dev@geronimo.apache.org Subject: RE: STOMP bytes messages The CMS STOMP client code is here https://svn.apache.org/repos/asf/incubator/activemq/trunk/cms/ I'm currently in the middle of working out a couple of issues (with the help of Hiram), but I'm at work and don't have access to that code at the moment. I should have those fixes posed in a few days or so. Regards, Nate -Original Message- From: Dhawan, Vikram (LNG-DAY) [mailto:[EMAIL PROTECTED] Sent: Monday, April 17, 2006 12:17 PM To: activemq-dev@geronimo.apache.org Subject: RE: STOMP bytes messages Hey Nate, Where can I get latest working code for your CMS client? Thanks! Vik -Original Message- From: Mittler, Nathan [mailto:[EMAIL PROTECTED] Sent: Monday, April 17, 2006 12:10 PM To: activemq-dev@geronimo.apache.org Subject: RE: STOMP bytes messages Great - keep me posted. At this point, I'll be happy just to see data coming back for the bytes message ... no guarantees as to whether the CMS client processes it correctly :) Regards, Nate -Original Message- From: [EMAIL PROTECTED] [mailto:[EMAIL PROTECTED] On Behalf Of Hiram Chirino Sent: Monday, April 17, 2006 11:45 AM To: activemq-dev@geronimo.apache.org Subject: Re: STOMP bytes messages Hi Nathan, Yep. found a bunch of issues. Next up is trying your c++ client. Regards, Hiram
RE: Openwire C client issue
Hi Hiram, Is any one maintaining working copy of that code now? I tried to add that command type in the header that didn't worked either. Thanks! Vik -Original Message- From: [EMAIL PROTECTED] [mailto:[EMAIL PROTECTED] On Behalf Of Hiram Chirino Sent: Thursday, April 13, 2006 1:09 PM To: activemq-dev@geronimo.apache.org Subject: Re: Openwire C client issue looks like some new command types were added but we forgot to add them to the header file that defines the id of command types. On 4/13/06, Dhawan, Vikram (LNG-DAY) [EMAIL PROTECTED] wrote: Hi Hiram, I saw that it was your initiative to write the openwire C client. For the following issue I was kind of hoping a direction. I am not sure if you delegated this responsibility to some other team member. I will really appreciate if I can get a help in understanding what is happening in this code. Thanks! Vik -Original Message- From: vik Dhawan [mailto:[EMAIL PROTECTED] Sent: Wednesday, April 12, 2006 1:36 AM To: activemq-dev@geronimo.apache.org Subject: Openwire C client issue Hi, When i am trying to build Openwire C client i am getting following errors in ow_commands_v1.c. CC -mt -D_REENTRANT -DNO_SSL -DSAPI_LINUX -DOS_LINUX_2_2 -DEFX -DLINUX -D_GNU_SOURCE -DADDR_SRV -D_LARGEFILE64_SOURCE=1 -D_FILE_OFFSET_BITS=64 -DHTREE -I../libactivemq -I../libopenwire -I/usr/local/apr/include/apr-1 -L/usr/local/apr/lib-c -o ow_commands_v1.o ../libopenwire/ow_commands_v1.c ../libopenwire/ow_commands_v1.c, line 416: Error: OW_FLUSHCOMMAND_TYPE is not defined. ../libopenwire/ow_commands_v1.c, line 416: Error: An integer constant expression is required for a case label. ../libopenwire/ow_commands_v1.c, line 1580: Error: OW_FLUSHCOMMAND_TYPE is not defined. ../libopenwire/ow_commands_v1.c, line 1580: Error: An integer constant expression is required for a case label. ../libopenwire/ow_commands_v1.c, line 1591: Error: OW_FLUSHCOMMAND_TYPE is not defined. ../libopenwire/ow_commands_v1.c, line 2533: Error: OW_FLUSHCOMMAND_TYPE is not defined. ../libopenwire/ow_commands_v1.c, line 2533: Error: An integer constant expression is required for a case label. ../libopenwire/ow_commands_v1.c, line 2533: Error: Case label defined twice. ../libopenwire/ow_commands_v1.c, line 2586: Error: OW_FLUSHCOMMAND_TYPE is not defined. ../libopenwire/ow_commands_v1.c, line 2586: Error: An integer constant expression is required for a case label. ../libopenwire/ow_commands_v1.c, line 2586: Error: Case label defined twice. ../libopenwire/ow_commands_v1.c, line 2639: Error: OW_FLUSHCOMMAND_TYPE is not defined. ../libopenwire/ow_commands_v1.c, line 2639: Error: An integer constant expression is required for a case label. ../libopenwire/ow_commands_v1.c, line 2639: Error: Case label defined twice. ../libopenwire/ow_commands_v1.c, line 2692: Error: OW_FLUSHCOMMAND_TYPE is not defined. ../libopenwire/ow_commands_v1.c, line 2692: Error: An integer constant expression is required for a case label. ../libopenwire/ow_commands_v1.c, line 2692: Error: Case label defined twice. Any insight Thanks! -- View this message in context: http://www.nabble.com/Openwire-C-client-issue-t1436230.html#a3875953 Sent from the ActiveMQ - Dev forum at Nabble.com. -- Regards, Hiram
RE: CMS C++ client compatibility on Solaris
Hey Nate, I have collogue who is a solris/c++ expert. I asked him if he is interested, he is interested to help. He is not a member of activeMQ community and has few questions regarding your implementation before; he can put something in there. Is it possible for you to have direct communication with him? If yes tell me yr email and I will introduce him to you. Thanks! Vik -Original Message- From: Mittler, Nathan [mailto:[EMAIL PROTECTED] Sent: Tuesday, April 11, 2006 9:55 AM To: activemq-dev@geronimo.apache.org Subject: RE: CMS C++ client compatibility on Solaris Not to my knowledge. I don't personally have a solaris box available for testing, but if you'd like to take a stab at it, I would welcome any patches. Regards, Nate -Original Message- From: vik Dhawan [mailto:[EMAIL PROTECTED] Sent: Tuesday, April 11, 2006 9:44 AM To: activemq-dev@geronimo.apache.org Subject: CMS C++ client compatibility on Solaris Has any one tried to build latest C++ CMS code on Solaris 9? I tried to do that and ran into so many issues, for example semaphore specific functions and all. Please let me know. Thanks! -- View this message in context: http://www.nabble.com/CMS-C%2B%2B-client-compatibility-on-Solaris-t14318 64.html#a3861924 Sent from the ActiveMQ - Dev forum at Nabble.com.
RE: [VOTE] ActiveMQ 4.0 RC3
When I use STOMP C I am noticing similar problem in AMQ-RC3. If there are more then 1 message in the queue and I start consumer it hangs, and don't consume any messages in the queue. Thanks! Vik -Original Message- From: [EMAIL PROTECTED] [mailto:[EMAIL PROTECTED] On Behalf Of Hiram Chirino Sent: Tuesday, April 11, 2006 9:50 AM To: activemq-dev@geronimo.apache.org Subject: [VOTE] ActiveMQ 4.0 RC3 Hi Guys, We have a new RC3 cut of 4.0. I've posted it here: http://people.apache.org/~chirino/incubator-activemq-4.0-RC3/distributions/ I've tagged the source for that build as: https://svn.apache.org/repos/asf/incubator/activemq/tags/activemq-4.0-RC3/ac tivemq [ ] +1 Release the binary as ActiveMQ 4.0-RC3 [ ] -1 Veto the release (provide specific comments) If this vote passes, then we will then ask the Incubator PMC for their blessing before the official release. -- Regards, Hiram
RE: JMX exception
James, Thanks for your help. I will look at the latest SVN HEAD and let you know. Vik -Original Message- From: James Strachan [mailto:[EMAIL PROTECTED] Sent: Thursday, March 30, 2006 4:17 AM To: activemq-dev@geronimo.apache.org Subject: Re: JMX exception I've just reviewed the code - there was one possible code path (recovery) which could access the collection which was causing the concurrent modification exception. All other accesses are within a synchronized block so there is no possibility of the concurrent access exception. I wonder could you retry with SVN HEAD to see if you can still produce this? James On 3/24/06, vik Dhawan [EMAIL PROTECTED] wrote: I looked at the code for method removeMessage() in the org.apache.activemq.broker.region.Queue Class. This code is removing a message from the fail-fast iterator obtained in the code. It's definitely a hot spot for java.util.ConcurrentModificationException what i am seeing. I am not sure why developer of this code have chosen this implementation when its clearly written in Sun Collection Java docs for iterators. I will really appreciate if some one can explain that. Thanks! -- View this message in context: http://www.nabble.com/JMX-exception-t1337321.html#a3578256 Sent from the ActiveMQ - Dev forum at Nabble.com. -- James --- http://radio.weblogs.com/0112098/
RE: Class DestinationView
Hey James, I made another posting this morning http://forums.activemq.org/posts/list/451.page This posting is after I created a JMX client and ran into a confusing situation. My same client code also attached there. Thanks! Vik -Original Message- From: James Strachan [mailto:[EMAIL PROTECTED] Sent: Friday, March 03, 2006 11:27 AM To: activemq-dev@geronimo.apache.org Subject: Re: Class DestinationView On 2 Mar 2006, at 21:28, Dhawan, Vikram ((LNG-DAY)) wrote: Can we make Class DestinationView as MBean. By putting it into the MBean hierarchy and creating an MBean Interface for it. Have a surf around that package - its full of MBean interfaces and implementations. We have 2 derived classes, QueueView and TopicView which are both MBeans - DestinationView is just a useful base class. And if we do that can we Manage messages in a Queue in the ActiveMQ using browse calls from the agent. See the API for QueueViewMBean :) Those methods are all implemented currently James --- http://radio.weblogs.com/0112098/