1 files changed, 1 insertions, 2 deletions
diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/message/internal/InternalMessageMetaDataType.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/message/internal/InternalMessageMetaDataType.java
index 613d4d15d8..7fc13fb40b 100644
--- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/message/internal/InternalMessageMetaDataType.java
+++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/message/internal/InternalMessageMetaDataType.java
@@ -46,9 +46,8 @@ public class InternalMessageMetaDataType implements MessageMetaDataType<Internal
     @Override
     public InternalMessageMetaData createMetaData(final ByteBuffer buf)
     {
-        try
+        try(ObjectInputStream is = new ObjectInputStream(new ByteBufferInputStream(buf)))
         {
-            ObjectInputStream is = new ObjectInputStream(new ByteBufferInputStream(buf));
             InternalMessageMetaData metaData = (InternalMessageMetaData) is.readObject();
             return metaData;
         }