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.consume(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId,
PubSubProtocol.MessageSeqId messageSeqId)
Manually send a consume message to the server for the given inputs.
|
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.
|
void |
Subscriber.stopDelivery(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId)
Stop delivery of messages for this topic and subscriberId.
|
void |
Subscriber.unsubscribe(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId)
Unsubscribe from a topic that the subscriberId user has previously
subscribed to.
|
Modifier and Type | Method and Description |
---|---|
abstract void |
SubscribeResponseHandler.startDelivery(TopicSubscriber topicSubscriber,
MessageHandler messageHandler)
Start delivering messages for a given topic subscriber.
|
abstract void |
SubscribeResponseHandler.stopDelivery(TopicSubscriber topicSubscriber)
Stop delivering messages for a given topic subscriber.
|
Modifier and Type | Method and Description |
---|---|
void |
HedwigSubscriber.consume(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId,
PubSubProtocol.MessageSeqId messageSeqId) |
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) |
void |
HedwigSubscriber.stopDelivery(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId) |
void |
HChannelManager.stopDelivery(TopicSubscriber topicSubscriber)
Stop delivering messages for a given topic subscriber.
|
void |
HedwigSubscriber.unsubscribe(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId) |
protected void |
HedwigSubscriber.unsubscribe(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId,
boolean isHub) |
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) |
void |
AbstractSubscribeResponseHandler.stopDelivery(TopicSubscriber topicSubscriber) |
Modifier and Type | Method and Description |
---|---|
protected void |
MultiplexHChannelManager.restartDelivery(TopicSubscriber topicSubscriber) |
void |
MultiplexHChannelManager.startDelivery(TopicSubscriber topicSubscriber,
MessageHandler messageHandler) |
void |
MultiplexHChannelManager.stopDelivery(TopicSubscriber topicSubscriber) |
Modifier and Type | Method and Description |
---|---|
protected void |
SimpleHChannelManager.restartDelivery(TopicSubscriber topicSubscriber) |
void |
SimpleHChannelManager.startDelivery(TopicSubscriber topicSubscriber,
MessageHandler messageHandler) |
void |
SimpleHChannelManager.stopDelivery(TopicSubscriber topicSubscriber) |
Copyright © 2011–2016 The Apache Software Foundation. All rights reserved.