Uploaded image for project: 'ActiveMQ'
  1. ActiveMQ
  2. AMQ-6709

When are messageConsumed, messagePull and messageDelivered methods of BrokerFilter executed?


    • Type: Bug
    • Status: Closed
    • Priority: Minor
    • Resolution: Invalid
    • Affects Version/s: 5.14.1
    • Fix Version/s: None
    • Component/s: Broker
    • Labels:
    • Environment:

      MacOS 10.11.6


      I am developing a plugin to control the number of messages that AMQ can handle in a fix time, but, i don't know when the mentioned methods are executed. I run many tests, but in none i can see that the methods are executed. Can any one please explain to me if i need some special configuration in AMQ in order to used that methods in my plugin?

      I am using xbean to generate a custom XML for my plugin.

      This is the configuration in my AMQ:

      <broker xmlns="http://activemq.apache.org/schema/core" brokerName="instance-1" dataDirectory="${activemq.data}" schedulerSupport="true">
                  <policyEntry topic="&gt;">
                          <constantPendingMessageLimitStrategy limit="1000"/>
                  <policyEntry memoryLimit="100mb" producerFlowControl="false" queue="&gt;" prioritizedMessages="true" useCache="false">
                          <individualDeadLetterStrategy queuePrefix="DLQ." />
              <transactionsPlugin xmlns="http://commons.cm.com/schema/activemq">
                      <transactionsPolicy queue="jms.test.queue" transactions="10"/>
              <managementContext createConnector="false"/>
              <kahaDB directory="${activemq.data}/kahadb"/>
                      <memoryUsage percentOfJvmHeap="70"/>
                      <storeUsage limit="100 gb"/>
                      <tempUsage limit="50 gb"/>
              <networkConnector name="instance-2" uri="static:(tcp://" conduitSubscriptions="true" userName="admin" password="admin"/>
              <transportConnector name="openwire" uri="tcp://;wireFormat.maxFrameSize=104857600" updateClusterClients="true" rebalanceClusterClients="true" updateClusterClientsOnRemove="true"/>
              <bean xmlns="http://www.springframework.org/schema/beans" class="org.apache.activemq.hooks.SpringContextHook"/>

      I have tow Brokers configured in the same machine. Of course, only the brokerName and networkConnector it's different.

      This is my first time using JIRA platform, sorry if i select the incorrect issue type.




            • Assignee:
              felipe.olivares Felipe Olivares
            • Votes:
              0 Vote for this issue
              2 Start watching this issue


              • Created: