Re: UDP buffer problem

2007-06-21 Thread James Strachan
UDP is unreliable; whatever the buffer size is, messages can still get discarded if a client doesn't process them fast enough etc. So we need a working reliable layer on top of UDP which is capable of handling re-requests of missing packets etc. The current code is work in progress; which nearly

Re: Same MessageId assigned Messages created at the same time...

2007-06-21 Thread James Strachan
This does sound bizarre, as the message ID = producerID + sequenceNumber. Are you positive that both your producers have the same producer IDs? On 6/20/07, rvenkat23 [EMAIL PROTECTED] wrote: Here is the two message ids: ID:beprd02-46310-1181944109798-1:0:19:1:702

Re: reading message size using queue browser

2007-06-21 Thread keneida
James.Strachan wrote: On 6/20/07, keneida [EMAIL PROTECTED] wrote: using queue browser i can see all the parameters of the messages. However doesnt matter what I send the size parameter is always 0. What size parameter? -- James --- http://macstrac.blogspot.com/ Message:

Re: Basic Spring+AMQ+XBean+embededbroker problem

2007-06-21 Thread Paul Smith
On 21/06/2007, at 5:55 PM, James Strachan wrote: This line was the giveaway... On 6/21/07, Paul Smith [EMAIL PROTECTED] wrote: [snip] Caused by: java.lang.ClassNotFoundException: org.apache.xbean.spring.context.v2c.XBeanNamespaceHandler at

Re: Basic Spring+AMQ+XBean+embededbroker problem

2007-06-21 Thread James Strachan
On 6/21/07, Paul Smith [EMAIL PROTECTED] wrote: On 21/06/2007, at 5:55 PM, James Strachan wrote: This line was the giveaway... On 6/21/07, Paul Smith [EMAIL PROTECTED] wrote: [snip] Caused by: java.lang.ClassNotFoundException: org.apache.xbean.spring.context.v2c.XBeanNamespaceHandler

Re: reading message size using queue browser

2007-06-21 Thread James Strachan
On 6/21/07, keneida [EMAIL PROTECTED] wrote: James.Strachan wrote: On 6/20/07, keneida [EMAIL PROTECTED] wrote: using queue browser i can see all the parameters of the messages. However doesnt matter what I send the size parameter is always 0. What size parameter? -- James ---

Re: Orphan connections from .NET clients

2007-06-21 Thread Jim_Cross
If not, here's a quick class I hacked together to stop the inactive connections - just give your JMX url as a command line argument. Not guarantees provided with this code! package com.ubs.eq.speed; import java.util.Hashtable; import java.util.Set; import

Re: reading message size using queue browser

2007-06-21 Thread keneida
James.Strachan wrote: On 6/21/07, keneida [EMAIL PROTECTED] wrote: James.Strachan wrote: On 6/20/07, keneida [EMAIL PROTECTED] wrote: using queue browser i can see all the parameters of the messages. However doesnt matter what I send the size parameter is always 0. What

Re: How to have a highly available and scalable setup using network of brokers?

2007-06-21 Thread Joel Schaubert
Nicky Sandhu wrote: Joel Schaubert wrote: What are the extra benefits of going to the more complicated setup of pairs of master/slave's behind the load balancer instead of a flat space of a network of brokers? If a master were to fail then the slave would connect as a master to

Re: How to have a highly available and scalable setup using network of brokers?

2007-06-21 Thread Nicky Sandhu
James.Strachan wrote: It'd be interesting to see what kinds of throughput, RAM CPU usage you get in your environment; you might find a single broker can easily handle that load on a decent 2-4 way blade etc Wanted to make sure I have options before painting myself into a corner.

Re: How to have a highly available and scalable setup using network of brokers?

2007-06-21 Thread Nicky Sandhu
Joel Schaubert wrote: What I have found during my testing of the network of brokers is that you do get this behaviour. If I write 100 message to broker A, then I kill it, then I subscribe to broker B, I can read all of the messages. (and various versions of this scenario tested in our QA

How to send file using ActiveMQ

2007-06-21 Thread [EMAIL PROTECTED]
Hi, Can you let me know how to send large file using ActvieMQ ? Thanks -- View this message in context: http://www.nabble.com/How-to-send-file-using-ActiveMQ-tf3960326s2354.html#a11238250 Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: How to send file using ActiveMQ

2007-06-21 Thread Kit Plummer
We're using JMS to carry 100-1000MB files. [EMAIL PROTECTED] wrote: Hi, Can you let me know how to send large file using ActvieMQ ? Thanks

Re: How to send file using ActiveMQ

2007-06-21 Thread James Strachan
On 6/21/07, [EMAIL PROTECTED] [EMAIL PROTECTED] wrote: Hi, Can you let me know how to send large file using ActvieMQ ? Yes. We've supported JMS streams for a few years now, though in 5.x there's an even better mechanism, Blob Messages which supports out of band and external file systems/web

Re: How to have a highly available and scalable setup using network of brokers?

2007-06-21 Thread Joel Schaubert
Nicky Sandhu wrote: Joel Schaubert wrote: What I have found during my testing of the network of brokers is that you do get this behaviour. If I write 100 message to broker A, then I kill it, then I subscribe to broker B, I can read all of the messages. (and various versions of this

Re: How to send file using ActiveMQ

2007-06-21 Thread Gaurav Hariani
We have a similar need and after trying a number of approaches we settled on the following approach: The producer creates a file in a directory where it can be served by a webserver e.g. ~gaurav/public_html/large_messages/xyzABC123.zip Then the producer sends the URL of this file as a text

Behaviour of composite destination when a target destination was not created

2007-06-21 Thread panu
Hi All, I recently used the composite destination feature and it is nice (help us simplify the problem a lot). However, I notice that if a target destination was not created the message broker does not create it either. I use version 4.2 (SNAPSHOT). For instance, if I set a composiste

Defining queue in activemq.xml

2007-06-21 Thread Tom Samplonius
How do you define a queue in activemq.xml? I looked at the XSD and the best that I could come up with is: destinations queue name=myqueue / /destinations But this causes a null pointer exception. It is very hard to find documentation on this type of thing. I've seen an example on

Re: Defining queue in activemq.xml

2007-06-21 Thread Jonas Lim
Hi Tom, Here's the link on startup destinations http://activemq.apache.org/configure-startup-destinations.html Regards, Jonas Tom Samplonius wrote: How do you define a queue in activemq.xml? I looked at the XSD and the best that I could come up with is: destinations queue