public PooledParallelSender() 
{
      
        super();
}

 public synchronized  void connect() throws IOException 
{
        this.connected = true;
        super.connect();
}

 public synchronized  void disconnect() 
{
        this.connected = false;
        super.disconnect();
}

 public DataSender getNewDataSender() 
{
        try {
            ParallelNioSender sender = new ParallelNioSender();
            sender.transferProperties(this,sender);
            return sender;
        } catch ( IOException x ) {
            throw new RuntimeException("Unable to open NIO selector.",x);
        }
}

 public  void sendMessage(Member[] destination,
    ChannelMessage message) throws ChannelException 
{
        if ( !connected ) throw new ChannelException("Sender not connected.");
        ParallelNioSender sender = (ParallelNioSender)getSender();
        if (sender == null) {
            ChannelException cx = new ChannelException("Unable to retrieve a data sender, time out error.");
            for (int i = 0; i <  destination.length; i++) cx.addFaultyMember(destination[i], new NullPointerException("Unable to retrieve a sender from the sender pool"));
            throw cx;
        } else {
            try {
                sender.sendMessage(destination, message);
                sender.keepalive();
            } finally {
                if (!connected) disconnect();
                returnSender(sender);
            }
        }
}