com.baidu.brpc.client.channel

Class ChannelPooledObjectFactory

java.lang.Object

org.apache.commons.pool2.BasePooledObjectFactory<io.netty.channel.Channel>

com.baidu.brpc.client.channel.ChannelPooledObjectFactory

All Implemented Interfaces:

org.apache.commons.pool2.PooledObjectFactory<io.netty.channel.Channel>

public class ChannelPooledObjectFactory
extends org.apache.commons.pool2.BasePooledObjectFactory<io.netty.channel.Channel>

Channel pool for the rpc client. Base on apache.commons.pool.

Constructor Summary

Constructors

Constructor and Description
ChannelPooledObjectFactory(BrpcChannel channelGroup, String ip, int port)

Method Summary

Modifier and Type	Method and Description
io.netty.channel.Channel	create()
void	destroyObject(org.apache.commons.pool2.PooledObject<io.netty.channel.Channel> p)
boolean	validateObject(org.apache.commons.pool2.PooledObject<io.netty.channel.Channel> p)
org.apache.commons.pool2.PooledObject<io.netty.channel.Channel>	wrap(io.netty.channel.Channel obj)

Methods inherited from class org.apache.commons.pool2.BasePooledObjectFactory

activateObject, makeObject, passivateObject

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ChannelPooledObjectFactory

public ChannelPooledObjectFactory(BrpcChannel channelGroup,
                                  String ip,
                                  int port)

Method Detail

create

public io.netty.channel.Channel create()
                                throws Exception

Specified by:

create in class org.apache.commons.pool2.BasePooledObjectFactory<io.netty.channel.Channel>

Throws:

Exception

wrap

public org.apache.commons.pool2.PooledObject<io.netty.channel.Channel> wrap(io.netty.channel.Channel obj)

Specified by:

wrap in class org.apache.commons.pool2.BasePooledObjectFactory<io.netty.channel.Channel>

destroyObject

public void destroyObject(org.apache.commons.pool2.PooledObject<io.netty.channel.Channel> p)
                   throws Exception

Specified by:

destroyObject in interface org.apache.commons.pool2.PooledObjectFactory<io.netty.channel.Channel>

Overrides:

destroyObject in class org.apache.commons.pool2.BasePooledObjectFactory<io.netty.channel.Channel>

Throws:

Exception

validateObject

public boolean validateObject(org.apache.commons.pool2.PooledObject<io.netty.channel.Channel> p)

Specified by:

validateObject in interface org.apache.commons.pool2.PooledObjectFactory<io.netty.channel.Channel>

Overrides:

validateObject in class org.apache.commons.pool2.BasePooledObjectFactory<io.netty.channel.Channel>