absorption expires on drinking milk

src/main/java/com/benjocraeft/sharehealth/HealthManager.java

@@ -87,6 +87,8 @@ public class HealthManager {
         absorptionManager.create(duration, amount);
     }
 
-
+    void onMilkBucketConsumed(){
+        absorptionManager.expire(false);
+    }
 
 }

src/main/java/com/benjocraeft/sharehealth/PlayerListeners.java

@@ -1,5 +1,6 @@
 package com.benjocraeft.sharehealth;
 
+import org.bukkit.Material;
 import org.bukkit.block.Block;
 import org.bukkit.entity.Entity;
 import org.bukkit.entity.Player;
@@ -9,6 +10,7 @@ import org.bukkit.event.entity.*;
 import org.bukkit.event.entity.EntityDamageEvent.DamageCause;
 import org.bukkit.event.entity.EntityDamageEvent.DamageModifier;
 import org.bukkit.event.entity.EntityRegainHealthEvent.RegainReason;
+import org.bukkit.event.player.PlayerItemConsumeEvent;
 import org.bukkit.event.player.PlayerJoinEvent;
 import org.bukkit.event.player.PlayerRespawnEvent;
 import org.bukkit.potion.PotionEffect;
@@ -130,4 +132,14 @@ public class PlayerListeners implements Listener{
             }
         }
     }
+
+    @EventHandler
+    public void onPlayerItemConsumed(final PlayerItemConsumeEvent event){
+        Player consumer = event.getPlayer();
+        if (!Sharehealth.GetPlayers().contains(consumer))
+            return;
+
+        if (event.getItem().getType().equals(Material.MILK_BUCKET))
+            Sharehealth.Instance.onMilkBucketConsumed();
+    }
 }

src/main/java/com/benjocraeft/sharehealth/Sharehealth.java

@@ -196,6 +196,12 @@ public class Sharehealth extends JavaPlugin {
         saveStatus();
     }
 
+    void onMilkBucketConsumed(){
+        healthManager.onMilkBucketConsumed();
+
+        saveStatus();
+    }
+
     private void failed(Player cause){
         if (isFailed)
             return;