Search:

Amqp functionality is working perfectly in my application except when I wish to shut it down. I configure amqp entirely in xml and do not see how to stop the thread that it is working on. I know...

I am wondering if I have some redundancies in the way I have set up my project. I have created a working jar for my application, easier to run a test locally for me. It is completely self contained...

Using the new 1.0.0.RELEASE

Have not really changed much code. Using a basic fan-out exchange much like the example in the doc, producing messages works fine. In my consumer, again just like the...

I have commented out every actual redis action in my code and the cpu still hits 100% which I assume to mean that it is something with the Jedis lib or config. I have checked the Jedis google group...

Here is my config:
<bean id="redisTemplate" class="org.springframework.data.redis.core.StringRedisTemplate"
p:connection-factory-ref="redisConnectionFactory">
<property name="ValueSerializer"...

Probably missing something simple but

I am publishing to several channels, for instance quotes:ibm, quotes:bac.

When I subscribe to quotes:* I am getting the data but I really need to know the...

Costin,

Thanks for the reply. Well I am connected to my redis instance via redis-cli and was not getting anything when issuing get commands. I have since discovered the MONITOR command and...

trying to simply get redis working with my spring project. I am connected to a redis to go instance.

When trying a simple:
redisTemplate.opsForValue().set("key", "val");

it is not updating...

sorry guys I know this is frustrating and I really appreciate the help. Looks like spring-rabbit 1.0.0.RC2 may not pull amqp-client:

version for both is 1.0.0.RC2

<dependency>...

I was thinking this yesterday. Should I even use spring-rabbit? If so which version? I tried to removed the spring-rabbit dependency but it also seems to remove the amqp-client-2.5.0.jar. I cannot...

Again I would bet this is more to do with my abilities than a general problem. I was trying different combinations of version for both spring-amqp and spring-rabbit. I did however create a JIRA bug

I hate to come back but having another config related error. This is the last missing piece of my whole app. I am trying to produce to a fanout exchange. This is my amqp/rabbit related config:
...

Thanks for the response. The only reason that I tried the integration was because I kept getting the unknown channel errors, everything was working fine but they were just annoying. I am still...

i suspect I need an outbound channel for my return messaging?

I am almost positive it is my fault but I had not problems with JMS/ActiveMQ for some reason this rabbit stuff is throwing me for a loop

here is my config:
<?xml version="1.0" encoding="UTF-8"?>...

so now that I got through all that, I am now getting an unknown channel 3 error, and still getting 2 consumers per app.

Is this a result of me just not knowing what I am doing or just the early...

interesting

rabbitmqctl list_queues consumers does list 2 however only one app is running. Is this a residual effect from another app on same queue or is declaring a queue along with an inbound...

Ok thank you guys for all of your help. App is running but now with this new inbound channel adapter I seem to be getting only every other message. Since its an even number and consistent I would...

STS v2.6

To confirm I am using spring-integration-amqp.2.1.0-BUILD-SNAPSHOT

in the config package is the 2.0.xsd

in the definitions it defines queue-names as required

So I have verified that I am now dependent on spring-amqp.1.0.0.RC2 rather than the snapshot. However I am still experiencing the same issue.

For the inbound channel adapter

queue-names...

Mark,

Were you able to push the new release, I just got back from vacation and do not see it.

Thanks,
Bobby

Dave,

Thanks for the replies. Have the amqp issue resolved but still get a validation error when using queue-name in the channel adapter tag.

queue-names works and I have a reference to...

it seems that if I restart the rabbitmq server the error goes away.

so I am wondering if this is what happened...
in testing I may have initially created the queue without declaring it durable. ...

ok so this is what I am getting:
WARN [SimpleAsyncTaskExecutor-1] (SimpleMessageListenerContainer.java:527) - Consumer raised exception, processing can restart if the connection factory supports it...

Dave,

Thanks for the reply. I am getting closer. And I apologize for the documentation comment, it sounded rude, not my intention. I am more on the novice end...However I did get the...