Я новичок в Spring и работаю над облачным приложением и пытаюсь использовать RabbitTemplate и RabbitMQ.
Я могу хранить данные в очереди, используя.
rabbitTemplate.convertAndSend(QUEUE_NAME, msg);
Но когда я получаю данные из той же очереди, используя
rabbitTemplate.receiveAndConvert(QUEUE_NAME)
Я получаю исключение как:
Мой код:
Мой контроллер:
@Configuration
@Profile("cloud")
public class RabbitConfig extends AbstractCloudConfig {
@Bean
public RabbitTemplate rabbitTemplate(){
CachingConnectionFactory cachingConnectionFactory = (CachingConnectionFactory)connectionFactory().rabbitConnectionFactory();
cachingConnectionFactory.setCacheMode(CachingConnectionFactory.CacheMode.CHANNEL);
RabbitTemplate rabbitTemplate = new RabbitTemplate(cachingConnectionFactory);
return rabbitTemplate;
}
}
ОБНОВЛЕНО RabbitConfig.java
@RestController
@RequestMapping("mq")
public class MainController {
@Autowired
private RabbitTemplate rabbitTemplate;
private static final String QUEUE_NAME = "testqueue";
@RequestMapping(value = "/putinq/{msg}",method = RequestMethod.PUT)
public String storeMessage(@PathVariable("msg") String msg){
String result = "";
rabbitTemplate.setQueue(QUEUE_NAME);
try {
rabbitTemplate.convertAndSend(QUEUE_NAME, msg); // no exception
Thread.sleep(3000);
Object object = rabbitTemplate.receiveAndConvert(QUEUE_NAME); // getting exception here
System.out.println("Received: "+object);
result = "success";
}catch(Exception ex){
ex.printStackTrace();
}
return result;
}
}
Я пытался найти это в Интернете, но все же не могу решить проблему. Долго борюсь с этим исключением, любая помощь приветствуется.
@Configuration
@Profile("cloud")
public class RabbitConfig extends AbstractCloudConfig {
private static final String QUEUE_NAME = "testqueue";
@Bean
public RabbitTemplate rabbitTemplate(){
CachingConnectionFactory cachingConnectionFactory = (CachingConnectionFactory)(connectionFactory().rabbitConnectionFactory());
System.out.println("------------------------ Rabbit mq template: " + cachingConnectionFactory.getCacheMode());
System.out.println("------------------------ cachingConnectionFactory.toString(): " + cachingConnectionFactory.toString());
cachingConnectionFactory.setCacheMode(CachingConnectionFactory.CacheMode.CHANNEL);
cachingConnectionFactory.setChannelCacheSize(25);
System.out.println("----------after set-------------- Rabbit mq template: " + cachingConnectionFactory.getCacheMode());
System.out.println("------------------------ cachingConnectionFactory.toString(): " + cachingConnectionFactory.getChannelCacheSize());
RabbitTemplate rabbitTemplate = new RabbitTemplate(cachingConnectionFactory);
System.out.println("------------------------ Rabbit mq template: " + rabbitTemplate);
return rabbitTemplate;
}
@Bean
public Queue myQueue() {
System.out.println("--------------@@---------- creating queue: ");
final boolean isDurable = true;
final boolean isExclusive = false;
final boolean autoDelete = false;
return new Queue(QUEUE_NAME, isDurable, isExclusive, autoDelete);
}
}
Получил решение!
Вам нужен
rabbitTemplate.convertAndSend(QUEUE_NAME, msg);
rabbitTemplate.receiveAndConvert(QUEUE_NAME)
CachingConnectionFactory cachingConnectionFactory = new CachingConnectionFactory();
cachingConnectionFactory.setUsername("");
cachingConnectionFactory.setPassword("");
cachingConnectionFactory.setVirtualHost("");
cachingConnectionFactory.setHost("");
cachingConnectionFactory.setPort(1);
cachingConnectionFactory.setRequestedHeartBeat(30);
cachingConnectionFactory.setConnectionTimeout(30000);
RabbitAdmin admin = new RabbitAdmin(cachingConnectionFactory());
Queue queue = new Queue(QUEUE_NAME);
admin.declareQueue(queue);
TopicExchange exchange = new TopicExchange(EXCHANGE_NAME);
admin.declareExchange(exchange); admin.declareBinding(BindingBuilder.bind(queue).to(exchange).with(QUEUE_NAME));
RabbitTemplate template = new RabbitTemplate(cachingConnectionFactory());
