39 lines
710 B
D
39 lines
710 B
D
module renaissance.server.messagemanager;
|
|
|
|
import renaissance.server.server : Server;
|
|
|
|
public enum QUEUE_DEFAULT_SIZE = 100;
|
|
|
|
public class Queue
|
|
{
|
|
private size_t maxSize;
|
|
|
|
public this(size_t maxSize = QUEUE_DEFAULT_SIZE)
|
|
{
|
|
|
|
}
|
|
}
|
|
|
|
public class MessageManager
|
|
{
|
|
private Server server;
|
|
|
|
private Queue sendQueue;
|
|
private Queue receiveQueue;
|
|
|
|
private this()
|
|
{
|
|
// Initialize the queues (send+receive)
|
|
this.sendQueue = new Queue();
|
|
this.receiveQueue = new Queue();
|
|
}
|
|
|
|
public static MessageManager create(Server server)
|
|
{
|
|
MessageManager manager = new MessageManager();
|
|
manager.server = server;
|
|
|
|
|
|
return manager;
|
|
}
|
|
} |