From dfedb777d66fc8664d49bc5e8a9fdf7af7cd2580 Mon Sep 17 00:00:00 2001 From: querwurzel <> Date: Tue, 7 Nov 2023 19:31:25 +0100 Subject: [PATCH] backend deps upkeep --- .../business/tracking/MessagingConfig.java | 27 +++---------------- pom.xml | 2 +- 2 files changed, 4 insertions(+), 25 deletions(-) diff --git a/backend/src/main/java/com/github/binpastes/paste/business/tracking/MessagingConfig.java b/backend/src/main/java/com/github/binpastes/paste/business/tracking/MessagingConfig.java index 331f931..f1ba16f 100644 --- a/backend/src/main/java/com/github/binpastes/paste/business/tracking/MessagingConfig.java +++ b/backend/src/main/java/com/github/binpastes/paste/business/tracking/MessagingConfig.java @@ -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(); @@ -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); @@ -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() { diff --git a/pom.xml b/pom.xml index 9560f0c..65d41d4 100644 --- a/pom.xml +++ b/pom.xml @@ -46,7 +46,7 @@ 3.1.5 2.8.2 9.22.3 - 2.31.0 + 2.31.2 1.0.5 1.1.4