The Spring AMPQ stuff seems to be tightly bound to AMQP V0.91 as its what
RabbitMQ uses. ActiveMQ supports AMQP 1.0 and there are substantial
differences between the protocol versions. As stated perviously you'd be
better off using the SpringJMS approach.
On Thu Jan 29 2015 at 7:31:15 AM
Take a look at idempotent consumers in camel. This may help you out as a
basis for your plugin if you decide to go with it.
On Oct 18, 2014 5:47 PM, Andreas Gies andr...@wayofquality.de wrote:
Hi
I am using ActiveMQ 5.10 in an application. So far the requirement for the
remote locations has
Maybe an alternative approach to consider is to use camel routes
embedded in the broker.
Take a look at http://activemq.apache.org/broker-camel-component.html
On Tue, Aug 26, 2014 at 4:40 AM, Dror dro...@hotmail.com wrote:
Hi,
My use case:
We get lots of small size (up to 1K) messages and
I wonder if the queue prefetch is buffering the messages. Try reducing
the prefetch size to 0.
On Thu, Aug 21, 2014 at 4:23 AM, nolaez nurycelina_...@hotmail.com wrote:
Hello, I am noob in ActiveMQ and I have a question, I would like to know, How
to force a queue respect the priorities of the
Sorry I gave you the wrong info, its the SpringJMSTemplate that uses a
connection per message. So use a pooled or cached connection factory
for that.
As for the consumers I don't think you need a pooled/cached connection.
See
The spring dlmc opens a connection to send a message and then closes the
connection. This puts a lot of load on the broker. Using a pooled
connection factory gets around this by reusing the connections.
On Aug 12, 2014 9:14 PM, Sophia Wright sophiawrigh...@gmail.com wrote:
Hi,
I want to create
Others would know better but I'd have thought that each remote broker
would be seen as and individual client to the central broker and as
such would have its own prefetch limit and flow control management.
The latency and bandwidth limitations that you mention would also have
an impact.
As for
I'd suspect that you'd have storage corruption issues. Why not use store
and forward over network connectors between the two brokers. The internal
broker can open the network connection in duplex mode to allow message
transfer from the DMZ broker.
On Aug 12, 2014 4:27 AM, Chainbuck
I'd look at using camel routes embedded in activemq to control this as
you can retrieve queue depths to determine the processing approach.
Take a look at
http://rajdavies.blogspot.com.au/2013/09/apache-camel-broker-component-for.html
On Wed, Jul 16, 2014 at 11:27 AM, Niranjan Rao
+1
This approach is a derivative of the single purpose queue anti-pattern see
I haven't tried this but maybe you can encrypt the password in the
datasource definition file that loads the ActiveMQ RAR.
In the Configuring JBoss section of
http://activemq.apache.org/integrating-apache-activemq-with-jboss.html try
adding a security-domain element.
The following link describes
I may be wrong but I don't think the MQTT wire protocol facilitates the
passing of broker cluster details to clients. AMQP has the same limitation.
Take a look at the gateway feature of fabric8, this may help you get around
this https://github.com/jboss-fuse/fuse/blob/master/docs/gateway.md
On
Take a look at the pluggable storage lockers feature
http://activemq.apache.org/pluggable-storage-lockers.html
in particular the lockAcquireSleepInterval attribute of the database locker.
On Sat, May 24, 2014 at 12:56 AM, elazarrosenthal ela...@panix.com wrote:
We are testing ActimveMQ with
gary.tu...@gmail.com wrote:
peek at https://issues.apache.org/jira/browse/AMQ-3864 - there is
publishedAddressPolicy element on a transport connector that will
accept an IPADRESS strategy since 5.8
On 18 May 2014 02:50, Noel OConnor noel.ocon...@gmail.com wrote:
Thanks Sonica,
I'll try
in this_container /etc/hosts
pointing to the dynamic ip of other_container.
see:
http://blog.docker.io/2014/05/docker-0-11-release-candidate-for-1-0/
On Sat, May 17, 2014 at 6:15 AM, Noel OConnor noel.ocon...@gmail.com
wrote:
Hi,
I'm trying to get activemq working on a Docker container. I've got
Hi,
I'm trying to get activemq working on a Docker container. I've got the
basic install going and I'm now trying to configure multicast discovery so
that multiple containers can be connected together.
I've turned on the multicast discovery and the containers are trying to
connect.
However the two
You could try something like DNS failover or a software loadbalancer
presenting a VIP, but the easiest way might be to change you app to handle
connecting to multiple brokers
On Tue, Apr 29, 2014 at 11:57 AM, mchinea
manuel.chi...@adilamtech.com.auwrote:
So it seems the only way to be sure
Network of brokers might be what you're looking for
see http://activemq.apache.org/networks-of-brokers.html
On Sat, Mar 29, 2014 at 6:55 PM, mtakahashi mtakaha...@yourinventit.comwrote:
Hello,
Does ActiveMQ support active-active cluster configuration ?
I have read the following document,
Have you considered using a shared filesystem like NFS V4 or GlusterFS
mounted on a EBS volume. For multizone redundancy you could use the EBS
cross region snapshot copy feature.
I haven't done any of this so you'd have to verify that it works.
On Sat, Mar 22, 2014 at 8:20 AM, Oleg Dulin
what kind of restriction do you mean ?
On Wed, Mar 12, 2014 at 5:33 PM, khandelwalanuj khandelwal.anu...@gmail.com
wrote:
Hi,
Using ActiveMQ v.5.8
I want to know that is there a way to restrict a perticular client to
connect to the broker ?
I am using my own plugin where I override
have you seen ActiveMQSession.INDIVIDUAL_ACKNOWLEDGE
see
http://activemq.apache.org/maven/apidocs/org/apache/activemq/ActiveMQSession.html#INDIVIDUAL_ACKNOWLEDGE
On Wed, Mar 5, 2014 at 6:48 PM, Li Li fancye...@gmail.com wrote:
hi all,
I want to process a batch of message using my own
=getMessgeFromLinkedList();
process msg;
msg.acknowledge();
}
On Wed, Mar 5, 2014 at 5:08 PM, Noel OConnor noel.ocon...@gmail.com
wrote:
have you seen ActiveMQSession.INDIVIDUAL_ACKNOWLEDGE
see
http://activemq.apache.org/maven/apidocs/org/apache/activemq/ActiveMQSession.html
Rather than trying to change activemq you could look at implementing
something with activemq and camel to provide this custom dispatch and
redelivery mechanism.
But as artnaseef stated it wouldn't be a simple solution.
On Mon, Mar 3, 2014 at 6:41 PM, Li Li fancye...@gmail.com wrote:
sorry to
http://docs.oracle.com/javaee/5/api/javax/jms/MessageProducer.html#setPriority(int)
On Tue, Mar 4, 2014 at 11:57 AM, Li Li fancye...@gmail.com wrote:
I am using the following code snippet to send messages to a queue. How
to make priority queue enabled?
class Producer{
private
If the mdb is in a transaction you could try rolling it back. If not (I
think) the message should be redelivered if you throw a runtime exception
from within the MDB.
On Mon, Mar 3, 2014 at 3:35 PM, Li Li fancye...@gmail.com wrote:
hi all,
can a queue message consumer refuse a message
I've used this config in the past...
persistenceAdapter
replicatedLevelDB directory=../data/leveldb/amq
replicas=4
zkAddress=10.64.132.40:2182,10.64.132.40:2183,
10.64.132.40:2184
zkPassword=admin
Are you using topics and reusing the same client id for multiple producers.
Its just a guess but check just in case.
On Sat, Feb 15, 2014 at 9:18 AM, Rodrigo Ramos crackdu...@gmail.com wrote:
Hi
Im testing a web application that is connected with ActiveMQ as producer.
IM getting below
Take a look at apache camel for this kind of processing.
On Mon, Feb 10, 2014 at 4:22 PM, mamta.alshi mamta.al...@gmail.com wrote:
Hi,
I'm a newbie to activemq...
I want to know how I can combine all the messages in activemq queue (for eg
I have 900 records)to form an xml?
TIA for help
Check if you're hitting the max disk write on your local disk.
SAN disks can have battery backed caches which write to memory before
writing to disk.
On Wed, Feb 12, 2014 at 3:32 AM, kal123 kpfininf...@gmail.com wrote:
The following links states:
http://activemq.apache.org/masterslave.html
Try changing the timeBetweenExpirationCheckMillis to -1.
This will turn off the eviction thread. I don't know what implications this
will have for your application so test if there's any impact.
See
http://activemq.apache.org/maven/apidocs/org/apache/activemq/pool/PooledConnectionFactory.html
You could either use a JMS bridge to connect the two but its probably
better to get apache camel to do this for you.
see http://activemq.apache.org/jms-to-jms-bridge.html
On Thu, Feb 6, 2014 at 6:59 PM, kalyansworld
kadhakshinamoor...@inautix.co.in wrote:
I am new to JMS.
There will be a
hmmm can you check if the messages are being sent persistently ?
On Wed, Feb 5, 2014 at 3:13 PM, bpoppa jimj...@gmail.com wrote:
I do. Here is my config:
persistenceAdapter
replicatedLevelDB directory=activemq-data replicas=3
bind=tcp://10.240.242.233:61619
I haven't used this but how about having the list of nodes stored in a ldap
store
See http://activemq.apache.org/ldap-broker-discovery-mechanism.html
To be honest most production deployments I've seen have pretty static
cluster configurations.
On Sun, Feb 2, 2014 at 8:05 AM, 1gnition
Try turning on SSL debugging as well...
http://docs.oracle.com/javase/1.5.0/docs/guide/security/jsse/ReadDebug.html
On Tue, Feb 4, 2014 at 11:58 AM, artnaseef a...@artnaseef.com wrote:
What does the TransportConnector configuration look like?
The error, if I'm reading it right, is from the
You could either embed a camel route to consume from the queue or if you're
considering deleting the underlying kahadb persistence store maybe separate
it out from other stores using the mkahadb directive.
See
http://blog.garytully.com/2011/11/activemq-multiple-kahadb-instances.html
On Tue,
35 matches
Mail list logo
