| 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 | Class and Description |
|---|---|
class |
FilterableMessageHandler
Handlers used by a subscription.
|
| Modifier and Type | Method and Description |
|---|---|
MessageHandler |
FilterableMessageHandler.getMessageHandler() |
| 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) |
| Constructor and Description |
|---|
FilterableMessageHandler(MessageHandler msgHandler,
org.apache.hedwig.filter.ClientMessageFilter msgFilter) |
| Modifier and Type | Method and Description |
|---|---|
void |
ActiveSubscriber.startDelivery(MessageHandler messageHandler)
Start delivering messages using given message handler.
|
void |
AbstractSubscribeResponseHandler.startDelivery(TopicSubscriber topicSubscriber,
MessageHandler messageHandler) |
| Modifier and Type | Field and Description |
|---|---|
protected ConcurrentMap<TopicSubscriber,MessageHandler> |
MultiplexHChannelManager.topicSubscriber2MessageHandler |
| Modifier and Type | Method and Description |
|---|---|
void |
MultiplexHChannelManager.startDelivery(TopicSubscriber topicSubscriber,
MessageHandler messageHandler) |
| Modifier and Type | Field and Description |
|---|---|
protected ConcurrentMap<TopicSubscriber,MessageHandler> |
SimpleHChannelManager.topicSubscriber2MessageHandler |
| Modifier and Type | Method and Description |
|---|---|
void |
SimpleHChannelManager.startDelivery(TopicSubscriber topicSubscriber,
MessageHandler messageHandler) |
Copyright © 2011–2021 The Apache Software Foundation. All rights reserved.