Register ActiveMQ destinations in JNDI

I am new to using ActiveMQ. I am trying to integrate ActiveMQ in our Spring application environment. I have been successful in running the broker (defined in the activemq.xml file on the classpath) in the embedded form as a spring bean in our application context. I am also able to create a connect

Re: How do I delete a queue or topic that I no longer need?

On 4/2/07, sparky2708 <[EMAIL PROTECTED]> wrote: How do I delete a queue or topic that I no longer need? Can I do this through JConsole? If not, how? This functionality is available via the JMX APIs in ActiveMQ. Attached is a very small project that includes functionality to query for a topic

Question on persistent flag

I ran a quick test with the persistent flag set to true and another one with the flag set to false. In both the cases, I have the consumers subscribed as durable. I publish messages to the topic while the clients are up and while they are down. In both the cases, when the clients come back up, they

Re: STOMP broker - order of ACKs?

Just a clarification in the sequence that doesn't work: - Message 1 rcvd - ACK msg 1 - Message 2 rcvd - Message 3 rcvd - ACK msg 3 - ACK msg 2 the ACK of messages 1 and 3 are OK... it is the ACK of msg 2 that throws the exception jon jonm wrote: > > I am new to JMS and ActiveMQ --

STOMP broker - order of ACKs?

I am new to JMS and ActiveMQ -- I have been investigating using the STOMP broker and things have worked well so far, but I have a question about ACKs to messages received by a consumer: It seems that the order of ACKs is not important (if they are done in a 'batch'), for example, I can receive, s

RE: spring and activemq

ActiveMQ 4.1 Shawn -Original Message- From: James Strachan [mailto:[EMAIL PROTECTED] Sent: Monday, April 02, 2007 3:08 AM To: users@activemq.apache.org Subject: Re: spring and activemq Which version were you using? On 3/29/07, Garner, Shawn <[EMAIL PROTECTED]> wrote: > I'm having prob

RE: jencks & tomcat

I figured it out. I had to download the 1.2 version of Geronimo and get some module jars from there. The Jencks website has a link to the spec jar repository for Geronimo but it appears to be old or something. I had to get the connections and transaction modules from Geronimo along with the EBJ

Suggested implmentation?

I am looking build an event based system where the event is logged in a message queue and then listeners(subscribers/receivers) all perform their specific tasks based on the event. I've looked at the documentation and I can't seem to find exactly what I want to do. I would like to: - strictly o

RE: JDBC Persistance

Hi James, Is 4.2 production ready? Also, I switched the JDBC from mysql to embedded derby db. I still see the disk growth. Is it possible to get the cleanup of records in the db to happen faster? I guess I am asking if there is any configuration parameters that I can set? The CPU usage is minimal.

Re: Single Producer waiting on send

On 4/2/07, Gaurav Hariani <[EMAIL PROTECTED]> wrote: This may be a dumb question ... where in jconsole do I look for the usageManager stats? look n this page http://activemq.apache.org/jmx.html search for "Memory" -- James --- http://radio.weblogs.com/0112098/

Re: Single Producer waiting on send

This may be a dumb question ... where in jconsole do I look for the usageManager stats? James Strachan wrote: On 4/2/07, Gaurav Hariani <[EMAIL PROTECTED]> wrote: Is there a way of confirming that this is the cause? The JMX stats should show the usageManager being full.

Re: Can't figure out why send to my temporary queue doesn't work but Listener seems OK

Thanks James. I figured it out. This link was VERY HELPFUL: http://activemq.apache.org/how-should-i-implement-request-response-with-jms.html sparky2708 wrote: > > What I am trying to accomplish is that I need a temporary queue that I can > use like a control queue. I would like my clients t

Re: Can't figure out why send to my temporary queue doesn't work but Listener seems OK

What I am trying to accomplish is that I need a temporary queue that I can use like a control queue. I would like my clients to be able to send messages to a service's control queue (this could be permanent) and the service would be able to send responses to each client's control queue (indicated

Re: Can't figure out why send to my temporary queue doesn't work but Listener seems OK

That was my workaround. It would be convenient if we could just send by name... Thanks :-) James.Strachan wrote: > > On 4/2/07, sparky2708 <[EMAIL PROTECTED]> wrote: >> >> I create a temporary queue using: >> >> String user = ActiveMQConnection.DEFAULT_USER; >> String password = ActiveMQConnect

How do I delete a queue or topic that I no longer need?

How do I delete a queue or topic that I no longer need? Can I do this through JConsole? If not, how? -- View this message in context: http://www.nabble.com/How-do-I-delete-a-queue-or-topic-that-I-no-longer-need--tf3507018s2354.html#a9794952 Sent from the ActiveMQ - User mailing list archive at N

Re: Single Producer waiting on send

On 4/2/07, Gaurav Hariani <[EMAIL PROTECTED]> wrote: Is there a way of confirming that this is the cause? The JMX stats should show the usageManager being full. -- James --- http://radio.weblogs.com/0112098/

Re: Single Producer waiting on send

Is there a way of confirming that this is the cause? Something like maybe enable debug logging on the broker or something like that? James Strachan wrote: As I said, its probably this http://activemq.apache.org/my-producer-blocks.html On 4/2/07, Gaurav Hariani <[EMAIL PROTECTED]> wrote: Tha

Re: Can't figure out why send to my temporary queue doesn't work but Listener seems OK

On 4/2/07, sparky2708 <[EMAIL PROTECTED]> wrote: I create a temporary queue using: String user = ActiveMQConnection.DEFAULT_USER; String password = ActiveMQConnection.DEFAULT_PASSWORD; ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(user, password, jms_url); _connect

Can't figure out why send to my temporary queue doesn't work but Listener seems OK

I create a temporary queue using: String user = ActiveMQConnection.DEFAULT_USER; String password = ActiveMQConnection.DEFAULT_PASSWORD; ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(user, password, jms_url); _connection = connectionFactory.createConnection(); _connec

Re: Single Producer waiting on send

As I said, its probably this http://activemq.apache.org/my-producer-blocks.html On 4/2/07, Gaurav Hariani <[EMAIL PROTECTED]> wrote: Thats what I meant. Looking at the graphs in jconsole I don't see any memory increasing/decreasing when this happens. The producer blocks for hours and then conti

Re: JDBC Persistance

There is a lag if using the journal based on the journal checkpoint time; so using pure JDBC and no journal will use less disk (though be much slower). Also there is a further lag if you are using durable topics (since the deletion of messages is a background task). You might want to use queues if

Re: Single Producer waiting on send

Thats what I meant. Looking at the graphs in jconsole I don't see any memory increasing/decreasing when this happens. The producer blocks for hours and then continues fine ... yesterday it locked for 6 hours. I wasn't around to take a thread-dump when this happened yesterday ... but I'll try ge

RE: JDBC Persistance

Hi James, I do want to use persistent delivery. The problem I am seeing is the messages from the persistent store are not being deleted fast enough. My disk is getting full. Is there any way to control this? Do you think setAsyncSend(true) will help? Thanks, Ramesh. -Original Message-

Re: Deadlock in MutexTransport

Could you post a stack trace? On 4/2/07, Dennis Cheung <[EMAIL PROTECTED]> wrote: Hi, I have similar deadlock issue on MutexTransport. The transport thread having deadlock with another thread which is doing the Consumer.close() Any one can give advise to me? thanks On 10/26/06, kristoffer <[E

Re: Deadlock in MutexTransport

Hi, I have similar deadlock issue on MutexTransport. The transport thread having deadlock with another thread which is doing the Consumer.close() Any one can give advise to me? thanks On 10/26/06, kristoffer <[EMAIL PROTECTED]> wrote: Hi, Im speculating here: is it because the persistent fl

Loading configuration from properties file

Hi I've tried to make a pure properties loader fro activemq but it took much time than I can assume in my job so I´ll try to do it at home and now I'm trying to make a simple loader in my app. In my old xml spring style configuration file I used to have: http://activemq.o

Re: Stomp problems in apache-activemq-4.1-20070320.072657-13.tar.gz

That is indeed the case and it has just been addressed in the AMQ-CPP trunk. The patch will be included in the 2.0 release which should be out soon. On 4/2/07, James Strachan <[EMAIL PROTECTED]> wrote: You might wanna switch to CLIENT_ACKNOWLEDGE to prevent this problem (as the C++ client is p

Re: Java Heap Space Exception

I tried setting that but was not helping me solve the issue. I guess its something specific to the openwire protocol being used James.Strachan wrote: > > Try setting a bigger heap for running jboss? > > On 3/29/07, Karthik.Gopalakrishnan <[EMAIL PROTECTED]> > wrote: >> >> I tried sending a By

Re: JDBC Persistance

On 4/1/07, Ramesh Bobba <[EMAIL PROTECTED]> wrote: I have three producers producing 80K messages every 2 seconds, I have three consumers subscribed as durable consumers. I am using mysql as persistence. What I see is that the messages are being written to the database even when all the subscriber

Re: Stomp problems in apache-activemq-4.1-20070320.072657-13.tar.gz

You might wanna switch to CLIENT_ACKNOWLEDGE to prevent this problem (as the C++ client is probably acknowledging the message being processed immediately On 3/30/07, tommy.li <[EMAIL PROTECTED]> wrote: session = connection->createSession( Session::AUTO_ACKNOWLEDGE ); Thanks. James.Strachan wro

Re: spring and activemq

Which version were you using? On 3/29/07, Garner, Shawn <[EMAIL PROTECTED]> wrote: I'm having problems getting the example spring file to load: http://activemq.apache.org/spring-support.html 007-03-29 15:19:23,662 [main] ERROR org.springframework.web.context.ContextLoader:initWebApplicati

Re: JDBC Master Slave with embedded Derby?

On 3/30/07, ron55test <[EMAIL PROTECTED]> wrote: Hi, I would like to set-up 2 instances of Activemq with 1 as a master and the other as a slave. I'm using persistent messaging with embedded derby. Since I cannot establish multiple connections to an embedded derby, I suppose I'll have to use De

Re: ActiveMQ e Jonas

I'm afraid there isn't one yet, just a general J2EE one. http://activemq.apache.org/j2ee.html but we welcome contributions :) http://activemq.apache.org/contributing.html On 3/30/07, tewfik <[EMAIL PROTECTED]> wrote: i have to used activemq into jonas, i know there are other application serv

Re: Single Producer waiting on send

On 3/30/07, Gaurav Hariani <[EMAIL PROTECTED]> wrote: Would this show up in the memory usage on the broker? Not really; it would in JMX though. -- James --- http://radio.weblogs.com/0112098/

Re: jencks & tomcat

What jars are you putting on the classpaht? On 3/30/07, Garner, Shawn <[EMAIL PROTECTED]> wrote: I want to use Jencks 2.0 with tomcat but I am getting: java.lang.NoClassDefFoundError: org/apache/geronimo/transaction/manager/XAWork Any help? Shawn -- James --- http://radio.we

Re: Transport failed. Getting java.io.EOFException

See http://activemq.apache.org/jmstemplate-gotchas.html On 4/2/07, ron55test <[EMAIL PROTECTED]> wrote: I've set up a master slave configuration with the client using the failover transport to connect to the available brokers. With the master slave set-up, even if the master does not fail, I k

Re: Java Heap Space Exception

Try setting a bigger heap for running jboss? On 3/29/07, Karthik.Gopalakrishnan <[EMAIL PROTECTED]> wrote: I tried sending a ByteMessage from a c# client to a java consumer(MDB which listens on the queue) and it works completely file . But when i send a TextMessage from the same c# producer to

Re: BrokerFilter question

It might be easier for you to just use a JMS client. But if not you could use ConnectionInfo, ProducerInfo and MessageDispatch to send a message. On 3/31/07, Allesmallachen <[EMAIL PROTECTED]> wrote: Hi, thank you for yours answer James. Basically, I just want to send a message to the broker th

Re: How to handle accented Characters in ActiveMQ

On 3/30/07, Zango <[EMAIL PROTECTED]> wrote: XML message sent to the queue has accented characters. ActiveMQ just stops Queue client from reading the queue and all following messages are stored. If you are using TextMessages then any UTF-8 strings should be fine. Otherwise use a StreamMessag

Re: Flash and ActiveMQ

On 4/1/07, massive.boisson <[EMAIL PROTECTED]> wrote: Hi, is there a good way to connect between ActiveMQ and Flash? It should be really trivial to write a STOMP client in Flash since it can open sockets and read & write strings etc. http://stomp.codehaus.org/Protocol Has anyone done it?