| 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 |
ClientChannelPipelineFactory.cfg |
protected ClientConfiguration |
ActiveSubscriber.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 © 2011–2021 The Apache Software Foundation. All rights reserved.