Thank you for the answer, I will go this way!
Is it neccessary to create the session as "transacted=true" in case I want to
be sure that the ByteBuf was stored sucessfully?
session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);
How can I check with the JMS client if a parti
A example would be great!
-Ursprüngliche Nachricht-
Von: Clebert Suconic
Gesendet: Freitag, 26. März 2021 13:26
An: users@activemq.apache.org
Betreff: Re: send message
On your case it would make sense if the streaming was not a file but a biffer.
I get it.
The optimization here would
I'm using the following code to receive a message.
After a successful read I was expecting that the message is remove from the
queue?!
But the message was still in the queue.
How can I read a message and remove it?
String result;
ClientSession session = this.sessionFactory.createSess
Not he application is a kind of custom mail server and the messages can reach
up to 500mb and are received via tcp and a netty smtp handler.
Therefore I have a netty direct buffer already and don't want bring the huge
messages back into the jvm.
-Ursprüngliche Nachricht-
Von: Clebert Suc
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
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
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
I want to use the jms layer, but I've a netty application and I want to write
the ByteBuf mostly efficent to the queue.
I think it makes no sense to convert it back from a native buffer into a byte
array or stream and tunnel this throught the jvm!
Is there a way to use a ByteBuf with jms?
-
Same Issue!
public void sendMessageToSmtpQueue(String text) throws
ActiveMQException {
ClientSession session = this.sessionFactory.createSession();
try {
session.start();
ClientMessage message = session.createM
getDataBuffer gives same result! Already tried!
-Ursprüngliche Nachricht-
Von: Clebert Suconic
Gesendet: Dienstag, 23. März 2021 03:19
An: users@activemq.apache.org
Betreff: Re: send message
Why you don't use the JMS API for this?
or if you really want to use the core API, use the getR
I was thinking to use the JMS API, but I need to store a netty ByteBuf tot he
queue and I thougth the core api is more effective, isn't it?!
-Ursprüngliche Nachricht-
Von: Clebert Suconic
Gesendet: Dienstag, 23. März 2021 03:19
An: users@activemq.apache.org
Betreff: Re: send message
Wh
The stack trace is correct
-Ursprüngliche Nachricht-
Von: Justin Bertram
Gesendet: Montag, 22. März 2021 17:01
An: users@activemq.apache.org
Betreff: Re: send message
The stack-trace indicates you're invoking the "readString" method on line
93 of MailServerActiveMQClient.java, but I don
When I send/receive I ByteBuf Message my test fails saying the input/output is
not equal!
public void sendMessageToSmtpQueue(ByteBuf buf) throws
ActiveMQException {
ClientSession session = this.sessionFactory.createSession();
try {
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.ac
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
I`m using Apache James as message producer and I don`t want to change the code
if it is not necessary.
I found this example, there they are using Blobmessage, right?
https://github.com/apache/activemq-artemis/blob/master/tests/activemq5-unit-tests/src/test/java/org/apache/activemq/blob/FTPBlobTes
I got the message on the broker side that "BLOB types are not supported yet",
just wondering why? Is this a bug?
I`m running on Windows 10 with JDK 1.8.xxx with latest activemq artemis version.
2020-03-10 13:55:29,822 WARN [org.apache.activemq.artemis.core.server] Errors
occurred during the buf
19 matches
Mail list logo
