Re: ActiveMQ REST producer Causes Out Of MemoryError

2010-09-16 Thread ChicagoBob123
I have found part of a fix but it really doesnt fix everything. Here it is. Open your bin\ActiveMQ\ActiveMQ.bat Find this line if "%ACTIVEMQ_OPTS%" == "" set ACTIVEMQ_OPTS=-Xmx512M -Dorg.apache.activemq.UseDedicatedTaskRunner=true -Djava.util.logging.config.file=logging.properties change it to

ActiveMQ REST producer Causes Out Of MemoryError

2010-09-16 Thread ChicagoBob123
Every post message you make you make increases the thread count and memory footprint of java.exe I have tried version 5.3.1 and versions 5.4.0 from researching this on the net it looks like the error is tied to MessageServlet or how its being used. I dont know enough Java which is frustrating

Re: Retrieve number of pending messages in the queue

2010-09-16 Thread Timothy Bish
On Thu, 2010-09-16 at 15:07 -0700, lopan wrote: > Here is the activemq.xml file: > > http://www.springframework.org/schema/beans"; > xmlns:amq="http://activemq.apache.org/schema/core"; > xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; > xsi:schemaLocation="http://www.springframework.org/sch

Re: Retrieve number of pending messages in the queue

2010-09-16 Thread Timothy Bish
On Thu, 2010-09-16 at 15:07 -0700, lopan wrote: > - > >

Re: Retrieve number of pending messages in the queue

2010-09-16 Thread lopan
Here is the activemq.xml file: http://www.springframework.org/schema/beans"; xmlns:amq="http://activemq.apache.org/schema/core"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/sprin

Re: Retrieve number of pending messages in the queue

2010-09-16 Thread Timothy Bish
On Thu, 2010-09-16 at 14:47 -0700, lopan wrote: > 2010-09-16 18:39:19,126 | INFO | ActiveMQ Message Broker (localhost, > ID:SPSOLVODESENV01.solvo.com.br-48593-1284673039343-0:\ > 0) is shutting down | org.apache.activemq.broker.BrokerService | Thread-19 > 2010-09-16 18:39:19,128 | INFO | ActiveMQ

Re: Retrieve number of pending messages in the queue

2010-09-16 Thread lopan
2010-09-16 18:39:19,126 | INFO | ActiveMQ Message Broker (localhost, ID:SPSOLVODESENV01.solvo.com.br-48593-1284673039343-0:\ 0) is shutting down | org.apache.activemq.broker.BrokerService | Thread-19 2010-09-16 18:39:19,128 | INFO | ActiveMQ Message Broker (localhost, ID:SPSOLVODESENV01.solvo.co

Re: Retrieve number of pending messages in the queue

2010-09-16 Thread Timothy Bish
On Thu, 2010-09-16 at 11:19 -0700, lopan wrote: > OK, I see. The createBrowser method isn't mentioned in the CMS 1.2 Session > API. > > Now, whenever I start activemq with these options: > > > > > > > it goes down after 3 secs. Is there anything else that isn't mentioned in > this ar

websockets in 5.4.0: Anyone got the clients working ? ...

2010-09-16 Thread Ravi
browser: Chrome OS: Ubuntu 10.4 I followed the instructions for both stomple & stomp-websockets (Clients section http://activemq.apache.org/websockets.html) There is no indication either one can connect to the broker successfully. Anyone got either of them working ? What's the sauce I am missin

Re: Retrieve number of pending messages in the queue

2010-09-16 Thread lopan
OK, I see. The createBrowser method isn't mentioned in the CMS 1.2 Session API. Now, whenever I start activemq with these options: it goes down after 3 secs. Is there anything else that isn't mentioned in this article that should be done in order for this plugin to work? -- View

REST I am totally LOST now.

2010-09-16 Thread ChicagoBob123
I have a local version of ActiveMQ on a server on our internal network. Externally I have another version of ActiveMQ running. Same code is a producer and same code is a consumer. The internal server is hooked up via port 8080 everything just works. I can push via HTTP data via ActiveMQ and

Re: Retrieve number of pending messages in the queue

2010-09-16 Thread Timothy Bish
On Thu, 2010-09-16 at 08:37 -0700, lopan wrote: > I see this QueueBrowser is pure virtual, so I'd have to fully implement it in > C++. QueueBrowser like all other CMS API classes is an interface, if you call session.createBrowser then you get a working QueueBrowser, just like session.createProduce

Re: Retrieve number of pending messages in the queue

2010-09-16 Thread lopan
I see this QueueBrowser is pure virtual, so I'd have to fully implement it in C++. I noticed there is a class MessageDispatchChannel that has a peek() function, but again there is no documentation on how to use this class, more specifically, how to link this object to a specific queue. Google als

Re: FIFO order - just not quite

2010-09-16 Thread James Green
I have finally triggered this problem with stomp tracing and have logged a bug with log file attached: https://issues.apache.org/activemq/browse/AMQ-2923 Entirely possible I'm using ActiveMQ improperly. I would appreciate some assistance to confirm one way or another. James On 14 September 2010

Re: Retrieve number of pending messages in the queue

2010-09-16 Thread Timothy Bish
On Thu, 2010-09-16 at 08:18 -0700, lopan wrote: > Isn't there an easier built-in method to accomplish this? > You can browse a Q using the QueueBrowser object. C++ doesn't speak JMX so if you want something more then the broker statistics plugin is about you only option to access the broker's in

Re: Retrieve number of pending messages in the queue

2010-09-16 Thread lopan
Isn't there an easier built-in method to accomplish this? Also, the link you posted says: "To configure ActiveMQ to use the statistics plugin, just add the following to the ActiveMQ XML configuration" There are several XML config files, which one is it refering to? Thanks. -- View this messag

Re: Retrieve number of pending messages in the queue

2010-09-16 Thread Timothy Bish
On Thu, 2010-09-16 at 07:57 -0700, lopan wrote: > Hi, > > I am using activemq-cpp, I need a way to peek the next message in an > specific queue (without removing the message) and get the number of pending > messages in this queue. Surprinsingly, the documentation has no information > about this. >

Retrieve number of pending messages in the queue

2010-09-16 Thread lopan
Hi, I am using activemq-cpp, I need a way to peek the next message in an specific queue (without removing the message) and get the number of pending messages in this queue. Surprinsingly, the documentation has no information about this. Is there any way I can accomplish this? Thanks. -- View t

ActiveMQ 5.2.0 + REST + HTTP POST = java.lang.OutOfMemoryError

2010-09-16 Thread ChicagoBob123
Is this true? http://stackoverflow.com/questions/811732/activemq-5-2-0-rest-http-post-java-lang-outofmemoryerror It seems that the only solution is to write your own which is what the originator of the post indicated. I know very little about java (not coded any it in almost 15 years) but from w

Re: Rest producer quits after about 500 messages.

2010-09-16 Thread ChicagoBob123
More information.. If I go to the site and try to browse the queue's I get this error message. HTTP ERROR 500 Problem accessing /mjst/queueBrowse/FOO/BAR. Reason: unable to create new native thread Caused by: java.lang.OutOfMemoryError: unable to create new native thread at java.l

Re: StatisticsBrokerPlugin activation

2010-09-16 Thread Gary Tully
oops, sorry, my bad, so there is a broker factory for xbean but no transport factory. The correct syntax is to use the vm transport factory and tell it to use the xbean broker factory using the brokerConfig attribute: The brokerURI should be of the form: vm://localhost?brokerConfig=xbean:... so yo

Rest producer quits after about 500 messages.

2010-09-16 Thread ChicagoBob123
I am sending XML wrapped messages that are about 6K in length about once a second using REST. I gave the messages a timeout of 5 seconds. &JMSTimeToLive=5000 I am taking the messages off the queue and in currently there are no messages in the queue. The jetty sever seems to die after 500 messa

Re: StatisticsBrokerPlugin activation

2010-09-16 Thread Don Santillan
Hello Gary, Here's what I did: 1. added activemq.xml to classpath (classes/activemq.xml) 2. used xbean to initialize broker String brokerURI = "xbean:activemq.xml"; ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(brokerURI); connection = connectionFactory.createConn

Re: ActiveMQ can not lock store.

2010-09-16 Thread Tracy Snell
On Sep 16, 2010, at 4:11 AM, javadev wrote: > I tried to delete "activemq-data" dir and restart Tomcat, then delete lock > file and restart Tomcat. Nothing help. A lock file is getting created?

Re: Need Help

2010-09-16 Thread Tracy Snell
Typically you have N Initiators --> Broker --> Y Targets So you'd start a broker. Then your programs that are feeding and the programs that are consuming messages. On Sep 16, 2010, at 5:30 AM, pp wrote: > > Thanks gary. > > So we should have the initiator and target both should have the ac

KahaDB, detecting corrupt index file

2010-09-16 Thread Andrew Wasilczuk
Hi there, I have a shared file system master-slave setup and I'm currently testing how KahaDB handles corruption (it's important since it's a single point of failure). In one of the tests I corrupt the index file while the broker is running (there are a few pending messages in a test queue): d

Re: Need Help

2010-09-16 Thread pp
Thanks gary . Thanks a lot. -- View this message in context: http://activemq.2283324.n4.nabble.com/Need-Help-tp2541665p2541896.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Need Help

2010-09-16 Thread Gary Tully
typically not, typically there is a single broker. On 16 September 2010 10:30, pp wrote: > > Thanks gary. > > So we should have the initiator and target both should have the activemq > broker. > -- > View this message in context: > http://activemq.2283324.n4.nabble.com/Need-Help-tp2541665p254182

Re: Camel console not seeing my routes

2010-09-16 Thread Illtud Daniel
Hi Dejan, this is fixed in the current trunk ... see https://issues.apache.org/activemq/browse/AMQ-2203 for more info Good to know it's not just my ignorance! for your current setup just, the workaround is to modify your applicationContext.xml like this http://fisheye6.atlassian.com/browse/

Re: Need Help

2010-09-16 Thread pp
Thanks gary. So we should have the initiator and target both should have the activemq broker. -- View this message in context: http://activemq.2283324.n4.nabble.com/Need-Help-tp2541665p2541829.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: StatisticsBrokerPlugin activation

2010-09-16 Thread Gary Tully
Use the xbean: uri syntax to reference an xml configuration file in your brokerURI, that is the most flexible way to configure an embedded broker. http://activemq.apache.org/broker-configuration-uri.html On 16 September 2010 09:24, Don Santillan wrote: > Hello, > > I am using activemq as a dep

Re: StatisticsBrokerPlugin activation

2010-09-16 Thread Don Santillan
As a follow up, I used this unit test which made me think that StatisticsBrokerPlugin is not activated: [removed package and import lines] public class MonitoringTest extends TestCase { private String brokerURI = "vm://testBroker?broker.persistent=false"; private boolean transacted =

Re: Need Help

2010-09-16 Thread Gary Tully
it is typically client(producer/consumer) server (broker) but you can embed brokers in either of the clients, for a producer that always needs to be available for example, it can embed a broker that will serve as a local store and forward messages to the ultimate target broker. On 16 September 201

StatisticsBrokerPlugin activation

2010-09-16 Thread Don Santillan
Hello, I am using activemq as a dependency in a web app. My web app is deployed to a jetty server which is run through maven by issuing "mvn jetty:run". Of course, one part of the web app is to create and start a broker. I am doing this through ActiveMQConnectionFactory (as described at the l

ActiveMQ can not lock store.

2010-09-16 Thread javadev
i configure embedded ActiveMQ broker with: It is running as WAR on Tomcat 6. ActiveMQ can not run, because it fails to lock. Same bug for amq and kahaDB. 16.09.2010 12:05:33 org.apache.activemq.kaha.impl.KahaStore initialize I

Re: Terminating 'example.A'.

2010-09-16 Thread Dejan Bosanac
Hi, in 5.3.1 it's also included in camel web console as a sample route. Delete it from webapps/camel/WEB-INF/applicationContext.xml Cheers -- Dejan Bosanac - http://twitter.com/dejanb Open Source Integration - http://fusesource.com/ ActiveMQ in Action - http://www.manning.com/snyder/ Blog - htt

Need Help

2010-09-16 Thread pp
hi , I want to know that ,if it is neccesary that there should be broker present at publisher/producer as well as consumer/subscriber. -- View this message in context: http://activemq.2283324.n4.nabble.com/Need-Help-tp2541665p2541665.html Sent from the ActiveMQ - User mailing list archive at

Re: how to save topics and messages in mysql database

2010-09-16 Thread pp
I have one more question. For activemq must we have the broker(activemq) at every subscriber's server ? -- View this message in context: http://activemq.2283324.n4.nabble.com/how-to-save-topics-and-messages-in-mysql-database-tp2539322p2541661.html Sent from the ActiveMQ - User mailing list arc