Re: ACKs not being delivered correctly in ActiveMQ 5.1 (QueueSize growing)

Rob, what is the solution to use in the C# client. I don't believe it has a PooledConnectionFactory and can you please shed some light on why the way that it used to work in 4.1 doesn't work in 5.1? Why should we need to replace the way we establish a connection? rajdavies wrote: > > please

ACKs not being delivered correctly in ActiveMQ 5.1 (QueueSize growing)

I was using a C# client (NMS) to connect to the ActiveMQ 5.1 Broker and I am noticing that the broker always sends me 11 messages and then stops sending (am expecting to get about 200). I can reproduce this consistently - it always sends me 11 messages. When I open JConsole it looks like the size

Re: C# Client throwing StackOverflowException (easy fix but can't fix it correctly)

this, fixed it, and checked it in. If > you > get latest, you should see the fix. Would you test it out and make sure > it > now works for you. > > Thanks, > Jim > > On Mon, Aug 11, 2008 at 3:50 PM, sparky2708 <[EMAIL PROTECTED]> wrote: > >> >> J

C# Client throwing StackOverflowException (easy fix but can't fix it correctly)

Just looked at the code for the C# client from the trunk and it doesn't work. In class ActiveMQDestination.cs I get StackOverflowException – this is pretty straightforward if you look at the code below from ActiveMQ. How can this be put into the code base? (it is an infinite loop). I don't know ho

Re: failing to close a connection leaves consumers behind that prevent new consumers receiving messages

I had this same problem since 4.1.0-incubator. Learned to make killing off the dead consumers in jconsole as part of my morning routine. Glad you put a test case. I hope this will get fixed. I took your post and setup an Issue: AMQ-1850. Ossory wrote: > > Hi, > I have an issue where a JMS clie

Re: 5.2.0 release schedule?

Am also waiting for 5.2. Any concrete timeframe? Was really disappointed today that I couldn't use 5.1 as it has a major bug with the Queue Size not emptying out. Going back to the latest stable version: 4.1.0-incubator. <> Sigh, Sigh rajdavies wrote: > > > On 9 Jul 2008, at 09:12, mmastrac wr

Re: How can Dequeuecount == Enqueuecount == Dispatchcount and QueueSize != 0?

uld come up with a test case! > On 8 Jul 2008, at 18:49, sparky2708 wrote: > >> >> I am using ActiveMQ 5.1.0 and I can't explain the following in >> JConsole (I >> never pressed resetStats()). This seems to happen to most of my >> topics: >> >> h

Re: How can Dequeuecount == Enqueuecount == Dispatchcount and QueueSize != 0?

Could this be because the acknowledge/commit is not working correctly? rajdavies wrote: > > be great if you could come up with a test case! > On 8 Jul 2008, at 18:49, sparky2708 wrote: > >> >> I am using ActiveMQ 5.1.0 and I can't explain the following in &g

Re: How can Dequeuecount == Enqueuecount == Dispatchcount and QueueSize != 0?

u could come up with a test case! > On 8 Jul 2008, at 18:49, sparky2708 wrote: > >> >> I am using ActiveMQ 5.1.0 and I can't explain the following in >> JConsole (I >> never pressed resetStats()). This seems to happen to most of my >> topics: >> &g

How can Dequeuecount == Enqueuecount == Dispatchcount and QueueSize != 0?

I am using ActiveMQ 5.1.0 and I can't explain the following in JConsole (I never pressed resetStats()). This seems to happen to most of my topics: http://www.nabble.com/file/p18345113/untitled.jpg Any ideas? -- View this message in context: http://www.nabble.com/How-can-Dequeuecount-%3D%3D-En

Re: Services connected to ACTIVEMQ stop receiving messages (ActiveMQ 5.1.0)

I think you might be right. Is there a way to monitor when ActiveMQ runs out of memory? What could be some of the reasons it would run out of memory? bsnyder wrote: > > On Tue, Jul 8, 2008 at 8:20 AM, sparky2708 <[EMAIL PROTECTED]> wrote: >> >> I am noticing that

Re: why my consumer client always lost connection

Check your firewall. We had a similar problem - our firewall would disconnect the connection if it was idle/open for too long. It looked like the client was just losing it without any error messages. dingjing wrote: > > thank you for your advice, i have upgraded to 2.2, the bugs stilll > happe

Services connected to ACTIVEMQ stop receiving messages (ActiveMQ 5.1.0)

I am noticing that services connected to an ACTIVEMQ Broker stop receiving messages all of a sudden. I don't see anything in any of the ACTIVEMQ logs. I am using ActiveMQ 5.1.0. How can I figure out what is going on? (I have a suspicion that the broker might stop sending messages maybe because the

How do I change the activemq.log directory

I keep getting the following error message (I want everything to be logged to /tmp directory. Please help... Not sure what I am doing wrong: Loading message broker from: xbean:file:/activemq/conf/dev/activemq_master.xml log4j:ERROR setFile(null,true) call failed. java.io.FileNotFoundException: /a

CONFUSED!?!? What is the released version now?

What is the release version of ActiveMQ at this point? 5.0.0 or 5.1.0? On the download page: http://activemq.apache.org/download.html It says: The latest stable release is the ActiveMQ 5.0.0 Release And then follows the list of downloads (notice the 1st one): * ActiveMQ 5.1.0 Release *

Re: when will activemq 5.0.1 come out? how will testing improve in future releases?

Is it possible to do a release sooner rather than wait for camel? (how long of a wait are we talking about here? days? weeks? or months?) I would really like to move to 5.0 but I can't use a SNAPSHOT version in production. -- View this message in context: http://www.nabble.com/when-will-activemq

Is my destinationPolicy working [trying to deal with a slow consumer]

I recently put a variant of the following (in my activemq.xml file). When I start up the broker I don't see any confirmation that a destination policy has been setup? How can I test or confirm that it has been accepted and it is working? Here's your sample code:

Re: Queue size of broker increases all the time

I saw the same thing. Put in a JIRA so someone fixes it before the next version comes out. Michal Singer wrote: > > Hi. I use the 5.1 snapshot. > I see that the queue size of broker, and ActiveMQ.Advisory.TempQueue, > increase all the time. > > At first, the problem was that auto_ack did not w

when will activemq 5.0.1 come out? how will testing improve in future releases?

Since 5.0.0 is basically unusable with all the InactivityMonitor and EOFExceptions when will a 5.0.x version become available that we can use? 5.1 Snapshot seems not much better. Just out of curiosity, how did 5.0.0 come out with so many bugs in it that it is practically unusable? How will the te

Re: javax.jms.IllegalStateException: The producer is closed

ler-2 wrote: > > Did you close the session associated with the consumer? > > Mario > > On 3/6/08, sparky2708 <[EMAIL PROTECTED]> wrote: >> >> Periodically I have the following error. (I don't close the producer >> anywhere >> in my code) Any id

javax.jms.IllegalStateException: The producer is closed

Periodically I have the following error. (I don't close the producer anywhere in my code) Any ideas why? javax.jms.IllegalStateException: The producer is closed at org.apache.activemq.ActiveMQMessageProducer.checkClosed(ActiveMQMessageProducer.java:333) at org.apache.activemq.Acti

Does anyone have any software to monitor clients connected to ACTIVEMQ

Does anyone have any software to monitor clients connected to ACTIVEMQ? I am looking for something similar to TIBCO Hawk? Any suggestions? (I think jconsole is a little weak). I would like to see how messages are flowing more transparently and which of the services connected to ACTIVEMQ are up or

ActiveMQ 5.1-SNAPSHOT-125551-32 doesn't work

I get this error message when trying to start the SNAPSHOT version: ACTIVEMQ_HOME: /production/javalib/activemq/dev ACTIVEMQ_BASE: /production/javalib/activemq/dev Loading message broker from: xbean:file:/production/trade_execution/conf/dev/activemq_master.xml INFO BrokerService

Why would the queue size keep growing?

Anybody have any ideas why the queueSize would be growing in most of my topics under 5.1-SNAPSHOT? If I switch to activemq 4.0 it seems fine. -- View this message in context: http://www.nabble.com/Why-would-the-queue-size-keep-growing--tp15715777s2354p15715777.html Sent from the ActiveMQ - User

Re: Inactivity monitor exception is closing connection.

Would love to know how to do that. Can you give me an example of a test case or where I would find out how to write a test case? rajdavies wrote: > > Could you please provide a test case ? > > cheers, > > Rob > On 21 Feb 2008, at 22:52, sparky2708 wrote: > >

Re: Inactivity monitor exception is closing connection.

s which has been inactive > for a long time. You can set the time for inactive connection by set > activitymonitor. > > > On Thu, Feb 21, 2008 at 2:52 PM, sparky2708 <[EMAIL PROTECTED]> wrote: > >> >> This started happening since we upgraded from 4.1.0

Re: Inactivity monitor exception is closing connection.

This started happening since we upgraded from 4.1.0. 4.1.0 doesn't seem to have this problem. sparky2708 wrote: > > I am getting the same error with SNAPSHOT-5.1: > > 21/02/2008 08:03:34,335 ERROR [ActiveMQ Connection Worker: > tcp://puccell/10.0.55.197:61616] (Mes

Re: Inactivity monitor exception is closing connection.

I am getting the same error with SNAPSHOT-5.1: 21/02/2008 08:03:34,335 ERROR [ActiveMQ Connection Worker: tcp://puccell/10.0.55.197:61616] (MessageManager.java:439) - com.company_name.messaging.MessageManager::onException javax.jms.JMSException: Channel was inactive for too long: puccell/10.0.55.

Re: ActiveJMS & ActiveMQ

Am not a .NET guy. Ideally something > like typing in an Excel cell: > > =activemq("FOO.TOPIC","myField") > > :-) > > > Thanks. > > > sparky2708 wrote: >> >> Has anyone had any success running ActiveJMS to connect to ActiveMQ? I

ActiveMQ & NetMon

I am having issues monitoring activemq with netmon (10.0.1.8 is where netmon is running): ERROR TransportConnector - Could not accept connection from /10.0.1.8:47757: java.net.SocketException: Socket closed java.net.SocketException: Socket closed at java.net.SocketOutputStream

All kinds of errors while running the ActiveMQ Broker. Please help!

I am getting all kinds of errors when I run the broker. And then the broker stops responding. Does anyone have any suggestions: [EMAIL PROTECTED] /tmp]$ more activemq_master.log ACTIVEMQ_HOME: /usr/local/activemq Loading message broker from: xbean:file:activemq_master.xml INFO BrokerService

wireFormat.maxInactivityDuration=0 affecting durable consumers

I think when I added: wireFormat.maxInactivityDuration=0 to the url my durable subscribers are always stuck in ActiveMQ (I think they never get disconnected even though my client has died). When I try to restart the durable subscriber it always fails. When I restart the durable consumer I always g

Re: What are version 5.0 release dates?

Any responses? xbranko wrote: > > What are the release dates for version 5.0? Even having tentative dates > (with no obligations or strings attached) would be great. > > Thanks, > Branko > -- View this message in context: http://www.nabble.com/What-are-version-5.0-release-dates--tf3984671s

Re: ActiveMQ onMessage() callback not async

ent message > processing, you will need multiple threads; using multiple Sessions might > be the way to go. Someone else with more expertise here could say more. > > > sparky2708 wrote: >> >> I am finding that when I receive messages in my java client that I c

ActiveMQ onMessage() callback not async

I am finding that when I receive messages in my java client that I can only process one request at a time. It seems like the method: onMessage(Message arg) from MessageListener interface doesn't get called asynchronously. Do I need to start a thread in this method to get the async behavior that I

Where is the Log4Net config file in ActiveMQ

When I added log4net to my c# project I started getting the following error: at System.Configuration.ConfigurationManager.PrepareConfigSystem() at System.Configuration.ConfigurationManager.GetSection(String sectionName) at System.Configuration.PrivilegedConfigurationManager.GetSection(Stri

How do I remove ActiveMQ.Advisory.Producer.Queue.xxxx

My ActiveMQ clients create TEMPORARY queues and I have been looking through the active queues recently and I noticed a number of advisory queues are sticking around that refer to the temporary queues that I created. It seems that even though the temporary queues are gone the advisory topics are st

Re: Master/Slaver persistent?

Any ideas on what could be happening here? sparky2708 wrote: > > Here's how my slave starts up. Is the line in bold normal? (null looks > suspicious...): > > INFO BrokerService - ActiveMQ 4.1.1 JMS Message Broker > (slave) is startin

Re: Can't receive messages from C# NMS when sent using Java

Nevermind it was me... found the issue -- not an issue in ActiveMQ. sparky2708 wrote: > > Am using ActiveMQ 4.1.1 (seems to be fine in 4.1.0 so am going to revert > back). Every time I receive a message of type "TextMessage" in my C# NMS > client sent from Java (activem

Can't receive messages from C# NMS when sent using Java

Every time I receive a message in my C# NMS client I get the following error: Value cannot be null. Parameter name: type -- View this message in context: http://www.nabble.com/Can%27t-receive-messages-from-C--NMS-when-sent-using-Java-tf3687799s2354.html#a10309362 Sent from the ActiveMQ - User m

Re: Master/Slaver persistent?

been established. INFO BrokerService - ActiveMQ JMS Message Broker (slave, ID:slave-38738-1178199921573-2:0) started INFO MasterConnector- Slave connection between vm://slave#0 and tcp://master/10.0.55.197:61616 has been established. sparky2708 wrote: > >

Re: Master/Slaver persistent?

I have the same problem WITHOUT using the PERSISTENT delivery mode. Maybe we have some error in the activemq.xml file. Can someone check... My file for the master looks like: == for the master: == http://activemq.org/config/1.0";>

Please help understand the difference between these tags within the activemq.xml file

Sorry for asking so many questions but I started some mainstream development using ActiveMQ and things just started popping up. Let's say that I want to achieve a pure master/slave configuration. -- So in my activemq.xml for the MASTER I pu

I get this error periodically: SEVERE: Failed to parse URI: null

I see something else that I can't explain in version 4.1.1. For some reason I get this error periodically but I never saw it in 4.1.0. I am not sure where it is coming from and it doesn't seem to be consistent. I can run my application and it sometimes will produce the following message and other

Re: Why does this Exception happen periodically in the broker

Looks like the other post. Seems to have some issue when using with DeliveryMode.PERSISTENT. Used to be OK in the previous version. sparky2708 wrote: > > I get this exception periodically in the broker log (am using v 4.1.1 of > ActiveMQ) and am not sure why it is happening or what i

Why does this Exception happen periodically in the broker

I get this exception periodically in the broker log (am using v 4.1.1 of ActiveMQ) and am not sure why it is happening or what is causing it (I have a pure Master/Slave configuration): ERROR MasterBroker - Slave Failed java.lang.AssertionError: Unsupported Method at org.

Re: Shutdown script doesn't seem to work in 4.1.1

Yes. Just running it out of the box. Adrian Co wrote: > > Is JMX enabled in the broker? > > sparky2708 wrote: >> I get the following exception when I run the shutdown script. Any ideas? >> : >> >> ACTIVEMQ_HOME: /home/teprod/apache-activemq-4.1.1 >> A

Re: Why is ActiveMQ 4.1.1 trying to make a connection to an IP address in PA?

What is the multicast address that corresponds to "multicast://default"? sparky2708 wrote: > > James, > thanks... So I just do the following (see below). Can you explain why > it was finding that particular IP address? Or can you point me to how &g

Re: Why is ActiveMQ 4.1.1 trying to make a connection to an IP address in PA?

covery; you might > wanna disable that. > > On 5/1/07, sparky2708 <[EMAIL PROTECTED]> wrote: >> >> Hi, >>Our System Administrator was looking at the connections that my >> out-of-the-box ActiveMQ installation was doing and we couldn't figure out >>

Why is ActiveMQ 4.1.1 trying to make a connection to an IP address in PA?

Hi, Our System Administrator was looking at the connections that my out-of-the-box ActiveMQ installation was doing and we couldn't figure out why it was trying to connect to the following IP address in PA (port 61616): c-68-84-120-96.hsd1.pa.comcast.net (68.84.120.96) Can someone please inves

Shutdown script doesn't seem to work in 4.1.1

I get the following exception when I run the shutdown script. Any ideas? : ACTIVEMQ_HOME: /home/teprod/apache-activemq-4.1.1 ACTIVEMQ_BASE: /home/teprod/apache-activemq-4.1.1 ERROR: java.lang.RuntimeException: Failed to execute stop task. Reason: java.io.IOException: Failed to retrieve RMIServer

IKVM.NET & ActiveMQ

I was trying to use IKVM with ActiveMQ because then I can get all the Java features of ActiveMQ in .NET instead of using SPRING.NET. I can't seem to get it to run. Does someone have an idea of what might be happening. My program runs fine when I invoke it with "java" but when I invoke it with "ikv

Re: Why QueueSize becomes a negative number

I've had this happen a few times. This usually means that you might have durable subscribers that went down and in the jconsole window you clicked "reset" on the queue statistics. When the durable consumers come back up the messages go out to them therefore turning the count in the queue to a nega

Re: [NMS] download of Spring.Messaging.Nms available

from there... James.Strachan wrote: > > On 4/3/07, sparky2708 <[EMAIL PROTECTED]> wrote: >> >> How is this different from the NMS that used to be provided by ActiveMQ? > > It uses the NMS from ActiveMQ; its a utility layer above NMS. So if > you're aware of Sp

Re: [NMS] download of Spring.Messaging.Nms available

How is this different from the NMS that used to be provided by ActiveMQ? Does this support failover URLS? James.Strachan wrote: > > For folks using .Net with ActiveMQ we highly recommend the use of > Spring.Messaging.Nms for working with NMS. > > You can grab a binary download here... > http:/

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

(2) Click on the tab "Operations" (3) Invoke the method "Remove Topic" with the topic name as the argument Thanks for everyone's help! bsnyder wrote: > > On 4/2/07, sparky2708 <[EMAIL PROTECTED]> wrote: >> >> How do I delete a queue or topic that

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 m

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

(indicated in the request they make). The client's control queue should disappear when the client disappears. How can my service send messages to a client's temporary queue if I can't send by name? Or what's an alternative way to accomplish the same thing? James.Strachan wro

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 = 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

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

DESIGN GUIDANCE PLEASE: Initial Set of Messages followed by Incremental Messages

Hi, I am looking for suggestions/example code on how to do the following: (1) On client startup my service would Initially push out some messages to the client (2) Push out incremental messages to client when responding to some other message that I receive So for (1) I was thinking I would ne

FAILOVER with C# NMS Client

How do I achieve failover for C# NMS Clients? -- View this message in context: http://www.nabble.com/FAILOVER-with-C--NMS-Client-tf3295828s2354.html#a9168460 Sent from the ActiveMQ - User mailing list archive at Nabble.com.

RE: JDBC Table Descriptions

ce > tables will be generated. > > -Nilantha > > -Original Message- > From: sparky2708 [mailto:[EMAIL PROTECTED] > Sent: Thursday, February 22, 2007 11:27 AM > To: users@activemq.apache.org > Subject: JDBC Table Descriptions > > > Where can I find the des

JDBC Table Descriptions

Where can I find the descriptions of the JDBC tables that I need to create in my database for JDBC persistence? i.e. what tables I need to create, what columns, what types for each column. (I couldn't find the info on the main site) -- View this message in context: http://www.nabble.com/JDBC-Tab

ActiveMQ 4.1 link on www.activemq.com

ActiveMQ 4.1 link on www.activemq.com is missing. Actually, just found it in the archive section. I think someone posted the wrong news article on the main page. -- View this message in context: http://www.nabble.com/ActiveMQ-4.1-link-on-www.activemq.com-tf3262504s2354.html#a9067924 Sent from th

Re: Can't set 'useAsyncSend' on Connection

I believe so but maybe it never worked correctly. Maybe I forgot to do "jms.$PROPERTY" and just did "$PROPERTY" so it never complained about it. James.Strachan wrote: > > On 2/13/07, sparky2708 <[EMAIL PROTECTED]> wrote: >> >> it used to wo

Re: Can't set 'useAsyncSend' on Connection

it used to work in v3 James.Strachan wrote: > > The C# client doesn't support the various properties that the Java > client supports > > On 2/13/07, sparky2708 <[EMAIL PROTECTED]> wrote: >> >> When using the MNS C# client and using the foll

Can't set 'useAsyncSend' on Connection

When using the MNS C# client and using the following URL: tcp://localhost:61616?jms.useAsyncSend=true&jms.dispatchAsync=true I get an error message that says: "no such property useasyncsend on class: Connection" Am I forming the URL correctly? -- View this message in context: http://www.nabb

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

. Stach II wrote: > > sparky2708 wrote: >> Just FYI, C# .NET Development is not possible at this point with ActiveMQ >> C# >> NMS Client as establishing a connection will fatally crash the client >> (see >> JIRA). Please, please, please address this issue ASAP as

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

Just FYI, C# .NET Development is not possible at this point with ActiveMQ C# NMS Client as establishing a connection will fatally crash the client (see JIRA). Please, please, please address this issue ASAP as this is a show stopper for all of us that are trying to use ActiveMQ across different pla

Re: C#/.NET implementation see problem but don't know how to fix it

Protecting it doesn't work. This is probably some part of the protocol so I can't just make that change. Ok, I guess at this point I am stuck. sparky2708 wrote: > > Did some more debugging and narrowed down the problem: > > in WireFormatNegotiator the "command"

Re: C#/.NET implementation see problem but don't know how to fix it

port sender, Command command) in D:\activemq-dotnet\activemq-dotnet\src\main\csharp\ActiveMQ\Transport\WireFormatNegotiator.cs:line 75 at ActiveMQ.Transport.Tcp.TcpTransport.ReadLoop() in D:\activemq-dotnet\activemq-dotnet\src\main\csharp\ActiveMQ\Transport\Tcp\TcpTransport.cs:line 146 sparky2708 wro

Re: C#/.NET implementation not working

Could there be something wrong with the C#/.NET release in the HEAD of SVN? Shouldn't there be some stable tag or branch that I need to check out? sparky2708 wrote: > > A few days ago I checked out the latest C#/.NET code using svn as per the > instructions on the website. I