How can I set the prefetchSize for a TopicSubscriber using ActiveMQ 4.1.1 ?
--
View this message in context:
http://www.nabble.com/prefetchSize-for-TopicSubscriber-tf4390619s2354.html#a12518267
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Hi!
Our application has to make sure that all consumers with durable topic
subscriptions get messages in strict order even when a message has to be
delivered.
E.g.
Publisher puts message 1 to 10 on topic. Consumer opens a session, gets
message 1, makes a client acknowledment, gets message 2,
You can specify your own jdbc adapter class (see
http://activemq.apache.org/jdbc-support.html).
What I'd do is write a mysql adapter (extend the mysql one) and
override the locking statements. You can also rename the mysql adapter
for AMQ 5 (or svn revision 518161/518164) into
Unfortunately noone has replied yet!
Our problem still exists, but maybe some more information will help:
The problem showed up the first time, when we switched from Java 1.4 to Java
5 on our AIX machines. It's not reproducable what makes tracking down the
problem quite difficult.
Any ideas?
Hi
We had the same problem with NFS, I think it's an NFS/Java issue since
there also seem to be problems with other applications.
But someone told me they've it running successful with NFS, so I
suppose it's NFS-implementation/version specific whether locking works
or not (he ran a JVM 1.5.0_08
Hi all,
How I can check the state of activemq connection? i.e. how i can check that
the activemq server is up and running? My app needs to detect the cases when
the server is killed by kill -9 so advisory topics are not helpful here.
I'm using SpringFramework support for activemq.
Regards,
Hi!
Try to use the JMX interface ( http://activemq.apache.org/jmx.html ActiveMQ
JMX ).
Since you're using Spring this is quite easy.
Kind regards
Juergen
Marcin Szkudlarek wrote:
Hi all,
How I can check the state of activemq connection? i.e. how i can check
that the activemq server is
On 9/6/07, Marcin Szkudlarek [EMAIL PROTECTED] wrote:
Hi all,
How I can check the state of activemq connection? i.e. how i can check that
the activemq server is up and running? My app needs to detect the cases when
the server is killed by kill -9 so advisory topics are not helpful here.
I'm
Are the versions (distributions) of ActiveMQ ActiveMQ 4.1.0 and Apache
ActiveMQ 4.1.0-incubator the same?
Kind regards
Juergen
--
View this message in context:
http://www.nabble.com/ActiveMQ-version-4.1.0-and-incubator-version-4.1.0-tf4392835s2354.html#a12524900
Sent from the ActiveMQ - User
On 9/6/07, Juergen Mayrbaeurl [EMAIL PROTECTED] wrote:
Are the versions (distributions) of ActiveMQ ActiveMQ 4.1.0 and Apache
ActiveMQ 4.1.0-incubator the same?
Yes. 4.1.0 happened while ActiveMQ was still in incubation; so the
maven version number had to include -incubator. However thats a
It seems from my perspective that the PooledConnectionFactory is caching
only one connection to the network. Since load balancing between nodes is
done at connection time, using PooledConnectionFactory will not work with
load balancing. Will this be a problem to have a real pool of jms
connections
On 9/6/07, Olivier OTTAVI [EMAIL PROTECTED] wrote:
It seems from my perspective that the PooledConnectionFactory is caching
only one connection to the network. Since load balancing between nodes is
done at connection time, using PooledConnectionFactory will not work with
load balancing. Will
Yes I did and I try it with this configuration:
tcp://localhost:61616?jms.prefetchPolicy.all = 100
But it doesn't work!
Juergen Mayrbaeurl wrote:
Did you look at
http://activemq.apache.org/what-is-the-prefetch-limit-for.html
what-is-the-prefetch-limit-for on the ActiveMQ website?
On 9/6/07, drod [EMAIL PROTECTED] wrote:
Yes I did and I try it with this configuration:
tcp://localhost:61616?jms.prefetchPolicy.all = 100
Strange, works for me. You can also customize the PrefetchPolicy POJO
on ActiveMQConnectionFactory / ActiveMQConnection before you create a
consumer
Any clues?
tendlu wrote:
Using ActiveMQ 4.1
I have a producer that does the following -
1. main thread creates a Connectionfactory using tcp
2. creates a few threads - say 5
3. each thread creates a new Connection and a new Session using the
connectionfactory created in the main
If you specifiy a broker uri of the following format in creating an
ActiveMQ.ConnectionFactory:
tcp://localhost:61616?jms.redeliveryPolicy.maximumRedeliveries=3
an NMSException is thrown on calling
ActiveMQ.ConnectionFactory.CreateConnection().
The exception text is:
no such property:
Ok, I understand that.
Next question, how do I define what queue I want to watch? I have tried to
follow the docs on the Jetty page, but I am not sure that I have the right
things in the jetty.xml and jetty-plus.xml files. Or is that not where you
set that up? The docs are not very clear on
You use the http: scheme to connect your client to a remote or external
broker. You also have available other schemes like https:, tcp:, and ssl: to
connect to a remote broker. Just depends what protocol you want to use.
The vm: scheme is used to start an intra-JVM or embedded broker. So if you
So if my broker is running on server bob, I would change the value to
vm://bob:1234 or would it be http://bob:1234?
J
chago wrote:
If you download ActiveMQ, the web demo module contains a few demos that
use Jetty with an embedded broker talking to web pages using the amq.js
script file.
Not all messages(persistent) to a queue are sent to the broker if messages
are sent from multiple threads. Each thread creates its own connection and
session.
Please let me know if I am missing something or is this a bug?
--
View this message in context:
So I don't have to configure anything on the Jetty side to have the topics
available?
J
chago wrote:
When using the javascript client (amq.js) you subscribe to topics and
queues in your javascript code. For example, in the chat.js file when the
'join' button is pressed, an event fires
I tried them, but I could not get them to work. Sorry for all the dumb
questions.
J
chago wrote:
That's correct. Have you tried the examples in web demo?
Zanderfax wrote:
So I don't have to configure anything on the Jetty side to have the
topics available?
--
View this
That's correct. Have you tried the examples in web demo?
Zanderfax wrote:
So I don't have to configure anything on the Jetty side to have the topics
available?
--
View this message in context:
http://www.nabble.com/Looking-for-Help-ActiveMQ-and-Jetty-tf4379195s2354.html#a12533912
Sent
On 9/7/07, tendlu [EMAIL PROTECTED] wrote:
Not all messages(persistent) to a queue are sent to the broker if messages
are sent from multiple threads. Each thread creates its own connection and
session.
Please let me know if I am missing something or is this a bug?
That sounds wrong; do you
FWIW, I can't reproduce the timing issue... It seems your original code runs
fine on my setup.
Keep in mind that I am using a different version of amq.js. (See JIRA issue
http://issues.apache.org/activemq/browse/AMQ-1377 AMQ-1377 . )
Find the debug log and see if there were any exceptions or
Try this:
!DOCTYPE HTML PUBLIC -//W3C//DTD HTML 4.01 Transitional//EN
http://www.w3.org/TR/html4/strict.dtd;
html
head
titleObservatory/title
script type=text/javascript src=amq/amq.js/script
script type=text/javascript
amq.uri='amq';
On 9/6/07, Juergen Mayrbaeurl [EMAIL PROTECTED] wrote:
Hi!
Our application has to make sure that all consumers with durable topic
subscriptions get messages in strict order even when a message has to be
delivered.
E.g.
Publisher puts message 1 to 10 on topic. Consumer opens a session, gets
27 matches
Mail list logo
