Re: Apollo 1.6 multiple connected/disconnected messages while using Stomp

2013-11-14 Thread AlexP
After some debugging, we discovered that Apollo 1.6 Stomp implementation seems to be closing a Stomp connection on an un-subscribe of an invalid subscription. Here is the sample log: 2013-11-14 18:45:36,072 STOMP connection '/127.0.0.1:38038' error: The subscription '2' not found. 2013-11-14 18

Could ActiveMQ service start automatically after installing it as an NT service ?

2013-11-14 Thread HellKnight
The installservice.bat under win32/64 directory makes the installing of ActiveMQ as an windows service very convenient. However, ActiveMQ service is not started by default after I have installed it. Could ActiveMQ service get started automatically right after installing it as an windows service ?

Re: configuring memory usage with peer transport

2013-11-14 Thread mark_bh
I haven't been able to figure out how to configure peer transport in the XML file. Has anybody done that? There doesn't seem to be any documentation about it. -- View this message in context: http://activemq.2283324.n4.nabble.com/configuring-memory-usage-with-peer-transport-tp4674493p4674498.

Re: Expired messages sent to Topic Advisory DLQ as opposed to Activemq.DLQ

2013-11-14 Thread Christian Posta
Expired messages should be moved to ActiveMQ.DLQ. Show your test case and config. On Thu, Nov 14, 2013 at 10:37 AM, wrote: > I sent a few messages with a quick expiry time on them to test out whether > they'd be written to the Activemq.DLQ default. It appears they were written > to the Topic

Re: configuring memory usage with peer transport

2013-11-14 Thread Christian Posta
Maybe you can just specify the full broker config in an external file and configure memory and anything else the standard way.. there might be a way to hack it into the URI like you're asking, but i'd have to play around with that a bit to find whether that's possible... using the external file mig

Re: Managing Deadletter Handler

2013-11-14 Thread Christian Posta
Like I said, the community distro is different from the JBoss distro. In 5.9 (community) it comes out of the box. You can navigate to http://localhost:8161/hawtio On Thu, Nov 14, 2013 at 10:31 AM, wrote: > If it's included, do I need to do a features:install, or do I just kickoff > the hawt

configuring memory usage with peer transport

2013-11-14 Thread mark_bh
I'm using ActiveMQ inside tomcat using the peer transport. My Tomcat server.xml has: It's working fine, but when I upgraded to ActiveMQ 5.9, I get an ERROR message in the log on startup: ERROR .activemq.broker.BrokerService Memory Usage for the Broker (1024 mb) is more than the maximum availab

Re: KahaDB Journal files go missing

2013-11-14 Thread Christian Posta
Maybe this? https://issues.apache.org/jira/browse/AMQ-3120 Or this? https://issues.apache.org/jira/browse/AMQ-4051 Definitely newer than 5.4.2... give 5.9 a spin... On Thu, Nov 14, 2013 at 10:28 AM, wrote: > V5.4.2. Suggested upgrade to what version? > > Regards, > > Barry Barnett > WMQ Enter

Re: Apollo 1.6 multiple connected/disconnected messages while using Stomp

2013-11-14 Thread AlexP
Sure, We are using ReactPHP library's Stomp client, here: https://github.com/reactphp/stomp/tree/master/src/React/Stomp In the Factory, a physical socket is created and then consequently used: https://github.com/reactphp/stomp/blob/master/src/React/Stomp/Factory.php#L53 After the Factory create

Expired messages sent to Topic Advisory DLQ as opposed to Activemq.DLQ

2013-11-14 Thread barry.barnett
I sent a few messages with a quick expiry time on them to test out whether they'd be written to the Activemq.DLQ default. It appears they were written to the Topic Advisory DLQ and Topic Expiry queue... what are these and why wasn't it written to the Queue Activemq.DLQ? Regards, Barry Barnett

Apache.NMS.ActiveMQ openwire client performance

2013-11-14 Thread dantran
Hi I have a need to transport a large amount messages from .NET into java and ActiveMQ seems to be a good good fit for this bridge. However, I am running into some performance that I need to understand. The flow of the transport, consisting of NMS client to push messages, 1K each, into multiple q

RE: Managing Deadletter Handler

2013-11-14 Thread barry.barnett
If it's included, do I need to do a features:install, or do I just kickoff the hawtIO console in some way? Regards, Barry Barnett WMQ Enterprise Services & Solutions Wells Fargo Cell: 704-564-5501 -Original Message- From: Christian Posta [mailto:christian.po...@gmail.com] Sent: Thursd

RE: KahaDB Journal files go missing

2013-11-14 Thread barry.barnett
V5.4.2. Suggested upgrade to what version? Regards, Barry Barnett WMQ Enterprise Services & Solutions Wells Fargo Cell: 704-564-5501 -Original Message- From: Torsten Mielke [mailto:tmie...@redhat.com] Sent: Thursday, November 14, 2013 11:43 AM To: users@activemq.apache.org Subject: Re

Re: Apollo 1.6 multiple connected/disconnected messages while using Stomp

2013-11-14 Thread Christian Posta
Any chance you can post your client code? What stomp lib are you using? On Thu, Nov 14, 2013 at 9:35 AM, AlexP wrote: > We are using Stomp to connect and send messages to Apollo. While we only > establish a single connection and send all our messages on it, we see quite > few connected/disconnec

Apollo 1.6 multiple connected/disconnected messages while using Stomp

2013-11-14 Thread AlexP
We are using Stomp to connect and send messages to Apollo. While we only establish a single connection and send all our messages on it, we see quite few connected/disconnected messages. Here is how we defined our connector we use for stomp: Every time we use Stomp we see these messages on th

Re: KahaDB Journal files go missing

2013-11-14 Thread Torsten Mielke
Which version of ActiveMQ are you using? I have seen these errors on older versions but not lately. Perhaps upgrading is a solution? Regards, Torsten Mielke tmie...@redhat.com tmielke.blogspot.com On Nov 14, 2013, at 14:19 PM, wrote: > How would a journal file go 'missing'? > > Our AMQ u

Re: Rollback/NACK a single message

2013-11-14 Thread Timothy Bish
Correct, NMS.ActiveMQ behaves the same as a JMS client so this should work. On 11/14/2013 11:04 AM, Christian Posta wrote: I'm not too familiar with the NMS libs... but for the Java JMS impl, you would just throw an exception + combine with the redelivery policy (eg, disable redelivery?) and tha

Re: 5.3 question and server upgrade question...

2013-11-14 Thread Ned Wolpert
After I say you wrote 'prefetchExtension=false' I looked it up and found this bug sounds exactly like what I'm hitting: https://issues.apache.org/jira/browse/AMQ-2651 which led me to you talking on http://grokbase.com/t/activemq/users/103bdh5cgx/prefetchextension-off-by-1-for-transacted-consumers-w

Re: mock topic

2013-11-14 Thread Christian Posta
If there are no consumers, messages should get thrown away when sent to a topic, unless there are durable still subscribers around. On Tue, Nov 12, 2013 at 1:47 AM, mynickname wrote: > Hi > I have an application that produces messages into a topic. > and there is no consumers so messages are stat

Re: Managing Deadletter Handler

2013-11-14 Thread Christian Posta
It's included in the latest ActiveMQ 5.9. For earlier versions, take a look here: http://www.christianposta.com/blog/?p=315 HawtIO is here: http://hawt.io On Thu, Nov 14, 2013 at 8:10 AM, wrote: > Where do we get HawtIO? > > Regards, > > Barry Barnett > WMQ Enterprise Services & Solutions > Well

Re: active mq vs. a-mq CLI

2013-11-14 Thread Christian Posta
Correct. The community distro of Apache ActiveMQ does not have that same CLI as JBoss A-MQ. On Thu, Nov 14, 2013 at 8:04 AM, wrote: > So with Active MQ, there isn't a CLI that I could pull up like with A-MQ? I > go to /bin in my install path for A-MQ, kickoff the amq script, and my CLI is > i

RE: Managing Deadletter Handler

2013-11-14 Thread barry.barnett
Where do we get HawtIO? Regards, Barry Barnett WMQ Enterprise Services & Solutions Wells Fargo Cell: 704-564-5501 -Original Message- From: Christian Posta [mailto:christian.po...@gmail.com] Sent: Thursday, November 14, 2013 11:09 AM To: users@activemq.apache.org Subject: Re: Managing D

Re: Managing Deadletter Handler

2013-11-14 Thread Christian Posta
You could use JMX.. .you could use apache camel.. but HawtIO has a great web-based UI for doing this pretty easily :) On Tue, Nov 12, 2013 at 7:57 PM, letsplay wrote: > I have defined DLQ's for all the queues available under broker. Q1,Q2,Q3 are > the queues and DLQ.Q1,DLQ.Q2,DLQ.Q3 are the deadl

RE: active mq vs. a-mq CLI

2013-11-14 Thread barry.barnett
So with Active MQ, there isn't a CLI that I could pull up like with A-MQ? I go to /bin in my install path for A-MQ, kickoff the amq script, and my CLI is initiated. I told someone to provide me output from Active MQ with an 'admin:list', but they/we don't know how to startup the CLI. Regards,

Re: Rollback/NACK a single message

2013-11-14 Thread Christian Posta
I'm not too familiar with the NMS libs... but for the Java JMS impl, you would just throw an exception + combine with the redelivery policy (eg, disable redelivery?) and that would send back the "poison pill" or "nack" On Thu, Nov 14, 2013 at 6:42 AM, jlpedrosa wrote: > Hi All,We are coding an ap

Re: active mq vs. a-mq CLI

2013-11-14 Thread Christian Posta
You're asking about JBoss A-MQ? Well, ActiveMQ is bundled within Karaf in JBoss A-MQ. So it's karaf that gives the CLI. On Thu, Nov 14, 2013 at 7:14 AM, wrote: > In amq, I go to /bin and kick off the amq script to bring up the CLI. What > do I do in Active MQ to get the CLI up and running? > >

Re: WARN | Store update waiting on 1 replica(s) to catch up to log position 0

2013-11-14 Thread Hiram Chirino
Raj, Your slave probably can't connect to your master. Could be a firewall issue. Or it could be that the master is not advertising the right hostname for clients to connect to in ZooKeeper. Try configuring the hostname attribute on the replicatedLevelDB attribute. That might fix it for you.

Active MQ 5.8.0.rar - Disabling XAtransaction

2013-11-14 Thread SaniO
I am using ActiveMQ 5.8.0 rar to post a message from Webshpere. This rar support XAtransaction by default. How can I disable and use only JMS transactions rather than XA transactions. -- View this message in context: http://activemq.2283324.n4.nabble.com/Active-MQ-5-8-0-rar-Disabling-XAtransac

Re: WARN | Store update waiting on 1 replica(s) to catch up to log position 0

2013-11-14 Thread Raj Khanna
I am trying to use the setup as explained in the post with JDK "1.7.0_21", ZooKepper 3.4.3 and AMQ 5.10 SNAPSHOT version. But I can not get rid of the following error WARN | Store update waiting on 1 replica(s) to catch up to log position 0. I think the problem is that I dont see the Slave start

Managing Deadletter Handler

2013-11-14 Thread letsplay
I have defined DLQ's for all the queues available under broker. Q1,Q2,Q3 are the queues and DLQ.Q1,DLQ.Q2,DLQ.Q3 are the deadletter queues for them. Due to broker crash all the messages destined to Application queues are delivered to corrosponding Deadletter queue. How to redeliver these deadletter

mock topic

2013-11-14 Thread mynickname
Hi I have an application that produces messages into a topic. and there is no consumers so messages are statcked. How can i sent these messages to a "bin" without creating a consumer ? Thanks -- View this message in context: http://activemq.2283324.n4.nabble.com/mock-topic-tp4674197.html Se

Re: ActiveMQ CPP

2013-11-14 Thread Timothy Bish
On 11/14/2013 10:13 AM, Mark wrote: On Thu, 14 Nov 2013 09:57:40 -0500, Timothy Bish wrote: On 11/14/2013 09:16 AM, Mark wrote: Does the method cms::BytesMessage::getBodyBytes() return a buffer that requires free-ing by the caller? From the API Docs /** * Gets the byt

active mq vs. a-mq CLI

2013-11-14 Thread barry.barnett
In amq, I go to /bin and kick off the amq script to bring up the CLI. What do I do in Active MQ to get the CLI up and running? Regards, Barry

Re: ActiveMQ CPP

2013-11-14 Thread Mark
On Thu, 14 Nov 2013 09:57:40 -0500, Timothy Bish wrote: >On 11/14/2013 09:16 AM, Mark wrote: >> Does the method cms::BytesMessage::getBodyBytes() return a buffer that >> requires free-ing by the caller? >> >> >> > From the API Docs > > /** > * Gets the bytes that are contained in

Re: ActiveMQ CPP

2013-11-14 Thread Timothy Bish
On 11/14/2013 09:16 AM, Mark wrote: Does the method cms::BytesMessage::getBodyBytes() return a buffer that requires free-ing by the caller? From the API Docs /** * Gets the bytes that are contained in this message and returns them in a newly * allocated array that

Rollback/NACK a single message

2013-11-14 Thread jlpedrosa
Hi All,We are coding an application to process events in a queue. We are using NMS - ActiveMQ 1.6. In my mental model the best transactionality comes with: IndividualAcknowledge. If the proccess goes OK, the message is acknoledge, up to there no problem. But message has no rollback/nack method. So

ActiveMQ CPP

2013-11-14 Thread Mark
Does the method cms::BytesMessage::getBodyBytes() return a buffer that requires free-ing by the caller?

KahaDB Journal files go missing

2013-11-14 Thread barry.barnett
How would a journal file go 'missing'? Our AMQ usage uses the file store or KahaDB. A few months ago there was an incident wherein, for reasons I cannot found the root cause, some KahaDB journal files (*.log) got deleted or are missing. Due to this consumers cannot get the messages because the

Re: Can I control the output of command ps -ef|grep activemq ?

2013-11-14 Thread Torsten Mielke
Have you considered using jps -l -m instead of the ps command? Regards, Torsten Mielke tmie...@redhat.com tmielke.blogspot.com On Nov 14, 2013, at 01:23 AM, HellKnight wrote: > Mr. Mielke: > Quote from your post: > 1063855181 71497 71476 0 0:00.38 ttys0150:04.99 > /System/Library/Framew

Re: Can I control the output of command ps -ef|grep activemq ?

2013-11-14 Thread Claus Ibsen
Hi I suggest you look elsewhere for help and ideas how to get a process list to only show limited information. The unix shell is powerful, and you can pipe output to other commands that can parse and extra details you only want, such as awk or sed. On Thu, Nov 14, 2013 at 1:23 AM, HellKnight