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 artnaseef
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" wrote:
> Hi
>
> I am using ActiveMQ 5.10 in an application. So far the requirement for the
> remote locations has been for pure store
Multicast won't work on EC2 and the attached storage may give you
performance issues if you're doing persistent messaging.
I'd do a proof of concept first to ensure that activemq on EC2 can do
what you need.
On Wed, Oct 8, 2014 at 2:36 AM, khandelwalanuj
wrote:
> Hi,
>
> I want to use ActiveMQ on
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 wrote:
> Hi,
>
> My use case:
> We get lots of small size (up to 1K) messages and we need to send
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 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 messages without consideri
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
http://stackoverflow.com/questions/19560479/which-is-better-pooledconn
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 dis
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" wrote:
> Hi,
>
> I want to create 7 producers and 5 d
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" wrote:
>
>
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 wrote:
> Greet
+1
This approach is a derivative of the single purpose queue anti-pattern see
http://books.google.com.au/books?id=1G3Pa_LoIGQC&pg=PA236&lpg=PA236&dq=single+purpose+queue&source=bl&ots=O57wy-t5MZ&sig=ADfUPDpAUywSVNnrnanjnkus13g&hl=en&sa=X&ei=nNDFU6DYIcvn8AWPgoKYBw&ved=0CB4Q6AEwAA#v=onepage&q=single
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
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 wrote:
> We are testing ActimveMQ with and Oracle backe
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
Tully 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 wrote:
> > Thanks Sonica,
> > I
osed to inject for you an entry 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 >wrot
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
wrote:
> So it seems the only way to be sure clients are connected to either b
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 wrote:
> Hello,
>
> Does ActiveMQ support active-active cluster configuration ?
> I have read the following document, but this is only for mast
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 wrote:
what kind of restriction do you mean ?
On Wed, Mar 12, 2014 at 5:33 PM, khandelwalanuj 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 addConnection function,
while(true){
> Message msg=getMessgeFromLinkedList();
> process msg;
> msg.acknowledge();
> }
>
>
> On Wed, Mar 5, 2014 at 5:08 PM, Noel OConnor
> wrote:
> > have you seen ActiveMQSession.INDIVIDUAL_ACKNOWLEDGE
> >
> > see
> >
>
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 wrote:
> hi all,
> I want to process a batch of message using my own priority
> algorithm
http://docs.oracle.com/javaee/5/api/javax/jms/MessageProducer.html#setPriority(int)
On Tue, Mar 4, 2014 at 11:57 AM, Li Li wrote:
> I am using the following code snippet to send messages to a queue. How
> to make priority queue enabled?
> class Producer{
> private ActiveMQConnection conn;
> pri
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 wrote:
> sorry to hear that. I need t
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 wrote:
> hi all,
> can a queue message consumer "refuse" a message after receive a
> m
I've used this config in the past...
On Sat, Feb 22, 2014 at 12:53 AM, frederic.gendebien <
frederic.gendeb...@gmail.com> wrote:
> Hello guys,
>
> I am trying to set up a Replicated LevelDB store for ActiveMQ 5.9.0, but I
> am facing a lot of issues and I am a bit feed up I have
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 wrote:
> Hi
>
>
> Im testing a web application that is connected with ActiveMQ as producer.
> IM getting below error with load:
>
>
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 wrote:
> The following links states:
> http://activemq.apache.org/masterslave.html
> For those willing t
Take a look at apache camel for this kind of processing.
On Mon, Feb 10, 2014 at 4:22 PM, mamta.alshi 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
>
>
>
>
>
>
>
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
hmmm can you check if the messages are being sent persistently ?
On Wed, Feb 5, 2014 at 3:13 PM, bpoppa wrote:
> I do. Here is my config:
>
>
> bind="tcp://10.240.242.233:61619" hostname="10.240.242.233"
> zkAddress="10.240.142.24:2181,10.240.242.233:2181,10.240.211.220:2
Have you set the hostname and bind addresses ?
Is there anything in the slave log files ?
This is config that I've used a while ago
hth
On Wed, Feb 5, 2014 at 1:42 PM, bpoppa wrote:
> So I have the replicatedLevelDB configured and working using the example on
> the activeMQ
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, Fe
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 wrote:
> What does the TransportConnector configuration look like?
>
> The error, if I'm reading it right, is from the Broker accepting
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 wrote:
37 matches
Mail list logo
