messagestreamencoderadapter.java

来自「java 文件下载器。可自定义」· Java 代码 · 共 40 行

// 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:   MessageStreamEncoderAdapter.java

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

import com.aelitis.azureus.core.networkmanager.RawMessage;
import com.aelitis.azureus.core.peermanager.messaging.Message;
import com.aelitis.azureus.core.peermanager.messaging.MessageStreamEncoder;
import org.gudy.azureus2.pluginsimpl.local.network.RawMessageAdapter;

// Referenced classes of package org.gudy.azureus2.pluginsimpl.local.messaging:
//			MessageAdapter

public class MessageStreamEncoderAdapter
	implements MessageStreamEncoder
{

	private final org.gudy.azureus2.plugins.messaging.MessageStreamEncoder plug_encoder;

	public MessageStreamEncoderAdapter(org.gudy.azureus2.plugins.messaging.MessageStreamEncoder plug_encoder)
	{
		this.plug_encoder = plug_encoder;
	}

	public RawMessage[] encodeMessage(Message message)
	{
		org.gudy.azureus2.plugins.messaging.Message plug_msg;
		if (message instanceof MessageAdapter)
			plug_msg = ((MessageAdapter)message).getPluginMessage();
		else
			plug_msg = new MessageAdapter(message);
		org.gudy.azureus2.plugins.network.RawMessage raw_plug = plug_encoder.encodeMessage(plug_msg);
		return (new RawMessage[] {
			new RawMessageAdapter(raw_plug)
		});
	}
}