Ggtcf

Is divide-by-zero a security vulnerability?

“I had a flat in the centre of town, but I didn’t like living there, so …”

How do you make a gun that shoots melee weapons and/or swords?

How spaceships determine each other's mass in space?

Are there other characters in the Star Wars universe who had damaged bodies and needed to wear an outfit like Darth Vader?

If nine coins are tossed, what is the probability that the number of heads is even?

Sundering Titan and basic normal lands and snow lands

Deal the cards to the players

In the world of The Matrix, what is "popping"?

Why doesn't "adolescent" take any articles in "listen to adolescent agonising"?

Did Amazon pay $0 in taxes last year?

Should we avoid writing fiction about historical events without extensive research?

Are small insurances worth it

How do we objectively assess if a dialogue sounds unnatural or cringy?

School performs periodic password audits. Is my password compromised?

Convert an array of objects to array of the objects' values

Why are special aircraft used for the carriers in the United States Navy?

Computing the volume of a simplex-like object with constraints

Replacing tantalum capacitor with ceramic capacitor for Op Amps

Is this nominative case or accusative case?

Why won't the strings command stop?

Is it a Cyclops number? "Nobody" knows!

Does the in-code argument passing conventions used on PDP-11's have a name?

Where do you go through passport control when transiting through another Schengen airport on your way out of the Schengen area?

Spring AMQP and RetryTemplate

0

I have a RabbitTemplate configured with a RetryTemplate in the following way:

@Bean 
public RabbitTemplate myRabbitTemplate() 

 RabbitTemplate template = new RabbitTemplate(myConnectionFactory());
 template.setChannelTransacted(true);

 template.setMessageConverter(myMessageConverter());
 template.setReplyAddress(MY_RESPONSE_PRIVATE_QUEUE);
 template.setQueue(MY_RESPONSE_PRIVATE_QUEUE);
 template.setMandatory(true);
 template.setEncoding("UTF-8");
 template.setExchange(MY_REQUEST_EXCHANGE);
 template.setBeforePublishPostProcessors(new MyMessagePostProcessor());

 RetryTemplate retryTemplate = new RetryTemplate();
 ExponentialBackOffPolicy backOffPolicy = new ExponentialBackOffPolicy();
 backOffPolicy.setInitialInterval(500);
 backOffPolicy.setMultiplier(10.0);
 backOffPolicy.setMaxInterval(10000);
 retryTemplate.setBackOffPolicy(backOffPolicy);
 template.setRetryTemplate(retryTemplate);
 template.setAfterReceivePostProcessors(new DelegatingDecompressingPostProcessor());

 return template;

Doing connection tests using TCPView and WireShark, I think that in one of the connection cuts one of the sent messages has been duplicated (I guess by the configuration of the RetryTemplate).

Throughout the project there have been other connection failures and errors (ShutdownSignalException, TimeOut ...) and we have never detected duplicate messages.
Under what circumstances is the sending of the message re-attempted?

Thank you

spring-amqp

share|improve this question

asked yesterday

jandresjandres

98112

• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  You may have an exception already after send confirmation from the RabbitMQ. Or you may use request-reply feature some weird way... We need to see a simple project to play with to determine an issue...
  
  – Artem Bilan
  yesterday
  

  
  
  
  

add a comment | 

0

I have a RabbitTemplate configured with a RetryTemplate in the following way:

@Bean 
public RabbitTemplate myRabbitTemplate() 

 RabbitTemplate template = new RabbitTemplate(myConnectionFactory());
 template.setChannelTransacted(true);

 template.setMessageConverter(myMessageConverter());
 template.setReplyAddress(MY_RESPONSE_PRIVATE_QUEUE);
 template.setQueue(MY_RESPONSE_PRIVATE_QUEUE);
 template.setMandatory(true);
 template.setEncoding("UTF-8");
 template.setExchange(MY_REQUEST_EXCHANGE);
 template.setBeforePublishPostProcessors(new MyMessagePostProcessor());

 RetryTemplate retryTemplate = new RetryTemplate();
 ExponentialBackOffPolicy backOffPolicy = new ExponentialBackOffPolicy();
 backOffPolicy.setInitialInterval(500);
 backOffPolicy.setMultiplier(10.0);
 backOffPolicy.setMaxInterval(10000);
 retryTemplate.setBackOffPolicy(backOffPolicy);
 template.setRetryTemplate(retryTemplate);
 template.setAfterReceivePostProcessors(new DelegatingDecompressingPostProcessor());

 return template;

Doing connection tests using TCPView and WireShark, I think that in one of the connection cuts one of the sent messages has been duplicated (I guess by the configuration of the RetryTemplate).

Throughout the project there have been other connection failures and errors (ShutdownSignalException, TimeOut ...) and we have never detected duplicate messages.
Under what circumstances is the sending of the message re-attempted?

Thank you

spring-amqp

share|improve this question

asked yesterday

jandresjandres

98112

• 
  
  
  

  
  

  
  
  
  
  
  

  
  
  You may have an exception already after send confirmation from the RabbitMQ. Or you may use request-reply feature some weird way... We need to see a simple project to play with to determine an issue...
  
  – Artem Bilan
  yesterday
  

  
  
  
  

add a comment | 

I have a RabbitTemplate configured with a RetryTemplate in the following way:

@Bean 
public RabbitTemplate myRabbitTemplate() 

 RabbitTemplate template = new RabbitTemplate(myConnectionFactory());
 template.setChannelTransacted(true);

 template.setMessageConverter(myMessageConverter());
 template.setReplyAddress(MY_RESPONSE_PRIVATE_QUEUE);
 template.setQueue(MY_RESPONSE_PRIVATE_QUEUE);
 template.setMandatory(true);
 template.setEncoding("UTF-8");
 template.setExchange(MY_REQUEST_EXCHANGE);
 template.setBeforePublishPostProcessors(new MyMessagePostProcessor());

 RetryTemplate retryTemplate = new RetryTemplate();
 ExponentialBackOffPolicy backOffPolicy = new ExponentialBackOffPolicy();
 backOffPolicy.setInitialInterval(500);
 backOffPolicy.setMultiplier(10.0);
 backOffPolicy.setMaxInterval(10000);
 retryTemplate.setBackOffPolicy(backOffPolicy);
 template.setRetryTemplate(retryTemplate);
 template.setAfterReceivePostProcessors(new DelegatingDecompressingPostProcessor());

 return template;

Doing connection tests using TCPView and WireShark, I think that in one of the connection cuts one of the sent messages has been duplicated (I guess by the configuration of the RetryTemplate).

Throughout the project there have been other connection failures and errors (ShutdownSignalException, TimeOut ...) and we have never detected duplicate messages.
Under what circumstances is the sending of the message re-attempted?

Thank you

spring-amqp

share|improve this question

asked yesterday

jandresjandres

98112

@Bean 
public RabbitTemplate myRabbitTemplate() 

 RabbitTemplate template = new RabbitTemplate(myConnectionFactory());
 template.setChannelTransacted(true);

 template.setMessageConverter(myMessageConverter());
 template.setReplyAddress(MY_RESPONSE_PRIVATE_QUEUE);
 template.setQueue(MY_RESPONSE_PRIVATE_QUEUE);
 template.setMandatory(true);
 template.setEncoding("UTF-8");
 template.setExchange(MY_REQUEST_EXCHANGE);
 template.setBeforePublishPostProcessors(new MyMessagePostProcessor());

 RetryTemplate retryTemplate = new RetryTemplate();
 ExponentialBackOffPolicy backOffPolicy = new ExponentialBackOffPolicy();
 backOffPolicy.setInitialInterval(500);
 backOffPolicy.setMultiplier(10.0);
 backOffPolicy.setMaxInterval(10000);
 retryTemplate.setBackOffPolicy(backOffPolicy);
 template.setRetryTemplate(retryTemplate);
 template.setAfterReceivePostProcessors(new DelegatingDecompressingPostProcessor());

 return template;

share|improve this question

asked yesterday

jandresjandres

98112

share|improve this question

asked yesterday

jandresjandres

98112

asked yesterday

jandresjandres

98112

asked yesterday

jandresjandres

98112