Mark-
Another approach is to consume the message, add your headers and then produce
it back to the DLQ within a transaction on the same session. That will maintain
reliability, and allow you to enrich the message with some root cause
information.
-Matt
On Sep 11, 2014, at 7:08 AM, Marc
ID: +
message.getJMSMessageID());
message = (TextMessage)consumer.receive(2000);
}
session.rollback();
closeResources(connection, session, null, consumer);
….
Thanks,
Matt Pavlovich | Founding Partner | Media Driver
Marc-
That’s mostly a Java VM deal. Google around, but there are ways to get a
handle to the ManagementFactory within memory. I believe you’d have to play
around with the startup parameters to enable the Management Bean, but not
enable the TCP/IP port.
Justin-
JMS connections act and behave very different from JDBC connections. Just like
a long query can block other apps trying to access the connection on a shared
JDBC connection, a slow consumer can impact others trying to access it as well.
You can do multiple sessions on top of a single
Justin-
Sorry to hear that you’ve had problems with ActiveMQ in the past. I’ve had a
lot of successful deployments in large-scale environments (3,000+ brokers, hub
and spoke with 1 broker serving up to 1,000 clients, 4,000 queues and 3,000
total connections) with transactions, and the full
Are you saying you have a Durable Topic Subscription connecting to
VirtualTopic.A?
Otherwise, the way I’m reading this.. I think you are asking to stop message
from going to the Consumer.B.VirtaulTopic.A queue. To do that, just delete the
queue. The presence of the queue acts as the
I suggest looking at replacing the broker for generating the messages with
simple Camel routes using the timer or quartz endpoints. Clustering scheduled
jobs is always a challenge. If you run Camel in a Karaf-based container
(ServiceMix, JBoss Fuse, etc) you can setup the containers to be
What version of ActiveMQ jars do you have listed in your dependencies?
On Sep 1, 2014, at 9:37 AM, b-brother yingchao@alibaba-inc.com wrote:
first , I have copied file activemq.xml from src package.
---
?xml version=1.0 encoding=UTF-8?
beans
Hi James-
ActiveMQ 5.5.1 is quite aged at this point. Any reason you aren’t looking at a
newer version?
Transactions and connection pooling is tricky— are you doing XA or JMS Local?
I suggest trying to get it all working, then tune.. CACHE_NONE first.
-Matt
On Sep 2, 2014, at 7:05 AM, James
1. By “persistent topics”, do you mean “durable topics”, where you have
subscription(s) tied to a specific topic where messages are being produced, or
do you mean “persistent messages”?
2. A topic with no durable subscriptions isn’t going to consume much disk space
when there aren’t any
Sophia-
I suggest starting with a single connection per consumer. That model performs
well for most applications. You can then look to add multiple consumers on top
of a connection (maybe 4 max) and then look to add additional connections to
scale consumption.
-Matt
On Aug 19, 2014, at
-forward.
Best of luck!
-Matt Pavlovich
On Aug 21, 2014, at 6:25 AM, Jon Mithe jon.mi...@gmail.com wrote:
Hello,
I'm trying to figure out if activemq would be a good fit to broker messages
from a desktop application to a backend services.
In particular what is confusing me is say 100 users
This tcp://127.0.0.1:49881” looks like the client-side port, which is standard
for TCP/IP client-server traffic. If you have confirmed that messages are
moving, than you should feel confident that SSL is working. if you want to
validate with complete certainty, open a network sniffer and you
Yes, you can move the location of those KahaDB files while ActiveMQ is not
running.
http://activemq.apache.org/kahadb.html
broker brokerName=broker ...
persistenceAdapter
kahaDB directory=“/some/other/folder/activemq-data
journalMaxFileLength=32mb/
/persistenceAdapter
...
I don’t recommend using the same pool for consumers (especially if you use
local or XA transactions). The benefit is pretty minimal, and it can cause
issues once you start scaling.
I don’t see pooling being a big boost for the number of total connections you
are describing, but it might make
What size are the messages? What persistence store (KahaDB, LevelDB, JDBC) are
you using?
Are you using 5.7.0 Apache release or other?
On Oct 22, 2013, at 3:34 PM, wcpolicarpio walter.policar...@morgansolar.com
wrote:
Hi Everyone, I have a message queue named amq570queue, after
Confirmed.. if you don't clean up your session and connection cleanly, the
broker will warn for you. Its usually indicative of a client that is mis-coded.
Look for exceptions being thrown.. a lot of times folks don't have the finally
{ } block defined to clean up JMS objects.
Also.. check out
Hi Michal-
Lot of stuff to try to cover here.. but in short.. performance tuning is a
tough thing to cover in an email.
1. Separate the testing of perf through the broker from your app, so you can
get a baseline. Look into the activemq-perf tooling.
2. 40 producers and 40 consumers into one
Double check that you aren't hitting a memory limit and the broker swapping the
messages to the temp store. Either way, it shouldn't be that much slower.
Do you have a reproducible unit test that you could share to open a ticket?
On Oct 23, 2013, at 12:52 PM, kal123 kpfininf...@gmail.com
A couple things to look into--
1. Set a message expiration. You'll set this when producing the message.
2. gcInactiveDestinations (this will garbage collect a destination if a
consumer hasn't come around for X period of time)
http://activemq.apache.org/delete-inactive-destinations.html
Hope
David-
Try setting -Ddurable=true. It looks like you are producing non-persistent
messages. Non-persistent messages would be lost when the master goes down.
Hope this helps.
-Matt
On Oct 11, 2013, at 8:17 PM, dlaube dla...@gmail.com wrote:
I am encountering some issues with master/slave
often taking 10 seconds to list just 5 files in an NFS-mounted
That screams network issue.
+ Check your network interface stats for errors (ifconfig)
+ Check your duplex setting -- many switches do not really do auto well.
Hard-coding to full-duplex helps, but if you have a managed
Enqueued and dequeued are counters for the number of total messages that
have traveled through the system over time. QueueSize is the current count.
On 2/23/12 1:00 PM, mserrano wrote:
Ok, after poking around a bit, I realized that there must be persisted
messages being restored from a
Chris-
You could also look into using an encrypted filesystem, where it
encrypts an entire partition. Linux has built-in support for that. You
would then just configure ActiveMQ to store the KahaDB data on that
partition.
Matt Pavlovich
On 2/20/12 1:07 PM, chris snow wrote:
Hi Forum
were able to get HA w/o having to
wait for the SAP bug to be fixed.
The catch with updateClusterClients, is that it doesn't know about
slaves until they become active, so that's why you would need to masters
and two slaves to work around the SAP issue.
Hope this clears it up!
Matt Pavlovich
That's not right. If its older and really-really-low end, maybe, but
that's definitely not the standard.
If that is going to be the case, you'll want to consider NFSv4 instead.
On 2/15/12 8:55 AM, SuoNayi wrote:
Hi all,
In order to set up a master-slave cluster, we mounted the same
into play.)
3. Master 1 fails, client connects to Master 2
3. Slave 1 comes up. Master 2 provides client a list of active
brokers-- master2, slave1.
4. etc..
Broker side config here:
http://activemq.apache.org/failover-transport-reference.html
Hope this helps!
Matt Pavlovich
On 2/15/12 7:41 AM
to you in the routing rules.
Hope this helps!
Matt Pavlovich
On 2/13/12 6:58 AM, Hervé BARRAULT wrote:
Hi,
is there no advice to send a message to multiple consumers using activeMQ
?
Regards
Hervé
On 2/2/12, Hervé BARRAULTherve.barrault@gmail.**comherve.barra...@gmail.com
wrote:
Hi,
I
Are you using the Spring Caching Connection factory? If so, please
disable that. There are a number of reported bugs. Try the non-caching
version, or use the ActiveMQConnectionFactory directly.
On 2/14/12 9:13 AM, john wrote:
I'm running the fuse 4.4.1-fuse-01-13 ESB release which includes
I'm wondering if its a XA problem, or look into adjusting your pool
config. It currently allows a max of 500 connections. For consuming,
4-5 max connections per CPU core is usually a good ratio.
On 2/14/12 10:12 AM, john wrote:
I think I'm only using spring for transactions. Here's the
just happening with exceptions/errors/etc.
Hope this helps,
Matt Pavlovich
On 2/14/12 10:32 AM, john wrote:
I'll try bumping the max connections down, but I'm not sure I understand how
it would cause the leak. This route has been running on my dev box since
last Thursday and as of this morning I
recommend using the shared filesystem using a SAN (or NFSv4).
Hope this helps,
Matt Pavlovich
On 2/13/12 2:11 AM, Zagan wrote:
Hello again,
at the moment I am analysing and evaluating the different Active MQ HA
possibilities.
At the Active MQ instance level I found
* Shared Nothing Master/Slave two
flexibility available to you in the routing rules.
Hope this helps!
Matt Pavlovich
On 2/13/12 6:58 AM, Hervé BARRAULT wrote:
Hi,
is there no advice to send a message to multiple consumers using activeMQ ?
Regards
Hervé
On 2/2/12, Hervé BARRAULTherve.barra...@gmail.com wrote:
Hi,
I would multicast
Title: Signature
No problem, let us know how it goes.
Thanks!
Matt Pavlovich
On 2/10/12 3:50 PM, Brian Wright wrote:
Hi Matt,
Thanks for the information. I will pass this response onto the
developer to look into testing
.
Side note-- I'm not a big fan of Spring's JmsTemplate in general.
ActiveMQ provides an impl of the JMS API, and I think that provides a
simple enough abstraction. It seems to me that adding the Spring layer on
top just adds a layer of complexity. My $0.02.
Hope this helps,
Matt Pavlovich
On 2
configuration is correct, you won't have any problems.
If this test succeeds with a couple hundred thousand messages going
through it, than you know you need to focus on the client-side code.
http://activemq.apache.org/examples.html
Hope this helps!
Matt Pavlovich
On 2/9/12 12:12 PM, Abimael
Chaitanya-
You definitely need to upgrade from ActiveMQ 5.2. If you aren't
experiencing a bug currently, there is a good chance you will down the road.
Matt Pavlovich
On 2/2/12 7:00 AM, Chaitanya Gupta wrote:
Hi Matt,
Thx for inputs.
I tried failover transport but having one issue
as a back-end data store for AMQ?
Transactions?
Hope this helps,
Matt Pavlovich
On 2/6/12 9:40 PM, Brian Wright wrote:
Hello,
I'm actually asking this question on behalf of one of our
developers. As I understand ActiveMQ (and Service
have a
busy destination, be sure to add an entry for the busy destination to
give it more than 1mb, or increase the default.
Action 2: After fixing and testing #1, look to tweak the default
memoryLimit, or add per-destination configs for busy queues/topics.
Hope this helps!
Matt Pavlovich
that adding the Spring layer
on top just adds a layer of complexity. My $0.02.
Hope this helps,
Matt Pavlovich
On 2/7/12 6:09 PM, Kai Hackemesser wrote:
More details to the issue: This is how I configured the JmsTemplate:
public @Bean
JmsTemplate jmsTemplate
/stop it without having to stop the broker process.
Matt Pavlovich
On 2/2/12 8:27 AM, xhannan wrote:
We are trying to build a system that would be heavily message system based.
Trying to publish a topic and that needs to be brokered by a single process
to distribute that topic to the appropriate
Add the Fuse repo to your Maven settings
http://repo.fusesource.com/nexus/content/groups/public/
Matt Pavlovich
On 2/2/12 10:33 AM, Chris Robison wrote:
I'm trying to build apache-activemq-5.5.1-fuse-01-13 and I keep getting the
following error:
[ERROR] Failed to execute goal on project
find more useful information there.
Can you paste your ActiveMQ config and client-side URL's to
http://pastebin.com, or other and share the link? After reviewing the
config, we may be able to help identify the root cause.
Thanks,
Matt Pavlovich
On 2/2/12 1:46 PM, Abimael wrote:
Oh
on the group and the dynamic group model, where the groups are
listed on the users. I think it may depend on how many upgrades that
AD instance has been through.a
A patch may make sense, but it would need to be consider all the weird
LDAP grouping models.
Matt Pavlovich
On 2/2/12 3:13 PM, Chris
the community docs, I'm sure it
wouldn't be hard to get them tied in.
Thanks,
Matt Pavlovich
Media|Driver
On 1/31/12 9:19 PM, Jason Dillon wrote:
So is the community abandoning its documentation in favor of the fuse
documentation? I've seen similar replies a few times to go look at fuse docs
vs
Hi-
Glad to here the issue has cleared up for you. Using host names is
probably a safer setup in most cases, since there are situations where
using the IP address may cause problems for other folks.
Thanks,
Matt Pavlovich
On 2/1/12 7:19 AM, tomerb wrote:
figured out the problem (at list
Chris-
Try adding s to the connectionProtocol value, so it'd read
connectionProtocol=s. I think that's for simple, as in clear text
password to auth against LDAP.
Matt
On 2/1/12 12:22 PM, Chris Robison wrote:
I'm trying to use the LDAP login module to tie into Active Directory.
Here's
My bad.. the default is s in the ActiveMQ src. This is where you
would specify ssl or not. I think the problem is that you have it
empty, so its parsing as NULL, and you are getting the error. Try not
setting it, and see if the default works for you.
On 2/1/12 12:22 PM, Chris Robison
Are you getting the exact same exception? Your original exception cause
shows a null value for a key in that config:
Caused by: java.io.IOException: Configuration Error:
Line 6: expected [option key], found [null]
at com.sun.security.auth.login.**ConfigFile.match(ConfigFile.**java:577)
at
How comfortable are you with Java? The next step to try would be to
write up a quick Java unit test that has the ConfigFile class try to
intialize against your login.config file.
See:
com.sun.security.auth.login.ConfigFile
On 2/1/12 1:59 PM, Chris Robison wrote:
Yeah, it's the exact same
Chris-
I whipped up a quick unit test, and this passed. I set the
connectionProtocol=s, w/o quotes.
ldap-login {
org.apache.activemq.jaas.LDAPLoginModule required
debug=true
initialContextFactory=com.sun.jndi.ldap.LdapCtxFactory
connectionURL=ldap://dc101.cdr.corp;
Ah, start w/ line 0.. that puts it at connectionPassword. Try adding
around Password!. The exclamation point may be throwing it off.
On 2/1/12 2:47 PM, Chris Robison wrote:
The error says line 6 which in my login.config is connectionUsername.
Chris
On Wed, Feb 1, 2012 at 1:42 PM, Chris
Glad to hear :-)
On 2/1/12 3:00 PM, Chris Robison wrote:
Sweet! Now I'm getting an LDAP error, which is progress.
On Wed, Feb 1, 2012 at 1:56 PM, Matt Pavlovichmattr...@gmail.com wrote:
Ah, start w/ line 0.. that puts it at connectionPassword. Try adding
around Password!. The
+1 Cut out a where clause will speed it up
On 2/1/12 3:10 PM, Gary Tully wrote:
Would it be simpler to use different table names for each pair. So
just set the tablePrefix on the statements element in xml
configuration.
On 31 January 2012 18:34, mikmelamikm...@yahoo.com wrote:
As it was
Oscar-
What is your Java heap size?
On 1/27/12 5:29 AM, Oscar Pernas wrote:
Hi, sorry for the spam:
I have the following configuration
destinationPolicy
policyMap
policyEntries
policyEntry topic= producerFlowControl=false
router: http://camel.apache.org/content-based-router.html
Hope this helps,
Matt Pavlovich
On 1/27/12 2:54 PM, Chris Robison wrote:
Let me describe my scenario and hopefully my question will become clear. We
have 3 main data centers. In each of these data centers we host a web
portal that allows
or make changes while the broker
is running. With Camel routes, you can stop/start them individually, if
you have a maint window, etc.
Matt Pavlovich
On 1/27/12 3:52 PM, Chris Robison wrote:
Thanks for the quick response. The content-based router seems to be good
for messages going only one
like cursors and turn off producer
flow control in most scenarios, but if you want some nice bedtime
reading you can get more detail here:
http://activemq.apache.org/producer-flow-control.html
Matt Pavlovich
On 1/26/12 11:53 AM, Abimael wrote:
@Matt Pavlovich-2
Thank you.
Yes, while I
.
Moving to 5.5.1 is a good bet, and the FuseSource releases are nicer
since they've been patched to cover issues other customers have experienced.
Hope this helps!
Matt Pavlovich
On 1/26/12 2:41 PM, Soumya Kanti Chakraborty wrote:
Hi
We are using AMQ4.0.1 and JBoss 4.0 in a application
this helps!
Matt Pavlovich
On 1/25/12 4:20 AM, Chaitanya Gupta wrote:
Hi,
I have an application deployed in clustered env (say app server1, app server2).
I also have activemq running on server1 and server2 so I have 2 brokers (one
queue on each broker). App on server1 can write to any
Hi Matthew-
A negative seek offset sounds like a bug. I'd suggest creating a
ticket, and if you can attach the contents of the kahadb/ folder, that
would be helpful. Are you doing anything other than just simple
queues? Transactions, Durable Topics, Expiration, Message Groups, etc?
Matt
Pavlovichmattr...@gmail.com wrote:
Hi Bill-
Try adding the closing / to the statisticsBrokerPlugin element:
plugins
statisticsBrokerPlugin/
/plugins
Tip: Also, when working with configs. Starting AMQ with the 'console'
option.
./bin/activemq console
Hope this helps!
Matt Pavlovich
Hi Matt
a fork as much as it is just a more
stable build.
My offer still stands to help review your config and get you going.
Thanks,
Matt Pavlovich
On 1/25/12 11:12 AM, Bill Moo wrote:
On Wed, Jan 25, 2012 at 5:03 PM, Matt Pavlovichmattr...@gmail.com wrote:
Bill-
I guess I'm not understanding
familiar with that part of the code, but it seems
logical.
Matt Pavlovich
On 1/25/12 4:31 PM, mkubicina wrote:
Hi Matt,
Thanks for your reply.
We are just using standard queues. Nothing fancy. Unfortunately, I will not
be able to provide contents of the kahadb as it is rather large. Since we
Hi Bill-
Try adding the closing / to the statisticsBrokerPlugin element:
plugins
statisticsBrokerPlugin/
/plugins
Tip: Also, when working with configs. Starting AMQ with the 'console'
option.
./bin/activemq console
Hope this helps!
Matt Pavlovich
On 1/6/12 10:28 AM, Bill Moo wrote
/enterprise-activemq/
Alternatively, try the latest Apache 5.6 snapshot.
Hope this helps!
Matt Pavlovich
On 1/24/12 2:35 PM, Don Hu wrote:
There are numerous reports of similar issues, and it is a credible and critical
bug that prevents any serious usages of ActiveMQ in production.
We should
rule of thumb is space for at
least 3-4 days worth of data (depending on your messaging pattern).
Hope this helps!
Matt Pavlovich
On 1/24/12 1:32 PM, Abimael wrote:
Hi
Perhaps my question is simple . I tried to look for information on ApacheMQ
documentaion but I 'm not able to do.
Scenario
in the ActiveMQ libs for this, and
I'm not sure that there is a free C++ JMX API anywhere. You could write
a quick Java program that makes the JMX calls, and then have your C++
program call that directly.
Hope this helps!
Matt Pavlovich
On 1/23/12 7:06 AM, sreekar wrote:
Hi All,
I am a new bie
the
producer flow control.
JMSMessage msg = ...
msg.setJMSDeliveryMode(DeliveryMode.PERSISTENT);
Hope this helps!
Matt Pavlovich
On 1/20/12 1:21 PM, kureckam wrote:
I'm trying to setup ActiveMQ to store a large number of messages sent to a
queue but it seems to only use the memory limit
Yeah, that's large ;-). You might consider the pattern where the files are
stored (HTTP, WebDav, FTP, NFS, etc), and you create events that contain the
location URL of the file that the application on the other end will process.
That app then accesses the file accordingly.
Matt Pavlovich
and topics to meet different
eventing patterns that developers might need. A simple example would be like
an Instant Messaging system, where users send each other chat messages-- or
like Twitter, where a user sends on message and it can go to multiple
subscribers using Topics.
Matt Pavlovich
On Apr
How big is big? 1Mb, 100Mb, 10Gb?
On Apr 7, 2011, at 1:05 AM, cristianb wrote:
Hi,
What is considered a 'great' approach for doing this? IStreamMessage is of
no great use, BlobMessage is not supported... I thought there's support for
something better than sending the file in chunks,
:
UserForm - AMQ [Web page returns to user really quickly]
Elsewhere, Camel reads from AMQ and in parallel, sends the message to be stored
in MySQL and to MNO for processing.
On the return, Camel read from the response queue to update the data in MySQL.
- Matt Pavlovich
On Apr 7, 2011, at 11:46 AM
Exactly.
On Apr 7, 2011, at 1:24 PM, nnprasad wrote:
He Meant that the sending message process is very quick and it is a
asynchronous call.
as it is very quick, once after user clicks on send button / submit
button...the control will return to the user form with in no time, and the
user
I prefer sticky load balancing in production, so no accidental instances that
get fired up on the same network become part of the cluster.
On Sep 20, 2010, at 2:38 AM, Mot wrote:
if i have only one consumer and multiple brokers attached to it. then for
load balancing which is better out of
Is there a reason you would not consider using separate queues for each of the
different consumers? Seems that it may simplify your solution.
Matt Pavlovich
On Aug 31, 2010, at 12:30 PM, ChicagoBob123 b...@bobfx.com wrote:
Newbie question about many consumers and many producers.
I have
Definitely check out the examples folder in the distribution. Another place to
look would be unit tests in the source code, but definitely start with the
examples folder.
Matt Pavlovich
On Aug 31, 2010, at 12:32 PM, ChicagoBob123 b...@bobfx.com wrote:
I am stumbling on examples and some
Can you post the junit test to a pastebin.com or other clipboard?
Thanks
Matt Pavlovich
On Aug 20, 2010, at 12:37 PM, ReC0iL larrymon2...@gmail.com wrote:
Hi all,
I've just started to use ActiveMQ and I'm trying to build a distributed
workflow and I'm trying to get an end-to-end
201 - 278 of 278 matches
Mail list logo
