Re: C# .NET Development is not possible at this point with ActiveMQ

Previous versions are hard to align with the Java ActiveMQ release. There are no tags or branches in the SVN tree for C# NMS. No idea what I need to check out that would match the ActiveMQ 4.1.0 release. Maybe the developers of ActiveMQ could suggest a revision that should work? Christopher G.

Re: Fast producer, slow consumer with spooling to disk?

Hello all, On Fri, 02 Feb 2007, Rob Davies wrote: > Hi Albert, > > what is the behavior you are expecting ? > > cheers, > > Rob Hey Rob. What we'd like to happen in our fast producer/slow consumer scenario when the broker runs out of space (in memory) is that it blocks the producers for a w

Re: Async Exception: Broken Pipe

I will look into this over the weekend and will let you know. My client and server are both using a single connection (I'm using a SingleConnectionFactory), the client only uses one session, the server uses a session per thread. It's when the server is run with 6 or more threads I get problems.

Re: Async Exception: Broken Pipe

I'll give it a try over the weekend and will let you know. Thanks rajdavies wrote: > > do the errors exist on the latest 4.2 snapshot? > -- View this message in context: http://www.nabble.com/Async-Exception%3A-Broken-Pipe-tf3160498.html#a8776795 Sent from the ActiveMQ - User mailing list

Re: Queue question

Its maybe best if you step back a bit and clearly describe the exact semantics you want for your message exchanges as it sounds a little like a few concepts are being muddled together. Lets start with the absolute basics of how queues and topics differ... http://activemq.apache.org/how-does-a-que

Re: Queue question

Thanks for the clarification. While poking around with JConsole connecting to the broker via JMX I found the option to purge Queues. And after tweaking with the code a bit, came up with the following piece of code that actually *does* purge a queue. Has anyone used this approach before and are

Re: Testing "maximumRedeliveries"... MDP does not receives messages once an Exception is thrown...

Nilantha wrote: > > Nilantha wrote: >> I did the change as suggested(had to replace '&' with ';') >> >> > >> value="failover:(tcp://xxx:61416,tcp://xxx:61417)?jms.redeliveryPolicy.allPrefetchValues=1;jms.redeliveryPolicy.initialRedeliveryDelay=2000;jms.redeliveryPolicy.maximumRedeliv

Re: Fast producer, slow consumer with spooling to disk?

Hi Albert, what is the behavior you are expecting ? cheers, Rob On 2 Feb 2007, at 19:23, Albert Strasheim wrote: Hello all On Mon, 29 Jan 2007, Albert Strasheim wrote: Hey Rob, Thanks, I'll try this suggestion. I'm seeing a few issues with the new code (producer getting stuck, consumer

Re: Testing "maximumRedeliveries"... MDP does not receives messages once an Exception is thrown...

Nilantha wrote: > > I did the change as suggested(had to replace '&' with ';') > > > value="failover:(tcp://xxx:61416,tcp://xxx:61417)?jms.redeliveryPolicy.allPrefetchValues=1;jms.redeliveryPolicy.initialRedeliveryDelay=2000;jms.redeliveryPolicy.maximumRedeliveries=4;jms.redeliv

Re: Fast producer, slow consumer with spooling to disk?

thanks Albert! On 2 Feb 2007, at 19:23, Albert Strasheim wrote: Hello all On Mon, 29 Jan 2007, Albert Strasheim wrote: Hey Rob, Thanks, I'll try this suggestion. I'm seeing a few issues with the new code (producer getting stuck, consumer not getting any messages). I'm working on a test cas

Re: Fast producer, slow consumer with spooling to disk?

Hello all On Mon, 29 Jan 2007, Albert Strasheim wrote: > Hey Rob, > > Thanks, I'll try this suggestion. > > I'm seeing a few issues with the new code (producer getting stuck, > consumer not getting any messages). I'm working on a test case to show > the problem. I'll create a JIRA issue as so

Re: Testing "maximumRedeliveries"... MDP does not receives messages once an Exception is thrown...

Nilantha wrote: > I have posted this message earlier but it seems lost... sorry if I make > duplicates. > > I am using Jencks(2.0) for inbound. I am throwing a Runtime exception in > order to test max redelivery setting (I couldn't find any better way to test > with MDPs). If there are no excepti

Testing "maximumRedeliveries"... MDP does not receives messages once an Exception is thrown...

I have posted this message earlier but it seems lost... sorry if I make duplicates. I am using Jencks(2.0) for inbound. I am throwing a Runtime exception in order to test max redelivery setting (I couldn't find any better way to test with MDPs). If there are no exceptions thrown from MDP message

Configuring activemq app to avoid single point of failure

I have a spring/ActiveMQ standalone app which has an embedded broker. I am going to run this app on 2 identical servers (serverA.mydomain.com & serverB.mydomain.com) which are load balanced behind myapp.mydomain.com. My client will contact the app JMS Q by specifying the connection URI as tcp://my

Re: Queue Memory Limits

I am wondering if this is considered to be a problem? AMQ is simply hanging, no error messages reported. Maybe at the very list an error log message. If new messages are sent maybe client should get an exception with an error code? -- View this message in context: http://www.nabble.com/Queue-Mem

Disconnecting a broker.

Hi, I have some Java code that starts a broker, gets a connection the the broker using a tcp:// connector, and registers an exception listener for that connection. Is there a way to cause the connection to fail such that exception listener is invoked _without_ explicitly stopping the broker? I'd

Finding Destinations from JNDI

Hello, I am a newbie to both JMS an ActiveMQ. I am confused on how JNDI works with finding topics available on the broker. I am running Geronimo 2.0 w/ ActiveMQ. I created a topic called 'MyTopic'. Now my question is, I am trying to subscribe to the topic. I want to know how I can get 'MyTopi

durable subscriptions

Hello activemq users , In my project we'll be using durable subscriptions. Is there any example or code sample which explains the usage of durable subscriptions using active mq ? please let me know, thanks, Suchitha.

Re: Async Exception: Broken Pipe

do the errors exist on the latest 4.2 snapshot? On 2 Feb 2007, at 17:44, Paul French wrote: These two other posts seem related and have not been responded to, I would appreciate any advice since I'm snookered at the moment.. http://www.nabble.com/onAsyncException-and-Broken-Pipe-proble

Re: Async Exception: Broken Pipe

These two other posts seem related and have not been responded to, I would appreciate any advice since I'm snookered at the moment.. http://www.nabble.com/onAsyncException-and-Broken-Pipe-problem-t1664826.html#a4511552 http://www.nabble.com/stopping-master-bridge%2C-negociation-timeout---out

RE: No effect on maximumRedeliveries setting

Thanks James for your explanation on Connection Factories, Now I am using Jencks for inbound. I am throwing a Runtime exception in order to test max redelivery setting (I couldn't find any better way to test with MDPs). If there are no exceptions thrown from MDP messages could be consumed continuo

ActiveMQConnection.createConnectionConsumer bug?

Okay, from what I can tell, when using the ra activation spec driven consumer construction, the ConsumerInfo options where getting lost. Upon removing the errant 'this.' and rebuilding the activemq-core module, things are now working for me. snippet from org.apache.activemq.ActiveMQConnection.ja

Re: Queue question

Thank you for explaining the PERSISTENT setting to me. I'm still unclear about a few things, though. First, what is a DurableSubscriber then, how does that affect anything, and how does that work with PERSISTENT/non settings? Secondly...what I'm really trying to accomplish, is that some of the

monitor AMQ

All, I'm evaluating a JMS implementation for a project. Have a question on the stats of queue. from Connector->openwire, i have DequeueCount=6 EnqueueCount=6 >From MyQueue, i have ConsumerCount=1 DequeueCount=6 DispatchedCount=6 EnqueueCount=8 QueueSize=2 Why the EnqueueCount from two pl

Re: Can't set prefetch size!

magic.moose wrote: > > jms.redeliveryPolicy.allPrefetchValues is not recognized as correct > connection param in ver. 4.1. > i tried jms.prefetchPolicy.all. Without success. That's weird, because that's what I use and it works. :) -- Christopher G. Stach II

Re: Queue question

As far as I know - and someone please correct me if I am wrong... The NON_PERSISTENT has to do with whether or not the jms service provider ( activemq in this case ) will persist the message in case ACTIVEMQ dies. If you try your scenario below but add step 2.5 of stop activemq, since you send d

Re: Can't set prefetch size!

jms.redeliveryPolicy.allPrefetchValues is not recognized as correct connection param in ver. 4.1. i tried jms.prefetchPolicy.all. Without success. Christopher G. Stach II wrote: > > magic.moose wrote: >> >> I tried that. Resource Adapter simply references connectionFactory: >> >

Re: No effect on maximumRedeliveries setting

James Strachan wrote: > On 2/1/07, Christopher G. Stach II <[EMAIL PROTECTED]> wrote: >> James Strachan wrote: >> > I'd certainly recommend never using the >> > org.apache.activemq.pool.PooledConnectionFactory for anything other >> > than sending messages with Spring's JmsTemplate as described here

Re: Async Exception: Broken Pipe

Placing the broker on another idendepent machine made no difference. I ran the broker in DEBUG and here is some of the relevant output. I really need some help here since I cannot scale the application as required. DEBUG TransportConnection- Setting up new connection: org.apache.act [

Re: Can't set prefetch size!

magic.moose wrote: > > I tried that. Resource Adapter simply references connectionFactory: > class="org.apache.activemq.xbean.BrokerFactoryBean" > depends-on="serverConnector"> > value="classpath:broker.xml" /> > > >

Re: No effect on maximumRedeliveries setting

On 2/1/07, Christopher G. Stach II <[EMAIL PROTECTED]> wrote: James Strachan wrote: > I'd certainly recommend never using the > org.apache.activemq.pool.PooledConnectionFactory for anything other > than sending messages with Spring's JmsTemplate as described here > http://activemq.apache.org/spri

Re: Can't set prefetch size!

On 2/2/07, magic.moose <[EMAIL PROTECTED]> wrote: I tried that. Resource Adapter simply references connectionFactory: I'm confused - I don't see any attempt to set the prefetch policy in your XML? If you are explicitly creating a connectionFactory and passing it into the RA you could try conf

Re: Network broker fails to start due to JournalLockedException

Are you absolutely positive that you are not creating a broker automatically via a JMS connection being created with a vm:// transport - before you initialize your broker? i.e. you are actually creating 2 brokers by mistake On 2/1/07, William Blackburn <[EMAIL PROTECTED]> wrote: I am using two e

Re: Async Exception: Broken Pipe

So first off, ActiveMQ supports auto-reconnection to avoid things hanging if for whatever reason a socket is closed by your OS / hardware /network http://activemq.apache.org/how-can-i-support-auto-reconnection.html Also each Connection created in ActiveMQ tends to create a socket and a thread on

Re: durable subscriptions

On 2/2/07, Suchitha Koneru (sukoneru) <[EMAIL PROTECTED]> wrote: Hello activemq users , In my project we'll be using durable subscriptions. Is there any example or code sample which explains the usage of durable subscriptions using active mq ? There's no real difference with dura

Async Exception: Borken Pipe

Hello, I have a single client laptop that connects to the broker on another machine, creates a temp queue and sends text messages to a main queue. The client also starts a listener consumer to consume the replies given on the temp queue. The server consumes messages from the main queue does some

Re: activemq cms stomp - creating a topic from message->getCMSReplyTo() does not work

Great! will do! On 2/2/07, Lalit Nagpal <[EMAIL PROTECTED]> wrote: Hey Nate- It works great it works bcoz now message->getCMSReply() method accepts a ::cms::Destination ... that makes it easier now This change and the introduction of setter/getter methods in the ::cms::Message

Re: High latency for small messages problem

this is odd! ActiveMQ writes messages onto the transport (in this case a tcp/ip socket) asap. As nagles has no affect, I suspect this is an OS issue cheers, Rob Davies http://rajdavies.blogspot.com/ On 2 Feb 2007, at 09:33, davidmc wrote: Hello, We are evaluating the possible use of A

Re: activemq cms stomp - creating a topic from message->getCMSReplyTo() does not work

Hey Nate- It works great it works bcoz now message->getCMSReply() method accepts a ::cms::Destination ... that makes it easier now This change and the introduction of setter/getter methods in the ::cms::Message class for different data types like setInt() setFloat() setLong() etc

High latency for small messages problem

Hello, We are evaluating the possible use of ActiveMQ in our projects and have encountered this problem. When sending small messages (for example, ByteMessages with a 1KB byte array) from a producer to a consumer through a broker, there is much higher latency than with bigger messages (for examp

Re: Can't set prefetch size!

I tried that. Resource Adapter simply references connectionFactory: where broker.xml: http://activemq.org/config/1.0";>

How can I configure an "Exclusive Consumer" queue with a Jencks JCAConnector?

I'm attempting to create a Jencks JCAConnector around a "consumer.exclusive=true" marked queue, but the constructed consumer appears to not be exclusive. Has anybody attempted a similar use case or know why this shouldn't work? I'm using Spring 2.0.2, ActiveMQ 4.1, and Jencks 2.0 Here are the r