I am running onto the same issue as well with ActiveMQ 5.1 and Spring 2.5. If
I don't use JmsTemplate or use it but do a blocking call, it is fine.
However, I am unable to use JmsTemplate with it being non-blocking. Any
thoughts?
Yohan Liyanage wrote:
>
> Hi,
>
> I tried to use JmsTemplate's r
James.Strachan wrote:
>
>
> This sounds like something Camel could do BTW; we could dynamically
> add new routes based on new Destinations being created?
>
> Another option is that there's actually a statically created consumer;
> but that consumer uses wildcards?
>
> e.g.
>
> from("activemq
What would be a good way to do this? Basically, this is my requirement -
* Clients send messages to dynamically created JMS destinations via a
Messaging Gateway.
* The gateway has to create dynamic JMS listeners (at runtime, that is) so
that it listens to each of these new destinations that are c
Take a look at this thread for a potential solution:
http://www.nabble.com/%28Solved%29-Discovering-queues-programmatically-and-dequeuing-messages-off-of-them-tt19538405.html
kpalania wrote:
>
>
> James.Strachan wrote:
>>
>> It does take a little while for some desti
Ok, this solved the problem -
destinationSource.start();
destinationSource.setDestinationListener(destinationListener);
I implemented a destination listener and added the above lines of code. I
now see the list of queues.. Is the expected behavior? Certainly, the
documentation doesn't mention th
James.Strachan wrote:
>
> It does take a little while for some destinations to show up as they
> are typically loaded asynchronously on the JMS client - does sleeping
> for a second or so help?
>
I believe this is the same problem that I am running into. Is this a bug?
--
View this message in
James.Strachan wrote:
>
> I'd start() the connection first - then wait a few seconds; the
> advisories are asynchronously sent once a connection starts
>
I added a Thread.sleep(1); call right after I started the connection,
but still no effect. This is exactly what I am doing. Let me know
Thanks James but this piece of code does not seem to return all the queues on
the broker. Any thoughts on why that would be the case?
---
public void testGetAllQueues()
{
ActiveMQConnectionFactory connectionFactor
I have a need to discover queues programmatically and dequeue messages off of
them. In other words, I cannot make configuration changes to handle new JMS
destinations and/or add new instances of the same listener. I basically need
a way to have a process that dynamically discovers destinations (an
I can't seem to find the DestinationSource class -
http://activemq.apache.org/maven/activemq-core/apidocs/
Has this been deprecated?
jlim wrote:
>
> Hi Shaf,
>
> Just tested this on 5.1.0 and seems to work fine on my test. I tested
> this using startup destinations
> (http://activemq.ap
Messages from a broker (say broker A) do not get forwarded to another broker,
broker B (has duplex set to TRUE and the network connector points to broker
A) unless and until I have a consumer that was active atleast once. If I run
a simple java application that dequeues the messages off of the que
This is my topology:
* Broker A is outside the LAN and has no network connectors.
* Brokers B and C are running on 2 different machines inside the LAN and
have duplex set to TRUE.
* Client sends a message to queue1 on brokerA and sends another message to
queue2 on brokerA.
* Broker A receives both
o see the following, which describes how to implement a recipient list
> via Camel
>
> http://activemq.apache.org/camel/recipient-list.html
>
> Hope this helps.
>
> Joe
> Get a free ActiveMQ user guide @ www.ttmsolutions.com
>
>
>
> kpalania wrote:
>>
>
Is this possible via ActiveMQ?
* Client sends message to broker A that has no network connectors defined.
* Broker B has a network connector pointing to broker A and has duplex set
to TRUE.
* Message is sent to a queue named "Test".
* Consumer listening to "Test" on broker B gets the message .
N
If I remove the "duplex" attribute from both the brokers in the LAN, I get an
InvalidClientIDException on one of the brokers..
kpalania wrote:
>
> This is my setup:
> * I have 3 brokers configured and running: 1 broker in the cloud and 2
> brokers in the LAN.
> * Ther
This is my setup:
* I have 3 brokers configured and running: 1 broker in the cloud and 2
brokers in the LAN.
* There is no network connector defined in broker 1. The transport connector
is set to use TCP on 61616.
* The network connectors on both the brokers in the LAN have "duplex" set to
TRUE an
This is my Spring configuration and I have ActiveMQ integrated with JBoss. I
am able to add messages to the queue but they never seem to get picked up. I
understand that the connection needs to be started. Where should this be
done? And is it possible to make it the default behavior? I tried to st
17 matches
Mail list logo
