diff options
Diffstat (limited to 'qpid/tools/src/java')
| -rw-r--r-- | qpid/tools/src/java/qpid-broker-plugins-management-qmf2/src/main/java/org/apache/qpid/server/qmf2/QmfManagementPluginImpl.java | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/qpid/tools/src/java/qpid-broker-plugins-management-qmf2/src/main/java/org/apache/qpid/server/qmf2/QmfManagementPluginImpl.java b/qpid/tools/src/java/qpid-broker-plugins-management-qmf2/src/main/java/org/apache/qpid/server/qmf2/QmfManagementPluginImpl.java index d7ea0971d4..7efd1962f1 100644 --- a/qpid/tools/src/java/qpid-broker-plugins-management-qmf2/src/main/java/org/apache/qpid/server/qmf2/QmfManagementPluginImpl.java +++ b/qpid/tools/src/java/qpid-broker-plugins-management-qmf2/src/main/java/org/apache/qpid/server/qmf2/QmfManagementPluginImpl.java @@ -220,6 +220,16 @@ public class QmfManagementPluginImpl extends AbstractPluginAdapter<QmfManagement getBroker().getEventLogger().message(ManagementConsoleMessages.STOPPED(OPERATIONAL_LOGGING_NAME)); } + @Override + protected void onClose() + { + super.onClose(); + if (_agent != null) + { + _agent.close(); + } + } + /** * Accessor to retrieve the connectionURL attribute. * @return the JMS connectionURL of the Plugin. |