Package | Description |
---|---|
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.protocol | |
org.apache.hedwig.util |
Modifier and Type | Method and Description |
---|---|
abstract void |
SubscribeResponseHandler.handleSubscriptionEvent(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId,
PubSubProtocol.SubscriptionEvent event)
Handle a subscription event delivered by the server.
|
Modifier and Type | Method and Description |
---|---|
void |
SubscriptionEventEmitter.emitSubscriptionEvent(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId,
PubSubProtocol.SubscriptionEvent event) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractSubscribeResponseHandler.handleSubscriptionEvent(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId,
PubSubProtocol.SubscriptionEvent event) |
protected void |
AbstractSubscribeResponseHandler.processSubscriptionEvent(ActiveSubscriber as,
PubSubProtocol.SubscriptionEvent event) |
protected void |
AbstractSubscribeResponseHandler.resubscribeIfNecessary(ActiveSubscriber ss,
PubSubProtocol.SubscriptionEvent event) |
void |
ActiveSubscriber.resubscribeIfNecessary(PubSubProtocol.SubscriptionEvent event)
Resubscribe a subscriber if necessary.
|
Modifier and Type | Method and Description |
---|---|
static PubSubProtocol.SubscriptionEvent |
PubSubProtocol.SubscriptionEvent.forNumber(int value) |
PubSubProtocol.SubscriptionEvent |
PubSubProtocol.SubscriptionEventResponseOrBuilder.getEvent()
optional .Hedwig.SubscriptionEvent event = 1; |
PubSubProtocol.SubscriptionEvent |
PubSubProtocol.SubscriptionEventResponse.getEvent()
optional .Hedwig.SubscriptionEvent event = 1; |
PubSubProtocol.SubscriptionEvent |
PubSubProtocol.SubscriptionEventResponse.Builder.getEvent()
optional .Hedwig.SubscriptionEvent event = 1; |
static PubSubProtocol.SubscriptionEvent |
PubSubProtocol.SubscriptionEvent.valueOf(com.google.protobuf.Descriptors.EnumValueDescriptor desc) |
static PubSubProtocol.SubscriptionEvent |
PubSubProtocol.SubscriptionEvent.valueOf(int value)
Deprecated.
Use
forNumber(int) instead. |
static PubSubProtocol.SubscriptionEvent |
PubSubProtocol.SubscriptionEvent.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static PubSubProtocol.SubscriptionEvent[] |
PubSubProtocol.SubscriptionEvent.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
static com.google.protobuf.Internal.EnumLiteMap<PubSubProtocol.SubscriptionEvent> |
PubSubProtocol.SubscriptionEvent.internalGetValueMap() |
Modifier and Type | Method and Description |
---|---|
PubSubProtocol.SubscriptionEventResponse.Builder |
PubSubProtocol.SubscriptionEventResponse.Builder.setEvent(PubSubProtocol.SubscriptionEvent value)
optional .Hedwig.SubscriptionEvent event = 1; |
Modifier and Type | Method and Description |
---|---|
void |
SubscriptionListener.processEvent(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId,
PubSubProtocol.SubscriptionEvent event)
Process an event from a subscription.
|
Copyright © 2011–2017 The Apache Software Foundation. All rights reserved.