Fyi:
1953068645(decimal) = 74697665(hexadecimal) = "tive"(ascii text)
And "tive" is likely part of the string "ActiveMQ"?
e.
-----Oorspronkelijk bericht-----
Van: tobias.w...@t-systems.com <tobias.w...@t-systems.com>
Verzonden: maandag 22 maart 2021 16:41
Aan: users@activemq.apache.org
Onderwerp: AW: send message
EXTERNAL SENDER: Do not click any links or open any attachments unless you
trust the sender and know the content is safe.
EXPÉDITEUR EXTERNE: Ne cliquez sur aucun lien et n’ouvrez aucune pièce
jointe à moins qu’ils ne proviennent d’un expéditeur fiable, ou que vous ayez
l'assurance que le contenu provient d'une source sûre.
While sending / receiving a text message I get this
java.lang.IndexOutOfBoundsException: Error reading in simpleString,
length=1953068645 is greater than readableBytes=3
at
org.apache.activemq.artemis.api.core.SimpleString.readSimpleString(SimpleString.java:185)
at
org.apache.activemq.artemis.api.core.SimpleString.readSimpleString(SimpleString.java:173)
at
org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper.readStringInternal(ChannelBufferWrapper.java:113)
at
org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper.readString(ChannelBufferWrapper.java:98)
at
com.tsystems.gematik.kim.mailserver.mq.MailServerActiveMQClient.receiveTextMessageFromSmtpQueue(MailServerActiveMQClient.java:93)
at
com.tsystems.gematik.kim.mailserver.mq.MailServerActiveMQClientTest.sendAndReceive(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 <jbert...@apache.org>
Gesendet: Montag, 22. März 2021 16:34
An: users@activemq.apache.org
Betreff: Re: send message
What actually fails? Do you have a stack-trace?
Justin
On Mon, Mar 22, 2021 at 9:53 AM <tobias.w...@t-systems.com> wrote:
> I try to send and receive a netty ByteBuf message, but it fails.
> What I'm doing wrong here? I even don't know ist he mistake in sending
> or receiving!
> I was thinking to use the jms layer, but I'm receiving the data buffer
> throught a netty buffer and I want to avoid to convert the buffer to a
> byte array!
>
> public void sendMessageToSmtpQueue(ByteBuf buf) throws
> ActiveMQException {
> ClientSession session = this.sessionFactory.createSession();
> try {
> session.start();
> ClientMessage message = session.createMessage(true);
> message.getBodyBuffer().writeBytes(buf, 0,
> buf.readableBytes());
> ClientProducer producer =
> session.createProducer(ACTIVE_MQ_SMTP_QUEUE);
> producer.send(message);
> } finally {
> session.close();
> }
> }
>
> public ActiveMQBuffer receiveMessageFromSmtpQueue() throws
> ActiveMQException {
> ActiveMQBuffer result;
> ClientSession session = this.sessionFactory.createSession();
> try {
> session.start();
> ClientConsumer consumer =
> session.createConsumer(ACTIVE_MQ_SMTP_QUEUE);
> ClientMessage message = consumer.receive();
> result =
> ActiveMQBuffers.fixedBuffer(message.getBodyBufferSize());
> message.getBodyBuffer().readBytes(result);
> } finally {
> session.close();
> }
>
> return result;
> }
>
>
> 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));
>
> this.server = new ActiveMQServerImpl(this.configuration);
> this.server.start();
> }
>
