Thanks a lot Tim . The config with ackBatchSize indeed worked .I saw the reference to this parameter in the doc but thought this might be not relevant to our setup .Federationactivemq.apache.orgBest regards,Saju DanielOn 1. Jul 2024, at 20:53, Timothy Bish wrote:On 6/26/24 06:56, Saju Daniel wro
On 6/26/24 06:56, Saju Daniel wrote:
Hello,
Just a gentle reminder. The issue is kind of critical for us to
implement federation on our setup .
Please let me know if you need more information on the problem.
After talking to Justin Bertram about some core client details I tried
your setup an
Hello ,
Are there any update on the issue ? If its confirmed to be a known
limitation with our configuration, we would like to find a workaround to
move forward with our federation setup.
Any tips in this regards would be greatly help us . Thank you.
FYI , Unfortunately AMQP is not an option for
Hello,
Just a gentle reminder. The issue is kind of critical for us to implement
federation on our setup .
Please let me know if you need more information on the problem.
Regards,
Saju
On Tue, 25 Jun 2024 at 16:50, Saju Daniel wrote:
> Hello Tim ,
>
> The issue seems to be easy to reproduce.
On 6/24/24 02:56, Saju Daniel wrote:
Hello Tim ,
Were you able to reproduce the issue with the messages in Delivering state
in the federated queue ?
Please let me know if you need more information .
I have not seen a reproducer provided so I have not looked into this
further.
My suggestion
Hello Tim ,
Were you able to reproduce the issue with the messages in Delivering state
in the federated queue ?
Please let me know if you need more information .
Regards,
Saju
On Fri, 21 Jun 2024 at 11:57, Saju Daniel wrote:
> Hello ,
>
> I tried out the same scenario with the version 2.35 and
Hello ,
I tried out the same scenario with the version 2.35 and still see the issue
that federated queue shows the message in delivering state even though its
correctly delivered at the other end .
I hope you are able to reproduce this at your end as well.
For illustration below is the status at
On 6/20/24 12:50, Saju Daniel wrote:
Hello Tim,
Thanks for the reply . We figured out the reason for duplicate message .
It was caused by the wildcard entry we used on federation configuration . This
was because the wild card address was also an address queue on the Europe
cluster. i.e events
For what it's worth, the latest version is currently 2.35.0 [1].
Justin
[1] https://activemq.apache.org/components/artemis/download/
On Thu, Jun 20, 2024 at 1:14 PM Saju Daniel wrote:
> We are using the the latest version of activemq . 2.33 . Forgot to mention
> this
>
> Best regards
> Saju D
We are using the the latest version of activemq . 2.33 . Forgot to mention this
Best regards
Saju Daniel
> On 20. Jun 2024, at 18:50, Saju Daniel wrote:
>
> Hello Tim,
>
> Thanks for the reply . We figured out the reason for duplicate message .
>
> It was caused by the wildcard entry we use
Hello Tim,
Thanks for the reply . We figured out the reason for duplicate message .
It was caused by the wildcard entry we used on federation configuration . This
was because the wild card address was also an address queue on the Europe
cluster. i.e events.#.
The consumer at the USA ends up re
On 6/19/24 14:33, Saju Daniel wrote:
Hello All ,
We see duplicated message at the consumer end on USA federation with a
symmetric federation setup as described here -
https://activemq.apache.org/components/artemis/documentation/2.20.0/federation-address.html
The configuration is described in t
But Currently we are using activemq 5.11.2 wherein we
have slf4j-api-1.7.10. Similarly we have slf4j-api-1.7.10 in activemq
5.12.0
Not sure why compatibility issues are coming.
On Tue, May 14, 2024 at 7:02 PM Matt Pavlovich wrote:
> This looks like a problem with slf4j logging library compatibi
This looks like a problem with slf4j logging library compatibility.
-Matt
> On May 13, 2024, at 11:20 PM, Sowjanya wrote:
>
> Hi
>
> We are trying to upgrade from activemq 5.11.2 to 5.12.0, New version of
> activemq is being reflected but unfortunately not able to access any module
> in our a
Hi,
Our application is using opene JDK 8, So last version of activemq that is
supporting our application is 5.16.
Tried upgrading activemq from 5.11.2 to 5.15 and faced same issue as stated
in my previous mail.
Regards,
Sowjanya
On Tue, 14 May 2024, 11:45 ski n, wrote:
> Probably an issue wit
Probably an issue with the version of SLFJ. See:
https://stackoverflow.com/questions/20537459/java-lang-nosuchmethoderror-org-slf4j-spi-locationawarelogger-log
Maybe you need to update other versions of your application (spring or the
JDK itself), but it's recommended to take the newest version a
Hi Paul,
I have a similar log4j2 config for ActiveMQ Artemis, and rollover works
without any problem. Which version of ActiveMQ are you using? (I'm guessing
that it is ActiveMQ Classic, but I'm not sure)
ActiveMQ Classic uses Log4j2 only in versions 5.17.1 and later. Older
versions use Log4j 1 and
Should have read all the mails first. Your python code below is almost
certainly for an AMQP 0-x protocol client but note that Artemis
supports clients using the AMQP 1.0 ISO standard protocol, so you
won't be able to use that client with Artemis even once you set the
dependencies+acceptor up corre
You specifically note trying STOMP and AMQP clients, however you make
no mention of bringing in the STOMP or AMQP protocol dependencies to
enable support of those protocols. Have you?
The artemis-jms-server dependency only brings in support for the CORE
protocol, used by artemis-jms-client for exa
I was doing telnet on 8990.
--telnet 127.0.0.1 8990
Trying 127.0.0.1...
Connected to localhost.
Escape character is '^]'.
Connection closed by foreign host.
-
I tried with making the ports as same in the broker url and acceptor.
Port used was 5672
In both the scenarios, the serv
The code line "configuration.addAcceptorConfiguration("remote", "tcp://
0.0.0.0:5672");" is adding an acceptor with the port 5672 while the client
is trying to connect to the port 8990: spring.artemis.broker-url=tcp://
127.0.0.1:8990. What Port are you testing with telnet?
On Thu, 14 Dec 2023 at 0
Artemis ships with lots of examples, including examples that demonstrate
failover with replication HA. Take a look in the examples/features/ha
directory (e.g. examples/features/ha/replicated-transaction-failover).
Keep in mind that those examples are great for getting a single HA pair set
up, but
Bumping the logging level is key to this; even if you succeed in finding
data files that demonstrate what happened, without the more detailed
logging it may be impossible to tell *why* it happened. If you get a large
enough disk attached to the machine to hold months of logs, that's great,
just mak
It is possible that there is a bug in the ack compaction feature, but if so
it only shows itself in
some very special cases. I have tried stressing it, but to no avail. In all
my tests the broker
does the right thing.
There are no cron jobs deleting any files in this system. The broker thinks
that
I've never seen anything like this on the mailing list, and the one project
where I've been directly involved in managing brokers used non-persistent
messaging exclusively so I've never seen it personally.
Here are a few crazy ideas of what might possibly cause the behavior you
described:
- As
ok, I've done a little further reading here:
https://zookeeper.apache.org/doc/trunk/zookeeperProgrammers.html
and realized that the ZooKeeper server will negotiate the actual timeout
with the client, so even if zkSessionTimeout on the ActiveMQ side is set to
2s ... if the "tick time" on the ZooKee
lto:a...@amlinv.com]
Sent: Friday, September 02, 2016 12:36 AM
To: users@activemq.apache.org
Subject: Re: Need Help With A JMS Exception
The broker and client negotiate the version of the OpenWire protocol when the
client connects. If the client sends a version of an ack that the broker
do
rsday, September 01, 2016 12:05 PM
> To: [hidden email] <http:///user/SendEmail.jtp?type=node&node=4716079&i=1>
> Subject: Re: Need Help With A JMS Exception
>
> A couple of thoughts on this front.
>
> First, how was the conclusion of different client versions made?
artnaseef [mailto:a...@amlinv.com]
Sent: Thursday, September 01, 2016 12:05 PM
To: users@activemq.apache.org
Subject: Re: Need Help With A JMS Exception
A couple of thoughts on this front.
First, how was the conclusion of different client versions made? I'm curious
because I can't t
062&i=0>]
> Sent: Thursday, September 01, 2016 10:58 AM
> To: [hidden email] <http:///user/SendEmail.jtp?type=node&node=4716062&i=1>
> Subject: Re: Need Help With A JMS Exception
>
> +1 Agree that debugging it is the only surefire way to understand what
> is goin
-Original Message-
From: Matt Pavlovich [mailto:mattr...@gmail.com]
Sent: Thursday, September 01, 2016 10:58 AM
To: users@activemq.apache.org
Subject: Re: Need Help With A JMS Exception
+1 Agree that debugging it is the only surefire way to understand what
is going on.
On a side note
+1 Agree that debugging it is the only surefire way to understand what
is going on.
On a side note-- CLIENT_ACKNOWLEDGE is kludgy of sorts. Be sure to
understand that it acknowledges the current message and _all_ previous
messages. It isn't an individual message acknowledgement as most people
Thank you Tim.
Michael Tarullo
Contractor (Engility Corp)
Software Engineer
FAA WJH Technical Center
(609)485-5294
-Original Message-
From: tbai...@gmail.com [mailto:tbai...@gmail.com] On Behalf Of Tim Bain
Sent: Thursday, September 01, 2016 8:47 AM
To: ActiveMQ Users
Subject: Re: Need
Since you have the 5.5.1 source code, I recommend you attach a debugger to
the broker process and set a breakpoint on the
TopicSubscription.acknowledge() method; the stack will tell you how you got
there. Setting breakpoints on the broker can lead to instability and may
force you to restart it (pl
Hi Raghu,
It may also be worth considering ActiveMQ Artemis in your evaluation. It
has a complete blocking architecture end to end and can delivery excellent
performance.
https://activemq.apache.org/artemis/
Regards
Martyn
On Mon, Jul 4, 2016 at 12:29 PM, Gary Tully wrote:
> to have a guar
to have a guarantee the fsync is necessary. possibly move the index to a
separate disk to reduce contention. To boost throughput, have multiple
connections publishing at the same time. In this way, multiple parallel
sends will get the benefit of a batched fsync.
On Sat, 2 Jul 2016 at 19:32 RaghuB
ActiveMQ is not a database, and its performance is optimized for use cases
where all messages are consumed relatively soon after they're published.
There's nothing that says a message can't be consumed after some period of
time just because the consumer to whom it is destined isn't online.
You can
Hello Tim,
there is no file older than 3 weeks ...
this is the oldest file (12 days old):
-rw-rw-r-- 1 activemq activemq 33584906 Dez 18 15:22 db-484.log
.. and i have never seen an older file than 3 weeks.
Yes, you understood my experiment correctly. I did the experiment after
midnight on a pr
OK, so I want to recap and make sure I've got everything correct. Please
confirm that there's nothing I'm mis-stating.
Your KahaDB data directory contained lots of files that were older than the
age-off interval that all of your producers are using when they produce
messages, which is unexpected
Hi Tim,
I subscribed every queue with a tool, but I used a selector which never
match a message.
=> no changes in den data folder
Than I used a selector which filters unimportant messages.
=> the server removed about 150 files from the data folder.
I think the activemq server works fine and if
Queue browsing just involves HTTP interactions with the Jetty web server,
and can be scripted if the volume of queues makes manual browsing
impossible.
After you browsed those queues, did any of the very old KahaDB data files
get deleted? That's the second question you're trying to answer by
brow
Hi Tim,
there are about 2500 queues and it is not so easy to browse all queues and
unconsumed messages.
I took a look to a lot of queues with unconsumed messages and all messages
has an (valid = future date) expiration date.
Now 561 files / 17,9 GB
regards
Shine
--
View this message in con
I'm looking forward to your answers to the questions I asked this morning,
and to hearing the results of your browsing the queues and inspecting the
oldest messages on each.
Tim
On Wed, Dec 23, 2015 at 6:32 AM, Shine wrote:
> Hi Tim,
>
> the oldest file has the name db-159.log ... created on th
Hi Tim,
the oldest file has the name db-159.log ... created on the 8th of december.
..
regards
Shine
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Need-help-with-a-message-broker-configuration-tp4705074p4705385.html
Sent from the ActiveMQ - User mailing list archive
Hi Tim,
the folder contains 546 files now; folder size: 17,4 GB. ... 2 files removed
and ~ 40 new files since yesterday.
regards
Shine
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Need-help-with-a-message-broker-configuration-tp4705074p4705384.html
Sent from the Act
Which two files were deleted? Not their filenames, but where did they sit
in the overall order?
When you browse the oldest message on each queue that has no consumers,
look to see if the oldest message in each either has no JMSExpiration
header or has one that's further in the future than your ex
Hi Tim,
in the folder are 512 files now ... and the folder size is about 16,5 GB.
in about 4 hours the server removed 2 files and creates 11 new files, so the
folder grows and grows.
regards
Shine
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Need-help-with-a-message
Your original description said that log directory "grows and grows", and
now you're saying "the activemq server removes log files and creates new
files." Which is it? If you're still looking for help, I think you need
to spend a little time describing exactly what you're seeing happen with
that d
Hi Tim,
thanks for you help.
i monitored the kahadb folder for some days. the activemq server removes log
files and creates new files. The folder contains 503 files currently. I
think thats no problem!?
Maybe I browse all 3000 Queues today and take a look at the kahadb folder
again.
regards
Sh
My primary goal in having you browse every queue with unconsumed messages
was to try to force the broker to evaluate whether those messages should be
expired, which would indicate that the problem was simply that the broker
wasn't evaluating message expiration when no consumer was connected. If
th
Hi Tim
i dont browse the queue .. i click on the "Queues" link in the WebConsole to
refresh the list of queues. You see the enqueued messages and the dequeued
messages .. if the time to live of an message is over, than the counter of
the dequeued messages increase and enqueued messages decrease.
For troubleshooting purposes, I'd recommend you use the web console or a
JMX viewer to find out which queues have unconsumed messages and no
consumers, and browse the messages on each such queue via the web console.
Browsing should (I think) run the messages through the expiration logic, so
once yo
Messages published to a topic are deleted from the message store when they
are consumed by the last subscriber. When there are no subscribers, they
are immediately deleted. So there's nothing for you to worry about there.
Tim
On Fri, Dec 18, 2015 at 11:23 AM, Shine wrote:
> Hi Tim.
>
> no que
Hi Tim.
no queue with that name
In the topic Tab is that entry .. SHINE is a queue name
ActiveMQ.Advisory.Expired.Queue.SHINER
Number Of Consumers: 0
Messages Enqueued: 2<= expired Messages ... automatically remove from
queue
Messages Dequeued: 0
.. but i cant remove via WebConsole .. mayb
It would be in the Queues tab, with a name of DeadLetterQueue.
On Fri, Dec 18, 2015 at 10:40 AM, Shine wrote:
> Hi,
>
> i use queues only. Each client has its own queue. It works like a chat, you
> send a message to queue .. if the client is online, it receives the message
> ... if the client is
Hi,
i use queues only. Each client has its own queue. It works like a chat, you
send a message to queue .. if the client is online, it receives the message
... if the client is offline .. maybe 5 days, than the message(s) still in
the queue (max. 2-3 weeks) until the client goes online.
I cant fi
How is it that those messages are not being consumed? Do you have no
consumers on the queue (or an offline durable topic subscriber)? Do you
have consumers, but with selectors that don't hit those messages?
Something else?
I haven't looked in detail at the message expiration code, but I believe
Hi,
is a Multi kahaDB persistence adapter a good way to get the growing of the
KahaDB folder under control?
best regards
Shine
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Need-help-with-a-message-broker-configuration-tp4705074p4705138.html
Sent from the ActiveMQ - U
Here the current configuration ...
any suggestion for improvement?
How many GB diskspace needs a "normal" kahaDB?
http://activemq.apache.org/schema/core";
brokerName="localhost" dataDirectory="${activemq.data}" useJmx="true"
schedulePeriodForDestinationPurge="60" >
Hi Tim,
For problem #1: there are a lot of unconsumed messages, but each message
havs an expiration time (max 2-3 weeks). Over the time the size of the
KahaDB folder should be nearly constant.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Need-help-with-a-message-broke
For problem #1, do you have any old but unconsumed messages? KahaDB can't
compact its journal files, so a single old message that can't be deleted
can cause KahaDB to keep a large number of files.
For problem #2, why is that a problem? You haven't said anything that
indicates that those advisory
I looked deeper in the code and it is hard coding a prefix of /topic/ or
/queue/ which JBoss HornetQ doesn't understand when it requests that the
client be registered as a consumer. It appears that it isn't configurable.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Ne
I've tried the masterslave discovery agent on broker amq3 & the failover from
master (amq1) to slave (amq2) works.
However, masterslave doesn't seem to support priorityBackup=true & so the
broker doesn't fail-back from slave to master when the master comes back
online.
My original issue is that
Looked briefly at your configs...
Can you try this... for the brokers that have 2+, you can use the
masterslave: discovery agent on your network connector... check out more
details here: http://activemq.apache.org/networks-of-brokers.html
For the NC that has single URI connectons, add this to the
On Thu, Sep 5, 2013 at 9:59 PM, gsk wrote:
> thanks for taking time to reply.
>
> 1. How can i set up camel as a consumer? Do you have any documents that
> will
> explain how to do this?
>
Yes. Tons.
http://camel.apache.org/jms.html
http://camel.apache.org/getting-started.html
http://camel.apache
thanks for taking time to reply.
1. How can i set up camel as a consumer? Do you have any documents that will
explain how to do this?
2. Where and how will i be invoking my java code from consumer?
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Need-help-with-creating
Your best bet for the db part would be to look at Apache Camel and connect
up the DB to activemq like that.
As for the push... you can use Camel for that as well. Set it up as a
consumer of a destination (queue/topic) and that will receive the message
and can invoke your code as needed.
http://ca
hi nehel,
Sorry for digressing from your issue. I need help in configuring push
messages inorder to push the messages from activemq to my java application.
how can i achieve this?
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Need-help-controling-the-rate-at-which-mes
On Nov 14, 2012, at 4:55 PM, mtod wrote:
> Thanks Torsten for the reply
>
> I'm looking for the syntax or process to use a PL/SQL (Internal Oracle)
> query that would route the message to ActiveMQ from Oracle.
>
> I have everything setup down to the client I can even send messages from the
> Or
Thanks Torsten for the reply
I'm looking for the syntax or process to use a PL/SQL (Internal Oracle)
query that would route the message to ActiveMQ from Oracle.
I have everything setup down to the client I can even send messages from the
Oracle Gateway to the ActiveMQ client.
What I'm missing is
On Nov 14, 2012, at 1:25 AM, mtod wrote:
> I’m working on a model that will send the results from an Oracle SQL query to
> remote Web Service:
>
> Oracle DB 11gR2 -> Oracle Enterprise Gateway -> ActiveMQ -> Windows .Net
> Client Service -> Remote Web Service
Sorry which part of the path is not
Producer and Consumer code is here:
https://fisheye6.atlassian.com/browse/~br=trunk/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/demo
Hope you already gone thru this:
http://activemq.apache.org/getting-started.html
ActiveMQ Examples
http://activemq.apache.org/examples.html
Acti
Yes, you can run multiple brokers on a single system. You just need to be
mindful of what ports you listen on (via the activemq.xml), and when you are
sending messages to the correct ports for each instance.
There is going to be a performance hit of using two servers instead of one, if
the sys
Hi,
can anyone tell me what is wild cards?
and what is its use in activemq.
>
>
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Need-Help-tp2541665p2543461.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Typically you have
N Initiators --> Broker --> Y Targets
So you'd start a broker. Then your programs that are feeding and the programs
that are consuming messages.
On Sep 16, 2010, at 5:30 AM, pp wrote:
>
> Thanks gary.
>
> So we should have the initiator and target both should have the ac
Thanks gary .
Thanks a lot.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Need-Help-tp2541665p2541896.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
typically not, typically there is a single broker.
On 16 September 2010 10:30, pp wrote:
>
> Thanks gary.
>
> So we should have the initiator and target both should have the activemq
> broker.
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Need-Help-tp2541665p254182
Thanks gary.
So we should have the initiator and target both should have the activemq
broker.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Need-Help-tp2541665p2541829.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
it is typically client(producer/consumer) server (broker) but you can
embed brokers in either of the clients, for a producer that always
needs to be available for example, it can embed a broker that will
serve as a local store and forward messages to the ultimate target
broker.
On 16 September 201
On 5 Nov 2009, at 23:43, bnortman wrote:
Just started using ActiveMQ 5.3
I have 1 producer and 1 consumer on a queue. Right now I have
problems where
my consumer is busy and can't keep up. After a while ActiveMQ will
run out
of memory and crash and then my product doesn't work to well. I'
We have four php-webservers together handling about three million
pageviews per day, and for each pageview a connection is made to
ActiveMQ (via Stomp) and at least one, often two and sometimes more
messages are sent via that connection.
The default settings of ActiveMQ don't really support th
- Original Message
> From: zmiq2
> To: users@activemq.apache.org
> Sent: Wednesday, May 13, 2009 12:20:11 PM
> Subject: Need help with activemq - php architecture
>
>
> I'm a newbie in activemq, and haven't found much info about setting the
> correct architecture for a high performance
I don't know of any such local store and forward for PHP, but I think the
concept is good. We have experienced issues where an ActiveMQ broker
freezes and blocks all PHP clients, which in turn can tie up all currency in
the website. You might do something as simple as staging message to the
local
Hi,
I think the problem is that the end-of-line or end-of-message
indicator I sent to activemq from my C client is not correctly
recognized. I have tried '\0' and '\n' to end the line ( similar to
ctrl-@ in telnet window ), but it does not work. Does anyone know how
I can solved this problem?
T
Hi Juan,
EOFException means that your client closed the socket unexpectedly. I'm
afraid I cannot help you much more.
Cheers
--
Dejan Bosanac
Open Source Integration - http://fusesource.com/
ActiveMQ in Action - http://www.manning.com/snyder/
Blog - http://www.nighttale.net
On Fri, Jan 9, 2009
check out the faq: see: http://activemq.apache.org/faq.html
2008/11/19 Nawaz Ahmed <[EMAIL PROTECTED]>:
> Hi all,
>
> I need a help regarding the Active MQ and Message Broker.
>
>
>
> Here are a list of questions:
>
> How do send the Message to Queue?
> How do send the Message to T
Hi,
Sorry to email this group again. After adding the camel and ibatis jars to
the classpath, this error goes away and I can see:
DEBUG CamelContextFactoryBean- Found JAXB created routes:
[Route[[From[activemq:queue:test]] -> [process[ref: myProcessor],
To[ibatis:insert$
I
The problem is
On Wed, Sep 24, 2008 at 12:13 AM, Nehel <[EMAIL PROTECTED]> wrote:
>
> Hi All
> I need help in configuring the ActiveMQ.
> I want to control the rate at which messages are pushed in Queue.
> Currently I am able to push approximately 2 messages per min.
> I need to control this rate to 10 messag
BTW there is a forum & mailing list for Camel specific questions...
http://activemq.apache.org/camel/discussion-forums.html
2008/9/10 Mick Knutson <[EMAIL PROTECTED]>:
> I am looking through the examples, and they all package a jar, then run 'mvn
> camel:run' which, I assume is an embedded camel/a
On Sun, May 11, 2008 at 11:12 AM, jaya_srini <[EMAIL PROTECTED]> wrote:
>
> Hi Filip
>
> I have 4 producers (who are also consumers) on different connections i.e I
> create a diffrent connection for each producer. But If multiple threads are
> using the same producer then I can see that they might
Hi Filip
I have 4 producers (who are also consumers) on different connections i.e I
create a diffrent connection for each producer. But If multiple threads are
using the same producer then I can see that they might end up using the same
session.
For sending message asynchrounously, should I be
aah, I see, the issue you are running into is a global lock on the session,
only one message can be sent at a time on the same session.
so if you have multiple threads using the same session, it will send the
requests, one at a time
you are probably sending messages synchronously, as opposed to
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
ok so i think i've figured out the consumer count thing. but first, what was
confusing me was that my ops guy had brought up a test instance of the
application this is intended for on the same network without letting me
know. so once that was taken down it became more clear. here's what i
gathe
Networks work by brokers acting as consumers on other brokers which
probably explains the unexpected consumer counts?
On 26/02/2008, metaldork <[EMAIL PROTECTED]> wrote:
>
> hi. i'm preparing to migrate to jms for oracle toplink cache synching and am
> currently doing some configuration and loa
Thank you for this instruction - i wanted to clear a couple of things up if
that is ok.
I have question mainly on ActiveMQBroker.java class. Is this a standalone
class? does it inherite from any class? Do i need to follow a specific
interface?
Do you have a complete example that you can sh
In our application , there are two web apps and the inter web app
communication is via the active mq broker. Out application uses active
mq 4.1.1 , java 1.6 and Tomcat5.5.20
1) The jndi resources for active mq can be specified in
Tomcat/conf/context.xml
the flag wireFormat.maxI
On 3/28/07, Shilpa <[EMAIL PROTECTED]> wrote:
hi,
i have sucessfully completed using jconsole now i have to start my
development of my project.
the requirement is as follows
whenever new message comes to the message queue or topic then i have to
refresh the jsp page inorder to display the
1 - 100 of 104 matches
Mail list logo
