Search:

i worked around this issue by loading another spring context using generic application context and calling the proxy directly instead of "injecting" it using BPP ( bean post processors )

i hope to...

some "progress".
[1] the datasource gets the connection string to inject using a proxy object - which calls a service to get the string. the proxy itself uses BeanPostProcessor (in particular...

i have the following setup for aip-persistence-context file:



<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"...

thanks gary for the pointers!
i took a shortcut, in the init method i did this:


private void init()
{
isUsable = true;
amqpTemplate = new...

hi gary:
sorry about not putting code in code quotes.
the problem is this "stand-alone" library requires "pre-created" queues for a web-app. that's the whole reason to go into "programmatic"...

// this is the client that's pre-configured and pooled
import..
class SpringClient
{
...
...
private Queue replyQueue = null;

public SpringClient(CachingConnectionFactory...

Thanks Gary!
will look at HA/mirrored queues - however, at this point it might be too much(apologize in advance for non-quantitative adjective) to implement from an operations perspective.

i was...

thanks Gary! i do see rabbit correlationid gets mapped by the default converter.

VIP testing using two brokers:
i use rabbitTemplate and simpleMessageListenerContainer(listener) like this:
*...

Thank you much for this explanation.
-- as a feedback to you i tested several scenarios:
[1] multithreaded test with different timeouts to see if there are cross correlation mismatch ( passes great...

Hi Gary:
sorry to bother you, but i have one more question. if i'd want to have control over #of connections how would i do that?
let's say configuration params from user is :
[1] # of...

thanks Gary!
this goes a long way in improving what i have today.
many many thanks,
-monish

thanks gary! will do.
in the meanwhile if i were to use the template as a prototype bean for configuring a template or maybe use @Configuration is there a way i can do the same thing?
1. would like...

hi gary:
what would be the java programmatic way to do the following spring-context:
<rabbit:template id="amqpTemplate"
connection-factory="connectionFactory" reply-queue="replies">
...

thanks much gary for the pointers!
i did take the short cut and use a threadlocal variable w/ a check to see if the header contains spring_reply_correlation. works great!

some clarifications...

hi gary :
i have the following service configuration for the server with spring-amqp.

the problem is the client receives the message but errors out with

[SimpleAsyncTaskExecutor-1] DEBUG...

well, it seems to gary.
the code is really simple :
src/main/java/com/bear/EchoClient.java :
//removing imports for brevity..
public class EchoClient
{
private static Logger logger =...

Thanks much Gary!
that clears up a lot of things..however, how come the strange combination of spring-rabbit-1.0.0.RELEASE and spring-amqp-1.1.1.RELEASE works with reply-queues="replies" w/o...

sorry, not to explain the situation, this was posted on lists.rabbitmq from an older post.
http://rabbitmq.1065348.n5.nabble.com/Handle-Stale-Connections-on-Clients-td20687.html

here's the...

hi gary:
using spring-amqp 1.1.1.RELEASE it seems i have to change the version of spring-rabbit to 1.0.0.RELEASE

<dependency>
<groupId>org.springframework.amqp</groupId>...

spring-amqp module provides great apis to call rabbitMQ services.
however, when using rabbitTemplate.convertSendAndReceive or rabbitTemplate.sendAndReceive, i find a significant
1)overhead to...

Goal
we are building a service-container framework using spring-integration 2.1-GA (SI) as our platform.
the idea is to replace legacy services that currently use tuxedo.
a service in our context...