You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by emw <en...@gmail.com> on 2019/02/05 10:56:55 UTC
Unwanted (unsolicited) messages from ActiveMQ.Advisory.MasterBroker
Hello everyone,
I have a consumer (spring default message listener) of queue mqtt.values.>
ActiveMq version is 5.15.8
Every time the listener starts it receive a message from topic
ActiveMQ.Advisory.MasterBroker
Is that right? Can you help me in order to not receiving such a message.
Meybe it is important, in the configuration I have virtualTopic from mqtt.>
to queue with prefic mqtt.values.
<destinationInterceptors>
<virtualDestinationInterceptor>
<virtualDestinations>
<virtualTopic name="mqtt.>" prefix="mqtt.values." selectorAware="false"/>
</virtualDestinations>
</virtualDestinationInterceptor>
</destinationInterceptors>
This is the .toString() of the message:
ActiveMQMessage {commandId = 0, responseRequired = false, messageId =
ID:<HIDDEN>-43596-1549363680962-1:1:0:0:1, originalDestination =
topic://ActiveMQ.Advisory.MasterBroker, originalTransactionId = null,
producerId = ID:<HIDDEN>-43596-1549363680962-1:1:0:0, destination =
queue://mqtt.values.>, transactionId = null, expiration = 0, timestamp = 0,
arrival = 0, brokerInTime = 1549363681468, brokerOutTime = 1549363786316,
correlationId = null, replyTo = null, persistent = false, type = Advisory,
priority = 0, groupID = null, groupSequence = 0, targetConsumerId = null,
compressed = false, userID = null, content = null, marshalledProperties =
org.apache.activemq.util.ByteSequence@20833b33, dataStructure = null,
redeliveryCounter = 0, size = 0, properties = {originBrokerName=localhost,
originBrokerId=ID:<HIDDEN>-43596-1549363680962-0:1,
originBrokerURL=nio+ssl://<HIDDEN>:61616}, readOnlyProperties = true,
readOnlyBody = true, droppable = false, jmsXGroupFirstForConsumer = false}
--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
Re: Unwanted (unsolicited) messages from ActiveMQ.Advisory.MasterBroker
Posted by Tim Bain <tb...@alumni.duke.edu>.
OK, thanks for letting us know.
Tim
On Wed, May 29, 2019, 4:03 AM emw <en...@gmail.com> wrote:
> Hello,
> I tried and tried and tried and I could not replicate the issues.
> I modified and I could not rescue the configuration that exploited the
> issue.
> So let's say it is not an issue.
> I will tell here and save the conf. if I'll get the issue again.
>
>
>
> --
> Sent from:
> http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
>
Re: Unwanted (unsolicited) messages from
ActiveMQ.Advisory.MasterBroker
Posted by emw <en...@gmail.com>.
Hello,
I tried and tried and tried and I could not replicate the issues.
I modified and I could not rescue the configuration that exploited the
issue.
So let's say it is not an issue.
I will tell here and save the conf. if I'll get the issue again.
--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
Re: Unwanted (unsolicited) messages from ActiveMQ.Advisory.MasterBroker
Posted by Tim Bain <tb...@alumni.duke.edu>.
So wait, I understood you to say that the problem was the trailing .> on
the name of your topicName element, but in the working example
configuration you gave, the trailing .> is still there. What did I
misunderstand?
Tim
On Thu, Feb 7, 2019, 8:21 AM emw <enrico.maschietto.work@gmail.com wrote:
> I did some tests and outcome is that it is neither a matter of point 1) nor
> point 2).
> The issue arises when listening queue when ends with .>
> I changed my topics and queues namespace and now I'm not getting advisory
> message anymore.
> Moreover I noted that in the activemq webconsole when advisory message is
> sent
> the 'Number Of Pending Messages' is -1!!!
>
> At this point do think an issues must be submitted?
>
> --
> My new working configuration is (note that I changes prefix into cloud. but
> again it is not a matter of preifx but a matter of .> at the end of
> listening queue):
> listener listens to cloud.mqtt.*.values
> and activemq.xml is
> <destinationInterceptors>
> <virtualDestinationInterceptor>
> <virtualDestinations>
> <virtualTopic name="mqtt.>" prefix="cloud." selectorAware="false"/>
> </virtualDestinations>
> </virtualDestinationInterceptor>
> </destinationInterceptors>
>
>
>
>
> --
> Sent from:
> http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
>
Re: Unwanted (unsolicited) messages from
ActiveMQ.Advisory.MasterBroker
Posted by emw <en...@gmail.com>.
I did some tests and outcome is that it is neither a matter of point 1) nor
point 2).
The issue arises when listening queue when ends with .>
I changed my topics and queues namespace and now I'm not getting advisory
message anymore.
Moreover I noted that in the activemq webconsole when advisory message is
sent
the 'Number Of Pending Messages' is -1!!!
At this point do think an issues must be submitted?
--
My new working configuration is (note that I changes prefix into cloud. but
again it is not a matter of preifx but a matter of .> at the end of
listening queue):
listener listens to cloud.mqtt.*.values
and activemq.xml is
<destinationInterceptors>
<virtualDestinationInterceptor>
<virtualDestinations>
<virtualTopic name="mqtt.>" prefix="cloud." selectorAware="false"/>
</virtualDestinations>
</virtualDestinationInterceptor>
</destinationInterceptors>
--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
Re: Unwanted (unsolicited) messages from ActiveMQ.Advisory.MasterBroker
Posted by Tim Bain <tb...@alumni.duke.edu>.
I notice a few things that are different from the configuration in the
documentation (https://activemq.apache.org/virtual-destinations.html). I'm
not sure if these would cause the behavior you're seeing, but it might be
worth changing them to see if that changes the behavior.
1. Your prefix contains no wildcards, whereas the example uses a * to allow
multiple consumer groups. I'm not sure that that would make any difference,
but it's probably worth a quick check to make sure there's not something
that's breaking without the wildcard.
2. Your virtual topic wildcard (mqtt.>) matches against your queue prefix,
whereas the example shows a prefix that doesn't match. Theoretically, that
shouldn't matter since one is for queues and one is for topics, but it's
worth changing quickly to see if it makes a difference due to something I'm
not considering.
Again, I don't know that either of these should make a difference, but
please eliminate them as possible explanations before the next step, which
would be to submit a bug in JIRA for the problem.
Thanks,
Tim
On Tue, Feb 5, 2019, 7:24 AM emw <enrico.maschietto.work@gmail.com wrote:
> Hello everyone,
> I have a consumer (spring default message listener) of queue mqtt.values.>
>
> ActiveMq version is 5.15.8
>
> Every time the listener starts it receive a message from topic
> ActiveMQ.Advisory.MasterBroker
>
> Is that right? Can you help me in order to not receiving such a message.
>
> Meybe it is important, in the configuration I have virtualTopic from mqtt.>
> to queue with prefic mqtt.values.
> <destinationInterceptors>
> <virtualDestinationInterceptor>
> <virtualDestinations>
>
> <virtualTopic name="mqtt.>" prefix="mqtt.values."
> selectorAware="false"/>
>
> </virtualDestinations>
> </virtualDestinationInterceptor>
> </destinationInterceptors>
>
>
> This is the .toString() of the message:
> ActiveMQMessage {commandId = 0, responseRequired = false, messageId =
> ID:<HIDDEN>-43596-1549363680962-1:1:0:0:1, originalDestination =
> topic://ActiveMQ.Advisory.MasterBroker, originalTransactionId = null,
> producerId = ID:<HIDDEN>-43596-1549363680962-1:1:0:0, destination =
> queue://mqtt.values.>, transactionId = null, expiration = 0, timestamp = 0,
> arrival = 0, brokerInTime = 1549363681468, brokerOutTime = 1549363786316,
> correlationId = null, replyTo = null, persistent = false, type = Advisory,
> priority = 0, groupID = null, groupSequence = 0, targetConsumerId = null,
> compressed = false, userID = null, content = null, marshalledProperties =
> org.apache.activemq.util.ByteSequence@20833b33, dataStructure = null,
> redeliveryCounter = 0, size = 0, properties = {originBrokerName=localhost,
> originBrokerId=ID:<HIDDEN>-43596-1549363680962-0:1,
> originBrokerURL=nio+ssl://<HIDDEN>:61616}, readOnlyProperties = true,
> readOnlyBody = true, droppable = false, jmsXGroupFirstForConsumer = false}
>
>
>
>
> --
> Sent from:
> http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
>