2008/5/8 Stefano Bagnara <[EMAIL PROTECTED]>:
> Hi all,
>
> I'm an Apache JAMES committer and I'm "almost" new to ActiveMQ.
Welcome :)
> I'm starting analysis on how to replace our default spool with ActiveMQ and
> I hope you can give me some hints :-)
> It would be better to use ActiveMQ via
Hi
Is TransportListener only meant to be used with Failover Transport? i.e if I
use it with tcp transport (without failover) will I be notified if the
broker shuts down and comes back up? The reason we can't use failover is
because we would also like to use Async Sends which is not possible with
Thanks much for the response Fillip.
Can you explain what the producerFlowControl setting does? And what other
options if any I can set?
>From activemQ admin page I see that the messages are being consumed at the
same rate as being produced. I have 4 producers that are also consumers.
Currently
that means youre producing messages faster than they are being consumed.
you could setup a policy entry to turn off flow control
memoryLimit="10mb"/>
memoryLimit="10mb"/>
however, if your consumers never catch up, then you need to decide what
you wanna do with your messages, as eventually y
Just wanted to add that we are using Durable Topic Subscribers with
Persistent delivery mode. Also the number of messages published is not very
many. A few hundred messages. The producers are also consumers of the
message and a single connection is being used for publish and subscribe.
Any help a
hi
We are using ActiveMQ 5.0 release and observing the following on production.
After a certain number of messages are sent the Activemq send blocks. The
thread dump produced the following
daemon prio=6 tid=0x3793f400 nid=0x1f28 waiting for monitor entry
[0x38aff000..0x38affc98]
java.lang.Th
Hi,
according to your hint i tried the following configuration:
Then both brokers give me the following error on start-up:
ERROR BrokerService - Failed to start ActiveMQ JMS Message
Broker. Reason: java.io.IOException: Transport Connector
Hi
I read about slow consumer from this URL:
http://activemq.apache.org/slow-consumers.html
Non-Durable Topics
Non-durable topics are the scenario which is most affected by slow consumers
since the messages are not persistent and messages generally go to all
consumers (who have a valid selector)
I just did some more checking, turns out it is the QueueBrowser that is
causing the duplicate message problem. I have a QueueBrowser that uses the
following code to periodically verify the queue size and perform
verification after queue size is zero.
private static class JMSBrowser implements Ses
Hi I just upgraded to 5.1 and there seems to be a very weird behavior
regarding the message redelivery.
Before upgrade to 5.1, I had the Spring 2.5.3 and 5.0 running fine with the
following setup.
1. I have a single producer sending and recording 100 persistent messages to
a queue.
2. maximumRedel
Daryl Richter-3 wrote:
>
> Do you open and close multiple sessions within the same consumer thread?
>
> We have seen that this can very reliably cause the broker to lock up.
>
> It is best to open a single session per thread and close all the way out
> when done consuming.
>
Is it wrong to
> i'm having a hard time with AMQ again:-)
[...]
> Ok, great! http is working, SSL is working, but
> https not?
reading docs it seems that if you want STOMP over SSL, you should use
'stomp+ssl:' -- following the same principle I would try with 'http+ssl:'.
However I'm quite new to AMQ, so I
Hey folks,
i'm having a hard time with AMQ again:-)
In a nutshell:
* Broker <- http -> Broker works using a configuration like this on both
brokers:
http://0.0.0.0:61617"/>
http://172.18.154.26:61617?trace=true)" networkTTL="5"/>
* Broker <- SSL (just tcp) ->
hi,
I have two questions about policy entries and wild card matching,
can I configure my entries like this
memoryLimit="10mb">
Questions:
1. is the matching ordered, ie, if I match on the first entry, those
settings apply, and then fallback to the second?
2. Do these policy entr
2008/5/8 shaf <[EMAIL PROTECTED]>:
>
> The subject says it all - is there any such thing in AMQ when dealing with
> Point-to-Point (Queues)?
Sure - thats basic JMS stuff. Just make sure you use transactions or
client acknowledges...
http://activemq.apache.org/should-i-use-transactions.html
> I
The subject says it all - is there any such thing in AMQ when dealing with
Point-to-Point (Queues)? I require reliability as I require to
create/destroy dynamic Queues programatically if anyone can provide some
code snippets.
Thanks,
Shaf
--
View this message in context:
http://www.nabble.com/A
Is it possible to setup jndi with ssl connection for Activemq in tomcat. If
so where do I define the client.ks/client.ts files?
My jndi config in context.xml file:
Hello!
I've installed activeMQ on windows platform and Market data web example does
not work:
The publisher works, but the consumer does not show real time data
I see from ActiveMQ WebConsole that the client does not subscribe to BUS
I've installed activeMQ on linux and I have the same problem
th
2008/5/8 beaker <[EMAIL PROTECTED]>:
>
> Hello,
>
> is it possible for a producer to detect, if there are any consumers on the
> topic/queue he is sending?
Yes - you can use advisories...
http://activemq.apache.org/advisory-message.html
e.g. try using the ConsumerEventSource helper class...
ht
Hello,
is it possible for a producer to detect, if there are any consumers on the
topic/queue he is sending?
I want the producer to only send out messages, if there is someone listening
for them.
Bye,
beaker
--
View this message in context:
http://www.nabble.com/Detect-consumers--tp17126905s2
2008/5/8 shaf <[EMAIL PROTECTED]>:
>
> Thanks guys, so when I try to create a Queue using the following:
>
> ActiveMQSession session =
> this.con.getConnection().createSession(false,
> Session.AUTO_ACKNOWLEDGE);
> // create queue
> Queue request = session.createQueue( nam
Thanks guys, so when I try to create a Queue using the following:
ActiveMQSession session = this.con.getConnection().createSession(false,
Session.AUTO_ACKNOWLEDGE);
// create queue
Queue request = session.createQueue( name );
System.out.println("The queue has been
FYI - the "Destination" link @ the top of
http://activemq.apache.org/activemq-510-release.html is broken.
Joe
James.Strachan wrote:
>
> BTW you can listen to destinations being added/removed by calling the
> setDestinationListener method on the DestinationSource
>
>
>
> 2008/5/8 shaf <[EMA
BTW you can listen to destinations being added/removed by calling the
setDestinationListener method on the DestinationSource
2008/5/8 shaf <[EMAIL PROTECTED]>:
>
> Hello,
>
> I am trying to get a list of existing Queues with the following code:
>
> ActiveMQConnectionFactory connectionF
It does take a little while for some destinations to show up as they
are typically loaded asynchronously on the JMS client - does sleeping
for a second or so help?
2008/5/8 shaf <[EMAIL PROTECTED]>:
>
> Hello,
>
> I am trying to get a list of existing Queues with the following code:
>
>
Hi Shaf,
Just tested this on 5.1.0 and seems to work fine on my test. I tested
this using startup destinations
(http://activemq.apache.org/configure-startup-destinations.html) and
also creating one via jmx.
Can you look in jconsole (or any jmx console) to see if the queues are
actually cr
Hi all,
I'm an Apache JAMES committer and I'm "almost" new to ActiveMQ.
I'm starting analysis on how to replace our default spool with ActiveMQ
and I hope you can give me some hints :-)
It would be better to use ActiveMQ via JMS (more flexibility) but if
there is any better solution to our pro
Has anyone managed to reproduce AMQ-1662 on 5.1.0?
2008/5/8 realSri <[EMAIL PROTECTED]>:
>
> Hi,
>
> Reg: AMQ 5.0 Stable release "PS Old Gen" Memory is growing continuously
> (http://issues.apache.org/activemq/browse/AMQ-1662)
>
> Thanks for the 5.1 release ! Could you please give an update on
28 matches
Mail list logo
