genericmessageencoder.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:   GenericMessageEncoder.java

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

import com.aelitis.azureus.core.networkmanager.RawMessage;
import com.aelitis.azureus.core.networkmanager.impl.RawMessageImpl;
import com.aelitis.azureus.core.peermanager.messaging.Message;
import com.aelitis.azureus.core.peermanager.messaging.MessageStreamEncoder;
import org.gudy.azureus2.core3.util.DirectByteBuffer;
import org.gudy.azureus2.core3.util.DirectByteBufferPool;

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

public class GenericMessageEncoder
	implements MessageStreamEncoder
{

	public GenericMessageEncoder()
	{
	}

	public RawMessage[] encodeMessage(Message _message)
	{
		GenericMessage message = (GenericMessage)_message;
		DirectByteBuffer payload = message.getPayload();
		if (message.isAlreadyEncoded())
		{
			return (new RawMessage[] {
				new RawMessageImpl(message, new DirectByteBuffer[] {
					payload
				}, 1, true, new Message[0])
			});
		} else
		{
			DirectByteBuffer header = DirectByteBufferPool.getBuffer((byte)1, 4);
			header.putInt((byte)11, payload.remaining((byte)11));
			header.flip((byte)11);
			return (new RawMessage[] {
				new RawMessageImpl(message, new DirectByteBuffer[] {
					header, payload
				}, 1, true, new Message[0])
			});
		}
	}
}