diff --git a/ihmc-pub-sub/src/main/java/us/ihmc/pubsub/common/SerializedPayload.java b/ihmc-pub-sub/src/main/java/us/ihmc/pubsub/common/SerializedPayload.java index d9190450..614fd52a 100644 --- a/ihmc-pub-sub/src/main/java/us/ihmc/pubsub/common/SerializedPayload.java +++ b/ihmc-pub-sub/src/main/java/us/ihmc/pubsub/common/SerializedPayload.java @@ -126,7 +126,7 @@ public ByteBuffer getData() } @Override - public void close() throws Exception + public void close() { dataPointer.close(); } diff --git a/ihmc-pub-sub/src/main/java/us/ihmc/pubsub/impl/fastRTPS/FastRTPSSubscriber.java b/ihmc-pub-sub/src/main/java/us/ihmc/pubsub/impl/fastRTPS/FastRTPSSubscriber.java index 0faabf8f..d9348d71 100644 --- a/ihmc-pub-sub/src/main/java/us/ihmc/pubsub/impl/fastRTPS/FastRTPSSubscriber.java +++ b/ihmc-pub-sub/src/main/java/us/ihmc/pubsub/impl/fastRTPS/FastRTPSSubscriber.java @@ -18,7 +18,13 @@ import us.ihmc.idl.CDR; import us.ihmc.pubsub.TopicDataType; import us.ihmc.pubsub.attributes.SubscriberAttributes; -import us.ihmc.pubsub.common.*; +import us.ihmc.pubsub.common.ChangeKind; +import us.ihmc.pubsub.common.Guid; +import us.ihmc.pubsub.common.MatchingInfo; +import us.ihmc.pubsub.common.SampleIdentity; +import us.ihmc.pubsub.common.SampleInfo; +import us.ihmc.pubsub.common.SerializedPayload; +import us.ihmc.pubsub.common.Time; import us.ihmc.pubsub.subscriber.Subscriber; import us.ihmc.pubsub.subscriber.SubscriberListener; import us.ihmc.rtps.impl.fastRTPS.NativeParticipantImpl; @@ -320,7 +326,7 @@ void delete() { synchronized(destructorLock) { - payload.release(); + payload.close(); impl.delete(); nativeListenerImpl.delete(); impl = null;