You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "Timothy Bish (JIRA)" <ji...@apache.org> on 2017/06/20 21:43:00 UTC
[jira] [Closed] (AMQ-6709) When are messageConsumed, messagePull
and messageDelivered methods of BrokerFilter executed?
[ https://issues.apache.org/jira/browse/AMQ-6709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Timothy Bish closed AMQ-6709.
-----------------------------
Resolution: Invalid
This is a topic best discussed on the users mailing list.
> When are messageConsumed, messagePull and messageDelivered methods of BrokerFilter executed?
> --------------------------------------------------------------------------------------------
>
> Key: AMQ-6709
> URL: https://issues.apache.org/jira/browse/AMQ-6709
> Project: ActiveMQ
> Issue Type: Bug
> Components: Broker
> Affects Versions: 5.14.1
> Environment: MacOS 10.11.6
> Reporter: Felipe Olivares
> Priority: Minor
> Labels: plugin
>
> 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:
> {code:xml}
> <broker xmlns="http://activemq.apache.org/schema/core" brokerName="instance-1" dataDirectory="${activemq.data}" schedulerSupport="true">
> <destinationPolicy>
> <policyMap>
> <policyEntries>
> <policyEntry topic=">">
> <pendingMessageLimitStrategy>
> <constantPendingMessageLimitStrategy limit="1000"/>
> </pendingMessageLimitStrategy>
> </policyEntry>
> <policyEntry memoryLimit="100mb" producerFlowControl="false" queue=">" prioritizedMessages="true" useCache="false">
> <deadLetterStrategy>
> <individualDeadLetterStrategy queuePrefix="DLQ." />
> </deadLetterStrategy>
> <pendingQueuePolicy>
> <storeCursor/>
> </pendingQueuePolicy>
> </policyEntry>
> </policyEntries>
> </policyMap>
> </destinationPolicy>
> <plugins>
> <transactionsPlugin xmlns="http://commons.cm.com/schema/activemq">
> <transactionsPolicies>
> <transactionsPolicy queue="jms.test.queue" transactions="10"/>
> </transactionsPolicies>
> </transactionsPlugin>
> </plugins>
> <managementContext>
> <managementContext createConnector="false"/>
> </managementContext>
> <persistenceAdapter>
> <kahaDB directory="${activemq.data}/kahadb"/>
> </persistenceAdapter>
> <systemUsage>
> <systemUsage>
> <memoryUsage>
> <memoryUsage percentOfJvmHeap="70"/>
> </memoryUsage>
> <storeUsage>
> <storeUsage limit="100 gb"/>
> </storeUsage>
> <tempUsage>
> <tempUsage limit="50 gb"/>
> </tempUsage>
> </systemUsage>
> </systemUsage>
> <networkConnectors>
> <networkConnector name="instance-2" uri="static:(tcp://127.0.0.1:62616)" conduitSubscriptions="true" userName="admin" password="admin"/>
> </networkConnectors>
> <transportConnectors>
> <transportConnector name="openwire" uri="tcp://0.0.0.0:61616?maximumConnections=1000&wireFormat.maxFrameSize=104857600" updateClusterClients="true" rebalanceClusterClients="true" updateClusterClientsOnRemove="true"/>
> </transportConnectors>
> <shutdownHooks>
> <bean xmlns="http://www.springframework.org/schema/beans" class="org.apache.activemq.hooks.SpringContextHook"/>
> </shutdownHooks>
> </broker>
> {code}
> 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.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)