You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by Domenico Francesco Bruscino <br...@gmail.com> on 2021/03/25 13:46:25 UTC
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, <To...@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();
> }
>
Re: EmbeddedJMS
Posted by Justin Bertram <jb...@apache.org>.
The class org.apache.activemq.artemis.jms.client.ActiveMQMessage implements
javax.jms.Message but not javax.jms.TextMessage. You'd need a
org.apache.activemq.artemis.jms.client.ActiveMQTextMessage to be able to
cast to javax.jms.TextMessage.
Given that you're sending a javax.jms.TextMessage and *not* receiving a
javax.jms.TextMessage back I'd guess there's another message on the queue.
I'd probably need a reproducer to investigate further.
Justin
On Thu, Mar 25, 2021 at 10:08 AM <To...@t-systems.com> wrote:
> Ok I see.
> What is wrong here in the jms client code?
>
> Connection connection =
> this.connectionFactory.createConnection();
> Session session = connection.createSession(false,
> Session.AUTO_ACKNOWLEDGE);
> Destination smtpQueue =
> session.createQueue(MailServerEmbeddedActiveMQServer.ACTIVE_MQ_SMTP_QUEUE);
> MessageProducer producer =
> session.createProducer(smtpQueue);
> MessageConsumer consumer =
> session.createConsumer(smtpQueue);
> connection.start();
> TextMessage message = session.createTextMessage("This is
> an order");
> producer.send(message);
> TextMessage receivedMessage = (TextMessage)
> consumer.receive(); --> HERE COMES THE EXCEPTION!!!!
> System.out.println("Got order: " +
> receivedMessage.getText());
>
> java.lang.ClassCastException: class
> org.apache.activemq.artemis.jms.client.ActiveMQMessage cannot be cast to
> class javax.jms.TextMessage
> (org.apache.activemq.artemis.jms.client.ActiveMQMessage and
> javax.jms.TextMessage are in unnamed module of loader 'app')
> at com.tsystems.gematik.kim.mailserver.mq
> .MailServerActiveMQJmsClient.sendJMSMessageToSmtpQueue(MailServerActiveMQJmsClient.java:47)
> at com.tsystems.gematik.kim.mailserver.mq
> .MailServerActiveMQClientTest.sendAndReceiveByteBufMessage(MailServerActiveMQClientTest.java:28)
> at
> java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native
> Method)
> at
> java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> at
> java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.base/java.lang.reflect.Method.invoke(Method.java:566)
> at
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
> at
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> at
> org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
> at
> org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
> at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
> at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
> at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
> at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
> at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
> at
> org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
> at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
> at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
> at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
> at
> org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:89)
> at
> org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:41)
> at
> org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:541)
> at
> org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:763)
> at
> org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:463)
> at
> org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:209)
>
>
> -----Ursprüngliche Nachricht-----
> Von: Justin Bertram <jb...@apache.org>
> Gesendet: Donnerstag, 25. März 2021 15:44
> An: users@activemq.apache.org
> Betreff: Re: EmbeddedJMS
>
> Yes. EmbeddedActiveMQ supports JMS. However, it will probably be helpful
> to read the short chapter on how JMS is mapped to core [1].
>
> The EmbeddedJMS class was removed because it was ultimately redundant.
> There's really nothing special about JMS support from the broker's point
> of view. The heaving lifting is done by the JMS & JNDI client
> implementations.
>
>
> Justin
>
> [1]
>
> http://activemq.apache.org/components/artemis/documentation/latest/jms-core-mapping.html
>
> On Thu, Mar 25, 2021 at 8:50 AM <To...@t-systems.com> wrote:
>
> > Hi Domenico,
> >
> > does "EmbeddedActiveMQ" support JMS?
> >
> > -----Ursprüngliche Nachricht-----
> > Von: Domenico Francesco Bruscino <br...@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/Embedde
> > dJMS.html
> > [2]
> >
> > https://activemq.apache.org/components/artemis/documentation/latest/em
> > bedding-activemq.html
> >
> > Regards,
> > Domenico
> >
> >
> > On Thu, 25 Mar 2021 at 14:28, <To...@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();
> > > }
> > >
> >
>
AW: EmbeddedJMS
Posted by To...@t-systems.com.
Ok I see.
What is wrong here in the jms client code?
Connection connection = this.connectionFactory.createConnection();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination smtpQueue = session.createQueue(MailServerEmbeddedActiveMQServer.ACTIVE_MQ_SMTP_QUEUE);
MessageProducer producer = session.createProducer(smtpQueue);
MessageConsumer consumer = session.createConsumer(smtpQueue);
connection.start();
TextMessage message = session.createTextMessage("This is an order");
producer.send(message);
TextMessage receivedMessage = (TextMessage) consumer.receive(); --> HERE COMES THE EXCEPTION!!!!
System.out.println("Got order: " + receivedMessage.getText());
java.lang.ClassCastException: class org.apache.activemq.artemis.jms.client.ActiveMQMessage cannot be cast to class javax.jms.TextMessage (org.apache.activemq.artemis.jms.client.ActiveMQMessage and javax.jms.TextMessage are in unnamed module of loader 'app')
at com.tsystems.gematik.kim.mailserver.mq.MailServerActiveMQJmsClient.sendJMSMessageToSmtpQueue(MailServerActiveMQJmsClient.java:47)
at com.tsystems.gematik.kim.mailserver.mq.MailServerActiveMQClientTest.sendAndReceiveByteBufMessage(MailServerActiveMQClientTest.java:28)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:566)
at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:89)
at org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:41)
at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:541)
at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:763)
at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:463)
at org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:209)
-----Ursprüngliche Nachricht-----
Von: Justin Bertram <jb...@apache.org>
Gesendet: Donnerstag, 25. März 2021 15:44
An: users@activemq.apache.org
Betreff: Re: EmbeddedJMS
Yes. EmbeddedActiveMQ supports JMS. However, it will probably be helpful to read the short chapter on how JMS is mapped to core [1].
The EmbeddedJMS class was removed because it was ultimately redundant.
There's really nothing special about JMS support from the broker's point of view. The heaving lifting is done by the JMS & JNDI client implementations.
Justin
[1]
http://activemq.apache.org/components/artemis/documentation/latest/jms-core-mapping.html
On Thu, Mar 25, 2021 at 8:50 AM <To...@t-systems.com> wrote:
> Hi Domenico,
>
> does "EmbeddedActiveMQ" support JMS?
>
> -----Ursprüngliche Nachricht-----
> Von: Domenico Francesco Bruscino <br...@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/Embedde
> dJMS.html
> [2]
>
> https://activemq.apache.org/components/artemis/documentation/latest/em
> bedding-activemq.html
>
> Regards,
> Domenico
>
>
> On Thu, 25 Mar 2021 at 14:28, <To...@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();
> > }
> >
>
Re: EmbeddedJMS
Posted by Justin Bertram <jb...@apache.org>.
Yes. EmbeddedActiveMQ supports JMS. However, it will probably be helpful to
read the short chapter on how JMS is mapped to core [1].
The EmbeddedJMS class was removed because it was ultimately redundant.
There's really nothing special about JMS support from the broker's point of
view. The heaving lifting is done by the JMS & JNDI client implementations.
Justin
[1]
http://activemq.apache.org/components/artemis/documentation/latest/jms-core-mapping.html
On Thu, Mar 25, 2021 at 8:50 AM <To...@t-systems.com> wrote:
> Hi Domenico,
>
> does "EmbeddedActiveMQ" support JMS?
>
> -----Ursprüngliche Nachricht-----
> Von: Domenico Francesco Bruscino <br...@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, <To...@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();
> > }
> >
>
AW: EmbeddedJMS
Posted by To...@t-systems.com.
Hi Domenico,
does "EmbeddedActiveMQ" support JMS?
-----Ursprüngliche Nachricht-----
Von: Domenico Francesco Bruscino <br...@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, <To...@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();
> }
>