Hi, I was wondering that one or the other might find the attached plugin useful. It allows to enforce the persistence mode for incoming messages.
This case comes handy, whenever the connecting clients are not respecting (or forgetting) message policies. In our case, one client connected and sent persistent messages with TTL=0 to a queue without having a consuming client. This caused the broker to pile up the messages until it died due to missing space (disk & mem). Our general policy for the brokers, however, is to handle only non-persistent messages. Therefore I wrote this little plugin to protect us from "nasty" clients. Please let me know what should be improved. Regards, Felix http://www.nabble.com/file/p24758167/ForcePersistencyModeBroker.java ForcePersistencyModeBroker.java http://www.nabble.com/file/p24758167/ForcePersistencyModeBrokerPlugin.java ForcePersistencyModeBrokerPlugin.java -- View this message in context: http://www.nabble.com/New-Broker-plugin-%3A-Enforcing-persistence-mode-tp24758167p24758167.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
