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 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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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:
>
>>
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
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
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
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
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
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
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
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
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
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
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://
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
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
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
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
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
33 matches
Mail list logo