Skip to content

Commit

Permalink
backend deps upkeep
Browse files Browse the repository at this point in the history
  • Loading branch information
querwurzel committed Nov 7, 2023
1 parent 8de196c commit dfedb77
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 25 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@ public MessagingClient messagingClient(
return new MessagingClient(clientSessionFactory, consumerThreadPool, producerThreadPool);
}

@Bean(destroyMethod = "stop")
@Bean(initMethod = "start", destroyMethod = "stop")
public EmbeddedActiveMQ activeMqServer() throws Exception {
org.apache.activemq.artemis.core.config.Configuration config = new ConfigurationImpl();

Expand All @@ -52,6 +52,7 @@ public EmbeddedActiveMQ activeMqServer() throws Exception {
AddressSettings addressSettings = new AddressSettings()
.setDefaultAddressRoutingType(RoutingType.ANYCAST)
.setDefaultQueueRoutingType(RoutingType.ANYCAST)
.setEnableIngressTimestamp(false)
.setExpiryDelay(TimeUnit.DAYS.toMillis(7));

config.addAddressConfiguration(addr);
Expand Down Expand Up @@ -82,30 +83,8 @@ public EmbeddedActiveMQ activeMqServer() throws Exception {
var embeddedActiveMQ = new EmbeddedActiveMQ();
embeddedActiveMQ.setConfiguration(config);

return embeddedActiveMQ.start();
return embeddedActiveMQ;
}
/*
@Bean
ConnectionFactory activeMqConnectionFactory() throws Exception {
JGroupsFileBroadcastEndpointFactory jGroupsFileBroadcastEndpointFactory = new JGroupsFileBroadcastEndpointFactory();
jGroupsFileBroadcastEndpointFactory.setChannelName("binpastesChannel");
DiscoveryGroupConfiguration discoveryGroupConfiguration = new DiscoveryGroupConfiguration();
discoveryGroupConfiguration.setName("binpastesGroup");
discoveryGroupConfiguration.setBroadcastEndpointFactory(jGroupsFileBroadcastEndpointFactory);
new TransportConfiguration();
ServerLocator serverLocator = new ServerLocatorImpl(false, discoveryGroupConfiguration);
ServerLocator serverLocator1 = ActiveMQClient.createServerLocator("vm://0");
ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory("vm://0", null, null);
//activeMQConnectionFactory.setUs
return activeMQConnectionFactory;
}*/

@Bean(initMethod = "init", destroyMethod = "dispose")
public Scheduler consumerThreadPool() {
Expand Down
2 changes: 1 addition & 1 deletion pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,7 @@
<spring-boot-bom.version>3.1.5</spring-boot-bom.version>
<junixsocket.version>2.8.2</junixsocket.version>
<flyway.version>9.22.3</flyway.version>
<artemis.version>2.31.0</artemis.version>
<artemis.version>2.31.2</artemis.version>
<r2dbc-mysql.version>1.0.5</r2dbc-mysql.version>
<r2dbc-mariadb.version>1.1.4</r2dbc-mariadb.version>
</properties>
Expand Down

0 comments on commit dfedb77

Please sign in to comment.