Hi Domenico,

does "EmbeddedActiveMQ" support JMS?

-----Ursprüngliche Nachricht-----
Von: Domenico Francesco Bruscino <bruscin...@gmail.com> 
Gesendet: Donnerstag, 25. März 2021 14:46
An: users@activemq.apache.org
Betreff: Re: EmbeddedJMS

Hi Tobias,

EmbeddedJMS was deprecated in favor of
org.apache.activemq.artemis.core.server.embedded.EmbeddedActiveMQ,
according the java doc[1]. You can find further detail in the ActiveMQ Artemis 
documentation[2].

[1]
https://activemq.apache.org/components/artemis/documentation/javadocs/javadoc-latest/org/apache/activemq/artemis/jms/server/embedded/EmbeddedJMS.html
[2]
https://activemq.apache.org/components/artemis/documentation/latest/embedding-activemq.html

Regards,
Domenico


On Thu, 25 Mar 2021 at 14:28, <tobias.w...@t-systems.com> wrote:

> I saw that EmbeddedJMS is deprecated.
> Is there already a successor class which can be used instead of?
> I'm currently using this code to start activemq artemis server and I 
> want now to implement/start the jms server too.
>
>        public void startServer() throws Exception {
>              this.configuration = new ConfigurationImpl();
>              this.configuration.addAcceptorConfiguration("in-vm",
> ACTIVE_MQ_EMBEDDED_SERVER_URL);
>              this.configuration.setPersistenceEnabled(true);
>              this.configuration.setSecurityEnabled(false);
>              this.configuration.addQueueConfiguration(new
> QueueConfiguration(ACTIVE_MQ_SMTP_QUEUE));
>
>              JMSConfiguration jmsConfig = new JMSConfigurationImpl();
>
>              TransportConfiguration connectorConfig = new 
> TransportConfiguration(InVMAcceptorFactory.class.getName());
>              ConnectionFactoryConfiguration cfConfig = new 
> ConnectionFactoryConfigurationImpl();
>        jmsConfig.getConnectionFactoryConfigurations().add(cfConfig);
>
>              JMSQueueConfiguration queueConfig = new 
> JMSQueueConfigurationImpl();
>               jmsConfig.getQueueConfigurations().add(queueConfig);
>
>              this.server = new ActiveMQServerImpl(this.configuration);
>              this.server.start();
>        }
>
>        public void stopServer() throws Exception {
>              if (this.server != null)
>                     this.server.stop();
>        }
>

Reply via email to