INNER CODE UNIT · Java
broker
dopplertask/dopplertask · backend/src/main/java/com/dopplertask/dopplertask/Application.java:27
public BrokerService broker() throws Exception {
final BrokerService broker = new BrokerService();
broker.addConnector("tcp://localhost:61616");
broker.addConnector("vm://localhost");
broker.addConnector("stomp://localhost:61613");
broker.addConnector("ws://0.0.0.0:61614");
broker.setPersistent(false);
return broker;
}
@Bean
public JmsListenerContainerFactory<?> jmsFactory(ConnectionFactory connectionFactory,
DefaultJmsListenerContainerFactoryConfigurer configurer) {
DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
factory.setConcurrency("50");
factory.setSessionTransacted(true);
// This provides all boot's default to this factory, including the message converter
configurer.configure(factory, connectionFactory);