incomingmessagequeueimpl.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:   IncomingMessageQueueImpl.java

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

import com.aelitis.azureus.core.networkmanager.IncomingMessageQueue;
import java.util.HashMap;
import org.gudy.azureus2.plugins.messaging.Message;
import org.gudy.azureus2.plugins.network.IncomingMessageQueueListener;
import org.gudy.azureus2.pluginsimpl.local.messaging.MessageAdapter;

public class IncomingMessageQueueImpl
	implements org.gudy.azureus2.plugins.network.IncomingMessageQueue
{

	private final IncomingMessageQueue core_queue;
	private final HashMap registrations = new HashMap();

	protected IncomingMessageQueueImpl(IncomingMessageQueue core_queue)
	{
		this.core_queue = core_queue;
	}

	public void registerListener(final IncomingMessageQueueListener listener)
	{
		com.aelitis.azureus.core.networkmanager.IncomingMessageQueue.MessageQueueListener core_listener = new com.aelitis.azureus.core.networkmanager.IncomingMessageQueue.MessageQueueListener() {

			final IncomingMessageQueueListener val$listener;
			final IncomingMessageQueueImpl this$0;

			public boolean messageReceived(com.aelitis.azureus.core.peermanager.messaging.Message message)
			{
				if (message instanceof MessageAdapter)
					return listener.messageReceived(((MessageAdapter)message).getPluginMessage());
				else
					return listener.messageReceived(new MessageAdapter(message));
			}

			public void protocolBytesReceived(int byte_count)
			{
				listener.bytesReceived(byte_count);
			}

			public void dataBytesReceived(int byte_count)
			{
				listener.bytesReceived(byte_count);
			}

			
			{
				this$0 = IncomingMessageQueueImpl.this;
				listener = incomingmessagequeuelistener;
				super();
			}
		};
		registrations.put(listener, core_listener);
		core_queue.registerQueueListener(core_listener);
	}

	public void deregisterListener(IncomingMessageQueueListener listener)
	{
		com.aelitis.azureus.core.networkmanager.IncomingMessageQueue.MessageQueueListener core_listener = (com.aelitis.azureus.core.networkmanager.IncomingMessageQueue.MessageQueueListener)registrations.remove(listener);
		if (core_listener != null)
			core_queue.cancelQueueListener(core_listener);
	}

	public void notifyOfExternalReceive(Message message)
	{
		if (message instanceof MessageAdapter)
		{
			core_queue.notifyOfExternallyReceivedMessage(((MessageAdapter)message).getCoreMessage());
			return;
		} else
		{
			core_queue.notifyOfExternallyReceivedMessage(new MessageAdapter(message));
			return;
		}
	}

	public int getPercentDoneOfCurrentMessage()
	{
		return core_queue.getPercentDoneOfCurrentMessage();
	}
}