Ниже приведен код, который выполняется во время запуска сервера, когда метод приема MessageProcessor продолжает прослушивать тему шины Tibco.Проблема здесь в том, что несколько запросов отбрасываются, и это не воспроизводимо.Это случается иногда.Любая идея, почему верблюд отбрасывает эти запросы от шины?
reg.put("MessageProcessor", new MessageProcessor());
// Create the context and configure route
context = new DefaultCamelContext(reg);
context.addRoutes(new RouteBuilder() {
public void configure() {
from(
"bus://"
+ subject
+ "?poolSize="
+ poolSize
+ "&account=busaccount&credentials=buscredentials&policy=buspolicy")
.threads(Integer.parseInt(minPoolSize),
Integer.parseInt(maxPoolSize))
.to("bean:MessageProcessor?method=receive(Exchange)");
}
});
// Start listening
context.start();
Примечание: мы догадались, что отбрасывание происходит, когда количество запросов> maxPoolSize настроено выше.Похоже, это не причина.Мы изменили short-running-threads
и long-running-threads
в Jboss standalone.xml, однако его значение (200) не совпадает с maxPoolSize (50).Как вы думаете, они должны быть одинаковыми?Мы хотим знать, почему верблюд отбрасывает эти запросы от Bus и исправляет это.