genericmessageendpointimpl.java

java 文件下载器。可自定义

// Decompiled by Jad v1.5.8e2. Copyright 2001 Pavel Kouznetsov.
// Jad home page: http://kpdus.tripod.com/jad.html
// Decompiler options: packimports(3) fieldsfirst ansi space 
// Source File Name:   GenericMessageEndpointImpl.java

package org.gudy.azureus2.pluginsimpl.local.messaging;

import com.aelitis.azureus.core.networkmanager.ConnectionEndpoint;
import com.aelitis.azureus.core.networkmanager.impl.tcp.ProtocolEndpointTCP;
import com.aelitis.azureus.core.networkmanager.impl.udp.ProtocolEndpointUDP;
import java.net.InetSocketAddress;
import org.gudy.azureus2.plugins.messaging.generic.GenericMessageEndpoint;

public class GenericMessageEndpointImpl
	implements GenericMessageEndpoint
{

	private ConnectionEndpoint ce;

	public GenericMessageEndpointImpl(ConnectionEndpoint _ce)
	{
		ce = _ce;
	}

	public GenericMessageEndpointImpl(InetSocketAddress _ne)
	{
		ce = new ConnectionEndpoint(_ne);
	}

	public InetSocketAddress getNotionalAddress()
	{
		return ce.getNotionalAddress();
	}

	protected ConnectionEndpoint getConnectionEndpoint()
	{
		return ce;
	}

	public void addTCP(InetSocketAddress target)
	{
		ce.addProtocol(new ProtocolEndpointTCP(target));
	}

	public InetSocketAddress getTCP()
	{
		com.aelitis.azureus.core.networkmanager.ProtocolEndpoint pes[] = ce.getProtocols();
		for (int i = 0; i < pes.length; i++)
			if (pes[i] instanceof ProtocolEndpointTCP)
				return ((ProtocolEndpointTCP)pes[i]).getAddress();

		return null;
	}

	public void addUDP(InetSocketAddress target)
	{
		ce.addProtocol(new ProtocolEndpointUDP(target));
	}

	public InetSocketAddress getUDP()
	{
		com.aelitis.azureus.core.networkmanager.ProtocolEndpoint pes[] = ce.getProtocols();
		for (int i = 0; i < pes.length; i++)
			if (pes[i] instanceof ProtocolEndpointUDP)
				return ((ProtocolEndpointUDP)pes[i]).getAddress();

		return null;
	}
}