PandacubeFr/BungeeCord
1
0
Fork 0
Code Releases Activity

Update Server interface to remove depreceated methods

Browse Source
This commit is contained in:
md_5 2013-03-07 20:52:19 +11:00
parent 0afc52c130
commit 0f9cc76633
2 changed files with 8 additions and 37 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
api/src/main/java/net/md_5/bungee/api/connection/Server.java
View File

@ -24,14 +24,4 @@ public interface Server extends Connection
* @param data the data to send
*/
public abstract void sendData(String channel, byte[] data);
/**
* Asynchronously gets the current player count on this server.
*
* @param callback the callback to call when the count has been retrieved.
* @deprecated use the corresponding method in {@link ServerInfo} for
* clarity
*/
@Deprecated
public abstract void ping(Callback<ServerPing> callback);
}

35
proxy/src/main/java/net/md_5/bungee/ServerConnection.java
View File

@ -1,47 +1,28 @@
package net.md_5.bungee;
import io.netty.channel.Channel;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.util.Queue;
import java.util.concurrent.ConcurrentLinkedQueue;
import lombok.Getter;
import net.md_5.bungee.api.Callback;
import net.md_5.bungee.api.ServerPing;
import lombok.RequiredArgsConstructor;
import net.md_5.bungee.api.config.ServerInfo;
import net.md_5.bungee.api.connection.Server;
import net.md_5.bungee.packet.DefinedPacket;
import net.md_5.bungee.packet.Packet1Login;
import net.md_5.bungee.packet.PacketFAPluginMessage;
import net.md_5.bungee.packet.PacketStream;
/**
* Class representing a connection from the proxy to the server; ie upstream.
*/
public class ServerConnection extends GenericConnection implements Server
@RequiredArgsConstructor
public class ServerConnection implements Server
{
private final Channel ch;
@Getter
private final ServerInfo info;
public final Packet1Login loginPacket;
public Queue<DefinedPacket> packetQueue = new ConcurrentLinkedQueue<>();
public ServerConnection(Socket socket, ServerInfo info, PacketStream stream, Packet1Login loginPacket)
{
super( socket, stream );
this.info = info;
this.loginPacket = loginPacket;
}
@Getter
private final Packet1Login loginPacket;
@Override
public void sendData(String channel, byte[] data)
{
packetQueue.add( new PacketFAPluginMessage( channel, data ) );
}
@Override
public void ping(final Callback<ServerPing> callback)
{
getInfo().ping( callback );
ch.write( new PacketFAPluginMessage( channel, data ) );
}
@Override