| Package | Description |
|---|---|
| org.apache.hedwig.client.api | |
| 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 |
| Modifier and Type | Method and Description |
|---|---|
void |
Subscriber.startDelivery(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId,
MessageHandler messageHandler)
Begin delivery of messages from the server to us for this topic and
subscriberId.
|
void |
Subscriber.startDeliveryWithFilter(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId,
MessageHandler messageHandler,
org.apache.hedwig.filter.ClientMessageFilter messageFilter)
Begin delivery of messages from the server to us for this topic and
subscriberId.
|
| Modifier and Type | Method and Description |
|---|---|
abstract void |
SubscribeResponseHandler.startDelivery(TopicSubscriber topicSubscriber,
MessageHandler messageHandler)
Start delivering messages for a given topic subscriber.
|
| Modifier and Type | Method and Description |
|---|---|
void |
HedwigSubscriber.startDelivery(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId,
MessageHandler messageHandler) |
void |
HChannelManager.startDelivery(TopicSubscriber topicSubscriber,
MessageHandler messageHandler)
Start delivering messages for a given topic subscriber.
|
void |
HedwigSubscriber.startDeliveryWithFilter(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId,
MessageHandler messageHandler,
org.apache.hedwig.filter.ClientMessageFilter messageFilter) |
| Modifier and Type | Method and Description |
|---|---|
protected abstract void |
AbstractHChannelManager.restartDelivery(TopicSubscriber topicSubscriber) |
void |
ActiveSubscriber.startDelivery(MessageHandler messageHandler)
Start delivering messages using given message handler.
|
void |
AbstractSubscribeResponseHandler.startDelivery(TopicSubscriber topicSubscriber,
MessageHandler messageHandler) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
MultiplexHChannelManager.restartDelivery(TopicSubscriber topicSubscriber) |
void |
MultiplexHChannelManager.startDelivery(TopicSubscriber topicSubscriber,
MessageHandler messageHandler) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
SimpleHChannelManager.restartDelivery(TopicSubscriber topicSubscriber) |
void |
SimpleHChannelManager.startDelivery(TopicSubscriber topicSubscriber,
MessageHandler messageHandler) |
Copyright © 2011–2021 The Apache Software Foundation. All rights reserved.