I assumed the data was already on a file.
If you passed the file name. The receiver would receive a message where
you could either do the opposite. (Pass a file name to steam. Or just
receive steaming)
At that size of message the optimization of the copy between your buffer
and a byte array mak
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 *n
So you mean I should save the ByteBuffer by myself to a file?
--> and pass it over the property that would stream the file directly.
(Available on core only)
What do you mean? I understand that I shall pass the name of the file via a
message property, right?
How would the receiver side looks lik
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(MailServerEmbe
Sending a message this large will make it to be converted as a large
stream and saved as a file on the server anyways...
The copy between ByteBuffer and a byte array would become irrelevant
at this point.
If you want to send a large message this big, you could save it to a
file, and pass it over
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
Hi Domenico,
does "EmbeddedActiveMQ" support JMS?
-Ursprüngliche Nachricht-
Von: Domenico Francesco Bruscino
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.c
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-l
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.configu
What are you talking about?
I want to send byte buffers with the size up to 500MB to a queue!
What do you mean with string and micro optimization!
The core api fails in my test already with sending/receiving a simple string,
yes, a simple test!
Does it make sense to have a 500mb native netty buffe
10 matches
Mail list logo
