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 © 2015 The Apache Software Foundation. All rights reserved.