public MulticastTransport(OpenWireFormat wireFormat,
    URI remoteLocation) throws UnknownHostException, IOException 
{
        super(wireFormat, remoteLocation);
}

 protected  void bind(DatagramSocket socket,
    SocketAddress localAddress) throws SocketException 
{

}

 protected InetSocketAddress createAddress(URI remoteLocation) throws UnknownHostException, IOException 
{
        this.mcastAddress = InetAddress.getByName(remoteLocation.getHost());
        this.mcastPort = remoteLocation.getPort();
        return new InetSocketAddress(mcastAddress, mcastPort);
}

 protected CommandChannel createCommandChannel() throws IOException 
{
        socket = new MulticastSocket(mcastPort);
        socket.setLoopbackMode(loopBackMode);
        socket.setTimeToLive(timeToLive);
        LOG.debug("Joining multicast address: " + getMulticastAddress());
        socket.joinGroup(getMulticastAddress());
        socket.setSoTimeout((int)keepAliveInterval);
        return new CommandDatagramSocket(this, getWireFormat(), getDatagramSize(), getTargetAddress(), createDatagramHeaderMarshaller(), getSocket());
}

 protected DatagramHeaderMarshaller createDatagramHeaderMarshaller() 
{
        return new MulticastDatagramHeaderMarshaller("udp://dummyHostName:" + getPort());
}

 protected  void doStop(ServiceStopper stopper) throws Exception 
{
        super.doStop(stopper);
        if (socket != null) {
            try {
                socket.leaveGroup(getMulticastAddress());
            } catch (IOException e) {
                stopper.onException(this, e);
            }
            socket.close();
        }
}

 public long getKeepAliveInterval() 
{
        return keepAliveInterval;
}

 protected InetAddress getMulticastAddress() 
{
        return mcastAddress;
}

 protected String getProtocolName() 
{
        return "Multicast";
}

 protected String getProtocolUriScheme() 
{
        return "multicast://";
}

 protected MulticastSocket getSocket() 
{
        return socket;
}

 public int getTimeToLive() 
{
        return timeToLive;
}

 public boolean isLoopBackMode() 
{
        return loopBackMode;
}

 public  void setKeepAliveInterval(long keepAliveInterval) 
{
        this.keepAliveInterval = keepAliveInterval;
}

 public  void setLoopBackMode(boolean loopBackMode) 
{
        this.loopBackMode = loopBackMode;
}

 protected  void setSocket(MulticastSocket socket) 
{
        this.socket = socket;
}

 public  void setTimeToLive(int timeToLive) 
{
        this.timeToLive = timeToLive;
}