Github user franz1981 commented on a diff in the pull request: https://github.com/apache/activemq-artemis/pull/1793#discussion_r165330750 --- Diff: artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireProtocolManagerFactory.java --- @@ -46,6 +48,11 @@ public ProtocolManager createProtocolManager(final ActiveMQServer server, return BeanSupport.setData(new OpenWireProtocolManager(this, server), parameters); } + @Override + public Persister<Message>[] getPersister() { + return new Persister[]{OpenWireMessagePersister.getInstance()}; --- End diff -- Cache it if possible instead of allocating it each time
---