look at message.setInputStream as you are using the Core API.
if you were using the JMS API there's a property that kind of wraps it
into the CoreMessage through the JMS Message.
Since you are using the core api directly look into that property.
Just implement an InputStream that will read from
create your session with (false, false, false)
this API is sort of internal... we do have some controls on flushes in
ACKs. if you set auto-ack to false, it would flush the acks before you
called commit.
On Fri, Mar 26, 2021 at 6:05 AM wrote:
>
> I'm using the following code to receive a
Hello-
ActiveMQ supports a number of different ways to authenticate users, so there is
not one command line tool to support all the combinations. If you are using the
users.properties or credentials.properties approach, you can simply append new
users to those text files.
For authorization,
hello:
i have a question in using activemq 5.15.9. when i want to create a new
user to connct the service ,
i find there is a way which need to edit the activemq.xml
configuration,and i feel this way is notconvenient
i want to know wheather there is other way to create user , for example
,use
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
On your case it would make sense if the streaming was not a file but a
biffer. I get it.
The optimization here wouldn’t be the copy but it would be not needintg to
duplicate the 500MB. We all thought you had a smaller buffer and did not
want the copy.
You can pass an InputStream as a property
Hello again!
I have a small question about the broker diagram.
I'm using a 3-node cluster, and each node also has a backup node. All nodes
have cluster-connections to all other nodes.
When the broker diagram is shown, this is the result (I replaced the labels
with my own shorter labels):
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 =
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
