Search:

Hello Gary,

Apologies for not using the correct terminology, I realize the difference between a queue and a channel.

Regarding the limit on the queue, I can see now how this limit is irrelevant...

Hello Gary,

When I said that "capacity is ignored", I meant that my gateway method is able to post millions of messages to the channel. It doesn't stop when there are 100 messages on the queue.
...

Hello all,

I have a scenario where a client application sends messages to activeMQ using Spring Integration. I have some processors that consume these messages, but they are not quite fast enough...

I don't see how adding another generic type would make Spring more happy?

Anyway I solved the problem by creating a new class that extends CaseInsensitiveMap, and provides a type for the generic...

Given an xml context containing this:


<util:map id="myMap" map-class="com.myproduct.CaseInsensitiveMap">
<entry key="key" value="value"></entry>
</util:map>

And the CaseInsensitiveMap...

I didn't realize that caching connections meant that the connection would keep the process running after the main code was done. I imagined it was sort of like caching database connections.

The...

Hi all,

I have a JMS client that uses Spring Integration and an <int-jms:outbound-gateway> to talk to an ActiveMQ server. My client code is able to send a request to the gateway proxy, and get a...

Yes I have the management ui running, it's been quite handy.

There might be some configuration differences, but really these are two Rabbit instances that are basically installed and run without...

Hello all,

I have a small test client which I use to send messages to RabbitMQ. Messages are sent using a spring created gateway proxy, which sends the message to a channel, which the gateway then...

Okay, I fixed the above by introducing an Admin interface in my code, which is then initialized by a messaging-specific implementation. This way the coupling is minimal.

If I have to get a reference to the RabbitAdmin instance in my code, in order to call initialize() on it, I'll be creating a fairly strong coupling to RabbitMQ inside my code. I would like to avoid...

Well, this would require the customer/end user to do some manual configuration which we want to avoid if at all possible. But even if we decided to add the configuration to rabbitmq.config, it would...

Because when the application starts up, RabbitMQ may not yet be available. The application is designed to start up and allow a user, through interaction, to start the messaging services.

I just...

Hi,

I have an application that consumes messages from RabbitMQ. Here is the basic XML configuration:

<rabbit:admin connection-factory="connectionFactory" auto-startup="false" />
...

Hello Mark,

Option 1 sounds like it might be the best way to go. But how do I get the messages back to the producer/client? In my scenario the client has a Future<xxx> that it obtained from the...

I should also mention that I am using an async gateway, meaning the client servicegateway is defined to return a Future<x>. As the client is waiting in the future.get() call, the server is running...

Hello,

I have a client talking to a server via Spring Integration/AMQP and RabbitMQ. The client uses an amqp:outbound-gateway and the server uses an amqp:inbound-gateway configuration.

When the...

Well, if I make the assumption that what I get back from a <rabbit:connection-factory> is an instance of AbstractConnectionFactory (the ConnectionFactory has no setter methods), I can set the...

(The reason for having both an rcf declaration and the rabbit:connection-factory tag is because I wanted the convenience and readability of the namespace tag but also the ability to set explicit...

The rcf instance is initialized like this:


<bean id="rcf" class="com.rabbitmq.client.ConnectionFactory">
<property name="requestedHeartbeat" value="10"/>
</bean>
...

Thanks Mark, now my gateway doesn't start automatically.

However, I also need to be able to set the connection parameters before starting the gateway. When I use the following Spring config, it...

Hello,

I have an Amqp gateway server application based on a mix of annotations and xml configuration. As soon as the application starts and Spring gets initialized, it connects to RabbitMQ and my...

Okay, this turned out to be much simpler than I made it into .. :-)

I just added "myproduct-key-*" as mapped-request-headers on the inbound and outbound gateways and voila everything worked as I...

Hello all,

I have a scenario where a client is posting a message to RabbitMQ which my server is getting though the use of an <int-amqp:inbound-gateway>.

I have been using the...

Adding the mapping solved the problem. I guess everything is working as it should now, thanks for your help Gary and Mark :-)