Re: How can I unsubscribe the topic

2013-10-10 Thread Christian Posta
non-durable: consumer.close(); durable: session.unsubscribe(durableId) On Thu, Oct 10, 2013 at 11:27 PM, yjgyjg1997 <549030...@qq.com> wrote: > How can i unsubscribe the topic that I have subscribed ? When i > received a > special message in the onMessage function,I want to unsubscribe the t

How can I unsubscribe the topic

2013-10-10 Thread yjgyjg1997
How can i unsubscribe the topic that I have subscribed ? When i received a special message in the onMessage function,I want to unsubscribe the topic. thanks a lot. -- View this message in context: http://activemq.2283324.n4.nabble.com/How-can-I-unsubscribe-the-topic-tp4672625.html Sent fro

Re: Re:XA transaction not working on Broker redelivery.

2013-10-10 Thread soelvar
Hi, I am trying a simular setup, but am having problems redeliveryPlugin/defaultEntry. It is complaining: IllegalArgumentException: You must specify the 'destination' property. How did you get around that? Cheers, Jesper -- View this message in context: http://activemq.2283324.n4.nabble.com/X

AMQCPP -- Cannot publish to a delete Destination: temp-queue

2013-10-10 Thread dpatel
In my application I am creating a TempararyQueue queue and I set it in MapMessage as my ReplyTo queue. My listener is written in C++ and uses activemq-cpp. In version 3.6 everything works fine. My response from the listener makes it back to MapMessage. However when I upgraded to 3.8 (even 3.7) w

Is it possible to dispatch a message in the topic to only a certain queues while using virtual topic?

2013-10-10 Thread HellKnight
I am using virtual topics but I've encountered a problem and I could not come up with a perfect solution , so I decide to post it and I believe you guys could help me . My use case is something like this : a producer is monitoring a database.Once the database is updated, the producer will send

Re: Possible Bug in AJAX/MessageListenerServlet.java?

2013-10-10 Thread prgtrdr
I wonder if there's a way around this by somehow cloning the amq.js library within a single browser tab? That way, I could call amq_init with different clientIds and reference it that way. Something like: amqInstance1 = new amq(); amqInstance1.amq_init( clientID: 'client1' ); amqInstance1.addlis

Re: How can I check the existence of a durable subscriber with a given name using NMS?

2013-10-10 Thread Jim Gomes
I see the problem you are encountering. Let me play around with it again to see if I can come up with some suggestions. On Thu, Oct 10, 2013 at 12:13 AM, HellKnight wrote: > Mr. Gomes: > I am using the Statistics plug-in now. I used wildcard to get the > statistics of every destination on

Re: Connect in-house consumers with TCP and cloud consumers with SSL

2013-10-10 Thread Johan Edstrom
You can setup multiple connectors. On Oct 10, 2013, at 1:22 PM, emexelem wrote: > Hi, > > I've a bunch of in-house servers that connect with TCP transport to an > ActiveMQ broker. > We would like to scale in the cloud and connect cloud instances to the > broker. > We already have a basic authen

Connect in-house consumers with TCP and cloud consumers with SSL

2013-10-10 Thread emexelem
Hi, I've a bunch of in-house servers that connect with TCP transport to an ActiveMQ broker. We would like to scale in the cloud and connect cloud instances to the broker. We already have a basic authentication and authorization with the simple plugins, but we would like a stronger security for wha

Weird behaviour with failover transport + priorityBackup=true

2013-10-10 Thread Jose María Zaragoza
Hello: I'm using AMQ 5.8 and ActiveMQConnectionFactory uses this transport connection "failover:(tcp://broker1:61616?connectionTimeout=3000,tcp://broker2:61617?connectionTimeout=3000,tcp://broker3:61618?connectionTimeout=3000)?timeout=5000&maxReconnectAttempts=0&randomize=false&priorityBackup=tru

Re: ActiveMQ, how can i delete alle consumers in my queue ?

2013-10-10 Thread Christian Posta
tomcat might be caching your war resources somehow? so the consumer stays away? you should figure out why/if it's doing that and make sure to properly close your consumers when your app goes away. On Sat, Oct 5, 2013 at 5:15 AM, stargate wrote: > Hi, > > i working with JEE and tomcat and i have

Re: Message not dequeue using Mule

2013-10-10 Thread Christian Posta
post your mule flow so i can try on my end. On Tue, Oct 8, 2013 at 11:16 PM, Neha wrote: > I am using auto_acknowledge. > > > > -- > View this message in context: > http://activemq.2283324.n4.nabble.com/Message-not-dequeue-using-Mule-tp4672315p4672435.html > Sent from the ActiveMQ - User mailin

Re: How to generate slow consumers.

2013-10-10 Thread Christian Posta
And also consider setting prefetch limits on your consumer lower than defaults. Slow consumers are "slow" relative to how many messages have been dispatched vs their prefetch limit. On Thu, Oct 10, 2013 at 10:02 AM, Robert Davies wrote: > Its going to be difficult to setup a slow consumer with

Re: How to generate slow consumers.

2013-10-10 Thread Robert Davies
Its going to be difficult to setup a slow consumer with request/reply because you are limiting the rate at which messages are produced. A consumer is slow if can't keep pace with producer(s). What I would suggest you do is change your test a little, have your producer send messages asynchronousl

How to generate slow consumers.

2013-10-10 Thread johnbing
Hi, I am using ActiveMQ-5.8.0. ActiveMQ internally takes care of handling the slow consumers. But i have never seen any slow consumer in my broker. I am trying to create a slow consumer but not successful yet -- I have a test application(ping-pong) in which requester sends a message and waits til

Re: How to access the web-console using ActiveMQ maven plug-in

2013-10-10 Thread Christian Posta
what's the configUri you're using? do you specify a config file? jetty is booted from the activemq.xml file. check the example config files that come with the distro. On Wed, Oct 9, 2013 at 1:53 AM, chrysthynee wrote: > I'm using the active-mq maven plug-in but when I run activemq:run it starts

Re: AMQP authentication trouble

2013-10-10 Thread Christian Posta
meant to say and *I* will dig in to see why it's not working :) On Thu, Oct 10, 2013 at 8:32 AM, Christian Posta wrote: > Put together a sample test client with the qpid 0.5 client and dig in to > see why it's not working correctly. > > > On Wed, Oct 9, 2013 at 1:04 PM, Marko Asplund wrote: > >>

Re: AMQP authentication trouble

2013-10-10 Thread Christian Posta
Put together a sample test client with the qpid 0.5 client and dig in to see why it's not working correctly. On Wed, Oct 9, 2013 at 1:04 PM, Marko Asplund wrote: > I just tried connecting to ActiveMQ using SwiftMQ client 9.4.0 and that > client library is able to authenticate and communicate wit

Re: How can I check the existence of a durable subscriber with a given name using NMS?

2013-10-10 Thread Christian Posta
Please check the wiki link I posted. It's REST based access, not JMX. On Thu, Oct 10, 2013 at 3:49 AM, HellKnight wrote: > I am using 5.8.0. However my client programs are written in C# by NMS > libraries , so JMX won't do any direct good to me unless some NMS API could > be used instead of JMX

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

2013-10-10 Thread Timothy Bish
On 10/10/2013 11:13 AM, Jose María Zaragoza wrote: Hello: I'm using AMQ 5.8 ( + integration with Spring ) and I'm getting this error sometimes in my application's logfile I attatch the log stacktrace What could be the reason ? Was a problem on client or on server ? a server failover ? Thanks

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

2013-10-10 Thread Christian Posta
What cacheLevel are you using for your spring DMLC? On Thu, Oct 10, 2013 at 8:13 AM, Jose María Zaragoza wrote: > Hello: > > I'm using AMQ 5.8 ( + integration with Spring ) and I'm getting this > error sometimes in my application's logfile > I attatch the log stacktrace > > What could be the rea

Re: Replicated LevelDB Store filling up memory

2013-10-10 Thread Christian Posta
give more details about your broker configuration (number of nodes in cluster?) are you sending non-persistent messages? is the master going OOM up or slave? On Wed, Oct 9, 2013 at 2:31 PM, kal123 wrote: > When I test with Replicated LevelDB Store and try to fill up the store > (queue) by just

javax.jms.IllegalStateException: The Consumer is closed

2013-10-10 Thread Jose María Zaragoza
Hello: I'm using AMQ 5.8 ( + integration with Spring ) and I'm getting this error sometimes in my application's logfile I attatch the log stacktrace What could be the reason ? Was a problem on client or on server ? a server failover ? Thanks [ActiveMQ Transport: tcp://broker1/127.0.0.1:61616@4

Re: Too many advisories topics created in ActiveMQ

2013-10-10 Thread Gary Tully
do take the other good advice :-) but for your existing use case: be sure and delete any temp destination; javax.jms.TemporaryQueue#delete when you are done b/c the lifecycle is tied to the connection that created it. If you disable advisories then u need to tell a connection to not watch advisorie

Possible Bug in AJAX/MessageListenerServlet.java?

2013-10-10 Thread prgtrdr
I've been having a problem with the ActiveMQ AJAX handler and believe I found a bug, and would like to post here to see if anyone else has run across the same problem. I'm using ExtJS to create two separate panels which run in one browser tab. After loading jquery, amq_jquery_adapter.js and amq.j

Re: Replicated LevelDB Store filling up memory

2013-10-10 Thread Graham Leggett
On 09 Oct 2013, at 11:31 PM, kal123 wrote: > When I test with Replicated LevelDB Store and try to fill up the store > (queue) by just running producer without any consumers, the memory usage > keeps going up and VM runs out of memory. > Has anyone see this issue.. any conf. or workarounds for

Re: Replicated LevelDB Store filling up memory

2013-10-10 Thread kal123
could this fix the memory issue? http://activemq.2283324.n4.nabble.com/git-commit-Fixes-bug-in-replicated-leveldb-where-log-files-on-slaves-were-not-getting-GCed-td4671551.html I will try this out... -- View this message in context: http://activemq.2283324.n4.nabble.com/Replicated-LevelDB-Stor

Replicated LevelDB Store filling up memory

2013-10-10 Thread kal123
When I test with Replicated LevelDB Store and try to fill up the store (queue) by just running producer without any consumers, the memory usage keeps going up and VM runs out of memory. Has anyone see this issue.. any conf. or workarounds for this.. -- View this message in context: http://

Re: STOMP/Websockets and CORS

2013-10-10 Thread prgtrdr
Just to confirm, I am able to do cross-domain requests to ActiveMQ against the Jetty server. If you pay close attention to the documentation you won't go too far wrong but unfortunately, there are some incorrect instructions for how to set it up on various web sites. In general, the given samples

Re: How can I check the existence of a durable subscriber with a given name using NMS?

2013-10-10 Thread HellKnight
I am using 5.8.0. However my client programs are written in C# by NMS libraries , so JMX won't do any direct good to me unless some NMS API could be used instead of JMX API -- View this message in context: http://activemq.2283324.n4.nabble.com/How-can-I-check-the-existence-of-a-durable-subscrib

Re: How can I check the existence of a durable subscriber with a given name using NMS?

2013-10-10 Thread Christian Posta
What version of ActiveMQ are you using? In later versions 5.8 for example, Jolokia is enabled on top of JMX for REST-based access. See here: http://activemq.apache.org/rest.html#REST-RestManagement Unfortunately the wiki doesn't seem to publish the code samples properly. See here instead? https

Re: How can I check the existence of a durable subscriber with a given name using NMS?

2013-10-10 Thread HellKnight
How can I check the existence of a queue with a given name using this plugin ? -- View this message in context: http://activemq.2283324.n4.nabble.com/How-can-I-check-the-existence-of-a-durable-subscriber-with-a-given-name-using-NMS-tp4672438p4672505.html Sent from the ActiveMQ - User mailing l

Re: How can I check the existence of a durable subscriber with a given name using NMS?

2013-10-10 Thread HellKnight
Mr. Gomes: I am using the Statistics plug-in now. I used wildcard to get the statistics of every destination on the broker. However, I don't know the number of destinations on the broker, so I have no idea how many replies will be sent back to the "reply-to" queue. So the code receiving those