diff options
| author | Sam Anthony <sam@samanthony.xyz> | 2024-11-15 17:08:36 -0500 |
|---|---|---|
| committer | Sam Anthony <sam@samanthony.xyz> | 2024-11-15 17:08:36 -0500 |
| commit | 3f63da76ab16450694d84dd29503d2e7ec0198c8 (patch) | |
| tree | 9b6717ad0ae589da90a0aae96578627965bce0c0 /src/main/java/derms/net/rmulticast/Retransmit.java | |
| parent | 050942608e70d01e5833fe5d0e5019071f95c68b (diff) | |
| download | soen423-3f63da76ab16450694d84dd29503d2e7ec0198c8.zip | |
reliable multicast: MessagePayload interface
Diffstat (limited to 'src/main/java/derms/net/rmulticast/Retransmit.java')
| -rw-r--r-- | src/main/java/derms/net/rmulticast/Retransmit.java | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/src/main/java/derms/net/rmulticast/Retransmit.java b/src/main/java/derms/net/rmulticast/Retransmit.java index 3f2fdbb..32e8d51 100644 --- a/src/main/java/derms/net/rmulticast/Retransmit.java +++ b/src/main/java/derms/net/rmulticast/Retransmit.java @@ -3,14 +3,13 @@ package derms.net.rmulticast; import derms.net.ConcurrentMulticastSocket; import derms.net.Packet; -import java.io.Serializable; import java.net.DatagramPacket; import java.net.SocketAddress; import java.util.concurrent.BlockingQueue; import java.util.logging.Logger; /** Retransmit dropped messages. */ -class Retransmit<T extends Serializable & Hashable> implements Runnable { +class Retransmit<T extends MessagePayload> implements Runnable { private final BlockingQueue<Message<T>> retransmissions; private final ConcurrentMulticastSocket outSock; private final SocketAddress group; |