Package | Description |
---|---|
org.apache.hedwig.client | |
org.apache.hedwig.client.benchmark | |
org.apache.hedwig.client.handlers | |
org.apache.hedwig.client.netty |
A Netty based Hedwig client implementation.
|
org.apache.hedwig.client.netty.impl | |
org.apache.hedwig.client.netty.impl.multiplex | |
org.apache.hedwig.client.netty.impl.simple | |
org.apache.hedwig.client.ssl |
Constructor and Description |
---|
HedwigClient(ClientConfiguration cfg)
Construct a hedwig client object.
|
HedwigClient(ClientConfiguration cfg,
org.jboss.netty.channel.ChannelFactory socketFactory)
Construct a hedwig client object, using a preexisting socket factory.
|
Constructor and Description |
---|
HedwigBenchmark(ClientConfiguration cfg,
org.apache.commons.cli.CommandLine cmd) |
Modifier and Type | Field and Description |
---|---|
protected ClientConfiguration |
AbstractResponseHandler.cfg |
Constructor and Description |
---|
AbstractResponseHandler(ClientConfiguration cfg,
HChannelManager channelManager) |
CloseSubscriptionResponseHandler(ClientConfiguration cfg,
HChannelManager channelManager) |
MessageConsumeCallback(ClientConfiguration cfg,
HChannelManager channelManager) |
PublishResponseHandler(ClientConfiguration cfg,
HChannelManager channelManager) |
SubscribeResponseHandler(ClientConfiguration cfg,
HChannelManager channelManager) |
UnsubscribeResponseHandler(ClientConfiguration cfg,
HChannelManager channelManager) |
Modifier and Type | Field and Description |
---|---|
protected ClientConfiguration |
HedwigSubscriber.cfg |
Modifier and Type | Method and Description |
---|---|
ClientConfiguration |
HedwigClientImpl.getConfiguration() |
Modifier and Type | Method and Description |
---|---|
static Client |
HedwigClientImpl.create(ClientConfiguration cfg) |
static Client |
HedwigClientImpl.create(ClientConfiguration cfg,
org.jboss.netty.channel.ChannelFactory socketFactory) |
Constructor and Description |
---|
HedwigClientImpl(ClientConfiguration cfg) |
HedwigClientImpl(ClientConfiguration cfg,
org.jboss.netty.channel.ChannelFactory socketFactory) |
Modifier and Type | Field and Description |
---|---|
protected ClientConfiguration |
ActiveSubscriber.cfg |
protected ClientConfiguration |
ClientChannelPipelineFactory.cfg |
Modifier and Type | Method and Description |
---|---|
protected ClientConfiguration |
AbstractSubscribeResponseHandler.getConfiguration() |
Modifier and Type | Method and Description |
---|---|
protected ActiveSubscriber |
AbstractSubscribeResponseHandler.createActiveSubscriber(ClientConfiguration cfg,
AbstractHChannelManager channelManager,
TopicSubscriber ts,
PubSubData op,
PubSubProtocol.SubscriptionPreferences preferences,
org.jboss.netty.channel.Channel channel,
HChannel hChannel) |
Constructor and Description |
---|
AbstractHChannelManager(ClientConfiguration cfg,
org.jboss.netty.channel.ChannelFactory socketFactory) |
AbstractSubscribeResponseHandler(ClientConfiguration cfg,
HChannelManager channelManager) |
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) |
NonSubscriptionChannelPipelineFactory(ClientConfiguration cfg,
AbstractHChannelManager channelManager) |
Constructor and Description |
---|
MultiplexHChannelManager(ClientConfiguration cfg,
org.jboss.netty.channel.ChannelFactory socketFactory) |
MultiplexSubscribeResponseHandler(ClientConfiguration cfg,
HChannelManager channelManager) |
MultiplexSubscriptionChannelPipelineFactory(ClientConfiguration cfg,
MultiplexHChannelManager channelManager) |
Modifier and Type | Method and Description |
---|---|
protected ActiveSubscriber |
SimpleSubscribeResponseHandler.createActiveSubscriber(ClientConfiguration cfg,
AbstractHChannelManager channelManager,
TopicSubscriber ts,
PubSubData op,
PubSubProtocol.SubscriptionPreferences preferences,
org.jboss.netty.channel.Channel channel,
HChannel hChannel) |
Constructor and Description |
---|
SimpleHChannelManager(ClientConfiguration cfg,
org.jboss.netty.channel.ChannelFactory socketFactory) |
SimpleSubscribeResponseHandler(ClientConfiguration cfg,
HChannelManager channelManager) |
SimpleSubscriptionChannelPipelineFactory(ClientConfiguration cfg,
SimpleHChannelManager channelManager) |
Constructor and Description |
---|
SslClientContextFactory(ClientConfiguration cfg) |
Copyright © 2015 The Apache Software Foundation. All rights reserved.