activemq, session management?

2008-11-11 Thread Eugeny N Dzhurinsky
"Ben, eto Danila, I need help!" (C) Hello there! I would appreciate any help you could provide me with. I need to solve some kind of a strange task, which might be out of scope of Active MQ. We need to build the distributed network of data processors, which are working interactively with users (

Re: CLIENT_ACKNOWLEDGE mode for a session misunderstanding?

2008-10-30 Thread Eugeny N Dzhurinsky
On Wed, Oct 29, 2008 at 05:06:33PM +, Rob Davies wrote: > Hi Eugeny, > > As James stated earlier - you need to set the prefetch - but the value > should be 0 - this will make ActiveMQ 'pull' rather than 'push' This doesn't work: javax.jms.JMSException: Illegal prefetch size of zero. This s

Re: CLIENT_ACKNOWLEDGE mode for a session misunderstanding?

2008-10-29 Thread Eugeny N Dzhurinsky
On Tue, Oct 28, 2008 at 05:44:26PM +, James Strachan wrote: > 2008/10/28 Eugeny N Dzhurinsky <[EMAIL PROTECTED]>: > > Hello! > > > > I am facing some strange issue with acknowledge mode in ActiveMQ. After > > reading the specs, I realized the broker wi

CLIENT_ACKNOWLEDGE mode for a session misunderstanding?

2008-10-28 Thread Eugeny N Dzhurinsky
Hello! I am facing some strange issue with acknowledge mode in ActiveMQ. After reading the specs, I realized the broker will never deliver a message to the consumer unless the consumer acknowledges the previous message. So I thought it is enough to not send the acknowledgement message to the serve

how to debug message flow?

2008-10-27 Thread Eugeny N Dzhurinsky
Hello! I created a Session with Session.CLIENT_ACKNOWLEDGE, then created a queue and a consumer using this session. I found if several producers are sending messages to the queue, the onMessage method of the consumer is called each time new message arrives. This happens even in case if the consume

Re: onMessage method of MessageListener is never called?

2008-09-03 Thread Eugeny N Dzhurinsky
On Wed, Sep 03, 2008 at 02:10:12PM +0100, James Strachan wrote: > If I had a dollar for every time someone's stumbled on this one in JMS... > > http://activemq.apache.org/i-am-not-receiving-any-messages-what-is-wrong.html Oh :) Really, that's my case - I didn't start the connection. However at a

onMessage method of MessageListener is never called?

2008-09-03 Thread Eugeny N Dzhurinsky
Hello! I am trying to write the test for my application which uses requests and response queues for handling message processing. I recently realized the onMessage is never being called on the MessageConsumer. I wrote the sample code listed below and it is really true - onMessage is just skipped. H

Re: distributing legacy code using JMS

2008-08-28 Thread Eugeny N Dzhurinsky
On Thu, Aug 28, 2008 at 11:29:02AM +0100, James Strachan wrote: > 2008/8/28 Eugeny N Dzhurinsky <[EMAIL PROTECTED]>: > The tricky bit is ensuring that the on-the-wire message formats > correctly match up to the legacy application. There's a number of > solutions out there in

distributing legacy code using JMS

2008-08-28 Thread Eugeny N Dzhurinsky
Hello, there! Can somebody please help me: I recently received the task to distribute legacy interface using JMS onto several hosts. This interface consists of many methods, some of them are returning byte arrays or input streams, and few ones takes output stream as a parameter to store results in

Re: Message announcement and routing

2008-08-26 Thread Eugeny N Dzhurinsky
On Tue, Aug 26, 2008 at 10:35:31AM +0100, James Strachan wrote: > > It's a good point, however this isn't the case we are worrying about for > > now, > > we are just trying to prove the concept. If the consumer did not send the > > acknowledgement, will the broker not route another messages to tha

Message announcement and routing

2008-08-25 Thread Eugeny N Dzhurinsky
Hello! Can somebody please take a look at my question below and let me know is it possible to achieve such behavior with ActiveMQ? I need to distribute the system which is doing heavy calculation for clients. This means the client sends the initial query to start the calculation task to the JMS n

Re: Embedded broker, adding connections after broker was configured with xbean:

2008-08-21 Thread Eugeny N Dzhurinsky
On Thu, Aug 21, 2008 at 12:33:52PM +0300, Eugeny N Dzhurinsky wrote: > the method createBroker doesn't start the broker. > > Or I didn't understand what you meant with > > > What should help is to add a start="false" attribute to the broker xbean. >

Re: Embedded broker, adding connections after broker was configured with xbean:

2008-08-21 Thread Eugeny N Dzhurinsky
On Wed, Aug 20, 2008 at 01:35:58PM +0100, Gary Tully wrote: > I think the issue is that the broker configured via > "xbean:activemq.xml" is started eagerly. That is, it is started before > your connector is added. What should help is to add a start="false" > attribute to the broker xbean. > > not

Embedded broker, adding connections after broker was configured with xbean:

2008-08-20 Thread Eugeny N Dzhurinsky
Hello all! I have the activemq.xml file, listed below: http://activemq.org/config/1.0";> http://mortbay.com/schemas/jetty/1.0";> When transportConnectors section was unc

Re: JDK 1.5, 1.6 and FreeBSD

2008-08-11 Thread Eugeny N Dzhurinsky
Allright, I was able to resolve the issue - looks like setChunkedStreamingMode in JDK 1.6 is either broken, or Jetty can't understand it well. I had created the custom uploading strategy, which is using Commons HttpClient 3.1, and things are working fine. Just in case if somebody will find this us

Re: JDK 1.5, 1.6 and FreeBSD

2008-08-11 Thread Eugeny N Dzhurinsky
On Fri, Aug 08, 2008 at 02:25:40PM +0300, Eugeny N Dzhurinsky wrote: > Hello, all! > > I found a very strange issue - having the broker, producer and consumer > running on JDK 1.6 Blob messages aren't processed at all - in the directory > with blobs I can see partial files wi

JDK 1.5, 1.6 and FreeBSD

2008-08-08 Thread Eugeny N Dzhurinsky
Hello, all! I found a very strange issue - having the broker, producer and consumer running on JDK 1.6 Blob messages aren't processed at all - in the directory with blobs I can see partial files with blobs and nothing happens - looks like the producer can't finish the uploading of a message for so

Re: Broker upload url is null?

2008-08-07 Thread Eugeny N Dzhurinsky
On Thu, Aug 07, 2008 at 03:23:26PM +0200, Marco Buss wrote: > remove the setting of the blobUploadStrategy from your code an use this > brokerURL to initialise your ActiveMQConnectionFactory > > tcp://localhost:1235?jms.*blobTransferPolicy*.defaultUploadUrl=http://localhost:8161/fileserver/ I wa

Re: Broker upload url is null?

2008-08-07 Thread Eugeny N Dzhurinsky
On Thu, Aug 07, 2008 at 02:43:33PM +0200, Marco Buss wrote: > Eugeny N Dzhurinsky schrieb: > > On Thu, Aug 07, 2008 at 02:18:40PM +0200, Marco Buss wrote: > > > >> First try this. Set CopyMessageOnSend to false on your connection. See > >> http://www.nabble.

Re: Broker upload url is null?

2008-08-07 Thread Eugeny N Dzhurinsky
On Thu, Aug 07, 2008 at 02:18:40PM +0200, Marco Buss wrote: > First try this. Set CopyMessageOnSend to false on your connection. See > http://www.nabble.com/A-problem-with-blobmessage-on-activemq-5.0-td15523989.html#a17364301 > If this is true (default) the Upload does not work. Really, this set

Re: Broker upload url is null?

2008-08-07 Thread Eugeny N Dzhurinsky
On Thu, Aug 07, 2008 at 01:15:51PM +0200, Marco Buss wrote: > Is the Blob successfuly uploaded? Can you see it in the jetty file system? No, the blob isn't uploaded at all. Moreover, I added the code listed below: ===

Broker upload url is null?

2008-08-07 Thread Eugeny N Dzhurinsky
Hello, everybody! I had configured the internal broker with this descriptor http://activemq.org/config/1.0";> http://mortbay.com/schemas/jetty/1.0";>

Re: Starting Jetty to serve blobs with embedded broker

2008-08-07 Thread Eugeny N Dzhurinsky
On Wed, Aug 06, 2008 at 03:46:20PM +0200, Dejan Bosanac wrote: > Hi Eugeny, > > try adding something like > > > org.mortbay.jetty > 6.1.2 > jetty > > > to your dependencies. Hello, Dejan! Thank you for advice, I was able to find out the pro

Re: Starting Jetty to serve blobs with embedded broker

2008-08-06 Thread Eugeny N Dzhurinsky
On Wed, Aug 06, 2008 at 02:24:00PM +0300, Eugeny N Dzhurinsky wrote: > 0 [main] INFO org.apache.xbean.spring.context.ResourceXmlApplicationContext > - Refreshing [EMAIL PROTECTED]: display name [EMAIL PROTECTED]; startup date > [Wed Aug 06 14:19:13 EEST 2008]; root of context hierar

Re: Starting Jetty to serve blobs with embedded broker

2008-08-06 Thread Eugeny N Dzhurinsky
On Tue, Aug 05, 2008 at 06:10:20AM -0700, Joe Fernandez wrote: > > Hi Eugeny, > > You can try starting the embedded broker with a brokerURL that specifies a > config file, and have the config file include a <> element. > > With this brokerURL the cfg file must be in the application???s CLASSPAT

Starting Jetty to serve blobs with embedded broker

2008-08-05 Thread Eugeny N Dzhurinsky
Hello, all! Could somebody please advice how can I start the embedded Jetty server when starting ActiveMQ from the application using embedded brokers? I need to serve blobs, and looks like the default Jetty server is not started when broker is created, thus blobs aren't uploaded and BlobMessage.