i use durable subscription for a topic,i want to know how to set the max
number of the message that topic can keep when my cliend offline
thank you inadvance
--
View this message in context:
http://activemq.2283324.n4.nabble.com/how-to-set-the-number-of-message-that-topic-keeped-tp4706628.ht
I made a connection manager, since a connection is also used in a Pub/Sub
implementation. The connection manager simply holds the Connection, Session,
Username and Password(if they are required), and also ensures closure on
disposal. The missing code is is the Connect method
where the Factory is
I agree, redelivery of request messages means you're not acking them
correctly, and a change in behavior due to changing your redelivery policy
further proves the point. You say you're doing that, but I don't see it in
the code you posted. Am I missing something?
Tim
On Jan 28, 2016 1:43 PM, "Bj
For starters, you can configure your store limit to not be larger than the
free disk space in the directory to which you're writing, and/or write your
files to a disk that has more free space. (That depends in part on whether
you actually need 102.4 GB of persistent message storage; that sounds li
HI Justin, these are great suggestions. I'm all for cleaner code.
We had another instance of 3 messages not delivered.
I stopped the broker and executed this command:
artemis data print.
When I implemented it for the first time it printed a lot of information to
the console.
I th
although.. look at activemq for some comparison:
http://activemq.apache.org/persistence.html
and look at artemis for some comparison if that helps:
http://activemq.apache.org/artemis/docs/1.2.0/persistence.html
Persistence on messaging is usually to help you survive failures or paging.
On Th
I've checked the logs, I see no self connection.
I've changed TTL to 4, but i'm at home, i'll test tomorrow.
you're right, i'm not sure msf01 and ms02 are used to dequeue messages, i have
to check the logs next time.
i thought they were used because they are very close to the messages readers
(lo
Hello Together,
i build a embedded ActiveMQ with Spring and Maven in Eclipse.
Active MQ is running, and do his work.
KahaDB create in the Path /activemq-data/localhost/KahaDB/
localhost is the BrokerName. I test this. If I insert brokerName="embedded",
the Directory is
/activemq-data/embedded/Ka
>
> This is the user's forum for the Apache ActiveMQ project.
Whoops! Sorry. I'll go hit them up for info.
Thanks,
Tim
On Thu, Jan 28, 2016 at 4:39 PM, Clebert Suconic
wrote:
> >>find out if if it's necessary to enable message persistence in
> order to backup RabbitMQ message queues<<
>
> you
>>find out if if it's necessary to enable message persistence in
order to backup RabbitMQ message queues<<
you would be better asking that question on the RabbitMQ user's forum,
or whatever they provide you.
This is the user's forum for the Apache ActiveMQ project.
On Thu, Jan 28, 2016 at 4:36 P
Hey guys,
I need to find out if if it's necessary to enable message persistence in
order to backup RabbitMQ message queues. I believe it is, but I would like
some confirmation on that.
The reason I ask is that we are using RabbitMQ within a PaaS system known
as Pivotal Cloud Foundry. We'd like t
Some extra info: I managed to consistently get 1:1 in my request/response
code. I did this by changing the redeliverypolicy.maximumRedeliveries to 0.
I don't like this solution, but suggests that problem is acknowledgement of
messages. I have previously acknowledge in the code by calling the
msg.ac
In my opinion KahaDB is more stable at this point than LevelDB. KahaDB
does not seem to suffer from some of the corruption problems and other
issues that have been reported when using LevelDB.
On Thu, Jan 28, 2016 at 12:52 PM, James A. Robinson
wrote:
> Is KahaDB considered the more robust back
Is KahaDB considered the more robust backing store of the two options?
We just ran into a variation of
https://issues.apache.org/jira/browse/AMQ-5459
and I couldn't see any way to recover it.
Jim
Hi folks,
I'm trying to see a feature on ActiveMQ where a consumer wants to consume a
group of messages, but just really get the messages when all messages of the
group was sent to the broker. I know some other brokers like IBM MQ-Series have
this feature, an example here [1].
I was expecting
On 28 January 2016 at 08:51, motic wrote:
> Hi all,
> I'm new to this subject - so I hope my question is indeed relevant to this
> forum.
>
> I'm now starting to work on a new java application that is using wildfly10
> as it's application server.
> This application (and server) will run an embedde
You could potentially simplify your configuration code as follows...
Configuration config = new ConfigurationImpl()
.setJournalType(JournalType.NIO)
.setPersistenceEnabled(true)
.setSecurityEnabled(false)
.addAcceptorConfiguration(new
TransportConfiguration(InVMAcceptorFacto
No, I meant that I think the amidala broker shouldn't have a
networkConnector to amidala, and same for the other three.
You can't consume messages that have been forwarded to a second broker from
clients on a third broker because the default networkTTL for
networkConnectors is only 1. Increase it
Wait, those sound like two separate things.
When you say "messages aren't de-queued even though they are acknowledged
when our
system consumes them", are you saying that the broker isn't removing from
the store messages that have been acknowledged by all subscribers (active
or offline)? Because t
Hi guys!
I use ActiveMQ 5.9.1 and ZooZeeper 3.4.6
I would like to know, if it is possible to configure the following scenario:
when the failed node will be brought back online it must go into master mode
again instead of elected slave?
In other words I want to have the main broker that will be forc
Hi Tim
yes i'm having the same config (except the broker name change).
when you say not not send to itself you mean for example system write :
Regarding what happened:
I've posted some messa
Hi all,
I'm new to this subject - so I hope my question is indeed relevant to this
forum.
I'm now starting to work on a new java application that is using wildfly10
as it's application server.
This application (and server) will run an embedded device and not on PC.
The Linux image I'm using is cre
Hi All,
We are facing strange issue in one of our customer place.
We are using ActiveMQ v 5.11.1
Our broker uri in the 'active.xml' file is as below:-
/<"ssl://0.0.0.0:50020?maximumConnections=1&wireformat.maxFrameSize=104857600">/
Our client side uri is as below:-
/ConnectionFactory conn
Hi, Clebert.
thanks for suggestion. I will try this command next time when this happens.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/ActiveMQ-does-not-send-some-messages-tp4706550p4706579.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Hi guys,
We have a single broker test setup that is used by clients to retrieve data
from servers using a request-response pattern i.e.;
1) Client creates TempQueue
2) Client publishes messages on Topic with JMSReplyTo = TempQueue
3) Server consumes messages
4) Server creates dedicated message pub
25 matches
Mail list logo
