ActiveSubscriber(ClientConfiguration cfg,
AbstractHChannelManager channelManager,
TopicSubscriber ts,
PubSubData op,
PubSubProtocol.SubscriptionPreferences preferences,
org.jboss.netty.channel.Channel channel,
HChannel hChannel)
Construct an active subscriber instance.
|
ClientChannelPipelineFactory(ClientConfiguration cfg,
AbstractHChannelManager channelManager) |
HChannelHandler(ClientConfiguration cfg,
AbstractHChannelManager channelManager,
Map<PubSubProtocol.OperationType,AbstractResponseHandler> handlers) |
HChannelImpl(InetSocketAddress host,
AbstractHChannelManager channelManager)
Create a un-established channel with provided target host .
|
HChannelImpl(InetSocketAddress host,
AbstractHChannelManager channelManager,
ClientChannelPipelineFactory pipelineFactory) |
HChannelImpl(InetSocketAddress host,
org.jboss.netty.channel.Channel channel,
AbstractHChannelManager channelManager,
ClientChannelPipelineFactory pipelineFactory)
Create a HChannel with an established netty channel.
|
NonSubscriptionChannelPipelineFactory(ClientConfiguration cfg,
AbstractHChannelManager channelManager) |