A B C D E F G H I J L M P R S T U V W Z
All Classes All Packages

A

acknowledge(String, Collection<String>) - Method in class com.bazaarvoice.emodb.databus.client.DatabusClient

B

baseUri - Variable in class com.bazaarvoice.emodb.databus.client.discovery.ZKEmoServiceDiscovery.Host

build() - Method in class com.bazaarvoice.emodb.databus.client.discovery.PartitionedDiscovery.Builder

Builder(String) - Constructor for class com.bazaarvoice.emodb.databus.client.discovery.ZKEmoServiceDiscovery.Builder

C

close() - Method in class com.bazaarvoice.emodb.databus.client.DatabusClient

com.bazaarvoice.emodb.databus.client - package com.bazaarvoice.emodb.databus.client

com.bazaarvoice.emodb.databus.client.discovery - package com.bazaarvoice.emodb.databus.client.discovery

com.bazaarvoice.emodb.databus.client.factory - package com.bazaarvoice.emodb.databus.client.factory

com.bazaarvoice.emodb.databus.client.Json - package com.bazaarvoice.emodb.databus.client.Json

compareTo(ZKEmoServiceDiscovery.Host) - Method in class com.bazaarvoice.emodb.databus.client.discovery.ZKEmoServiceDiscovery.Host

create() - Method in class com.bazaarvoice.emodb.databus.client.factory.DatabusFactory

D

DatabusClient - Class in com.bazaarvoice.emodb.databus.client

Thin client for accessing EmoDB Databus.

DatabusClient(EmoServiceDiscovery, EmoClient, String, RetryPolicy<Object>) - Constructor for class com.bazaarvoice.emodb.databus.client.DatabusClient

DatabusFactory - Class in com.bazaarvoice.emodb.databus.client.factory

Factory for creating DatabusClient clients.

DatabusFactory(EmoServiceDiscovery, String, JerseyClient) - Constructor for class com.bazaarvoice.emodb.databus.client.factory.DatabusFactory

DirectUriEmoServiceDiscovery - Class in com.bazaarvoice.emodb.databus.client.discovery

DirectUriEmoServiceDiscovery(URI) - Constructor for class com.bazaarvoice.emodb.databus.client.discovery.DirectUriEmoServiceDiscovery

doStart() - Method in class com.bazaarvoice.emodb.databus.client.discovery.ZKEmoServiceDiscovery

doStop() - Method in class com.bazaarvoice.emodb.databus.client.discovery.ZKEmoServiceDiscovery

E

EmoServiceDiscovery - Interface in com.bazaarvoice.emodb.databus.client.discovery

F

finalize() - Method in class com.bazaarvoice.emodb.databus.client.DatabusClient

G

getBaseUri() - Method in class com.bazaarvoice.emodb.databus.client.discovery.DirectUriEmoServiceDiscovery

getBaseUri() - Method in interface com.bazaarvoice.emodb.databus.client.discovery.EmoServiceDiscovery

getBaseUri() - Method in class com.bazaarvoice.emodb.databus.client.discovery.ZKEmoServiceDiscovery

getBaseUriFromDiscovery() - Method in class com.bazaarvoice.emodb.databus.client.discovery.PartitionedDiscovery

getBaseUriFromDiscovery() - Method in class com.bazaarvoice.emodb.databus.client.discovery.ZKEmoServiceDiscovery

getClaimCount(String) - Method in class com.bazaarvoice.emodb.databus.client.DatabusClient

getEventCount(String) - Method in class com.bazaarvoice.emodb.databus.client.DatabusClient

getEventCountUpTo(String, long) - Method in class com.bazaarvoice.emodb.databus.client.DatabusClient

getMoveStatus(String) - Method in class com.bazaarvoice.emodb.databus.client.DatabusClient

getReplayStatus(String) - Method in class com.bazaarvoice.emodb.databus.client.DatabusClient

getService() - Method in class com.bazaarvoice.emodb.databus.client.discovery.ZKEmoServiceDiscovery.Builder

getSubscription(String) - Method in class com.bazaarvoice.emodb.databus.client.DatabusClient

getZookeeperConnectionString() - Method in class com.bazaarvoice.emodb.databus.client.discovery.ZKEmoServiceDiscovery.Builder

H

Host(String, URI) - Constructor for class com.bazaarvoice.emodb.databus.client.discovery.ZKEmoServiceDiscovery.Host

hostsChanged(List<ZKEmoServiceDiscovery.Host>) - Method in class com.bazaarvoice.emodb.databus.client.discovery.PartitionedDiscovery

hostsChanged(List<ZKEmoServiceDiscovery.Host>) - Method in class com.bazaarvoice.emodb.databus.client.discovery.ZKEmoServiceDiscovery

I

id - Variable in class com.bazaarvoice.emodb.databus.client.discovery.ZKEmoServiceDiscovery.Host

injectEvent(String, String, String) - Method in class com.bazaarvoice.emodb.databus.client.DatabusClient

J

JsonUtil - Class in com.bazaarvoice.emodb.databus.client.Json

JsonUtil() - Constructor for class com.bazaarvoice.emodb.databus.client.Json.JsonUtil

L

listSubscriptions(String, long) - Method in class com.bazaarvoice.emodb.databus.client.DatabusClient

M

moveAsync(String, String) - Method in class com.bazaarvoice.emodb.databus.client.DatabusClient

P

parseJson(byte[], TypeReference<T>) - Static method in class com.bazaarvoice.emodb.databus.client.Json.JsonUtil

parseJson(byte[], Class<T>) - Static method in class com.bazaarvoice.emodb.databus.client.Json.JsonUtil

parseJson(InputStream, TypeReference<T>) - Static method in class com.bazaarvoice.emodb.databus.client.Json.JsonUtil

parseJson(InputStream, Class<T>) - Static method in class com.bazaarvoice.emodb.databus.client.Json.JsonUtil

parseJson(String, TypeReference<T>) - Static method in class com.bazaarvoice.emodb.databus.client.Json.JsonUtil

parseJson(String, Class<T>) - Static method in class com.bazaarvoice.emodb.databus.client.Json.JsonUtil

PartitionedDiscovery - Class in com.bazaarvoice.emodb.databus.client.discovery

Service discovery implementation which directs requests to a spectific host based on a partition key.

PartitionedDiscovery(String, String, String) - Constructor for class com.bazaarvoice.emodb.databus.client.discovery.PartitionedDiscovery

PartitionedDiscovery.Builder - Class in com.bazaarvoice.emodb.databus.client.discovery

peek(String, int) - Method in class com.bazaarvoice.emodb.databus.client.DatabusClient

poll(String, Duration, int) - Method in class com.bazaarvoice.emodb.databus.client.DatabusClient

purge(String) - Method in class com.bazaarvoice.emodb.databus.client.DatabusClient

R

renew(String, Collection<String>, Duration) - Method in class com.bazaarvoice.emodb.databus.client.DatabusClient

replayAsync(String) - Method in class com.bazaarvoice.emodb.databus.client.DatabusClient

replayAsyncSince(String, Date) - Method in class com.bazaarvoice.emodb.databus.client.DatabusClient

S

subscribe(String, Condition, Duration, Duration) - Method in class com.bazaarvoice.emodb.databus.client.DatabusClient

subscribe(String, Condition, Duration, Duration, boolean) - Method in class com.bazaarvoice.emodb.databus.client.DatabusClient

T

toJsonString(Object) - Static method in class com.bazaarvoice.emodb.databus.client.Json.JsonUtil

U

unclaimAll(String) - Method in class com.bazaarvoice.emodb.databus.client.DatabusClient

unsubscribe(String) - Method in class com.bazaarvoice.emodb.databus.client.DatabusClient

V

validate() - Method in class com.bazaarvoice.emodb.databus.client.discovery.PartitionedDiscovery.Builder

validate() - Method in class com.bazaarvoice.emodb.databus.client.discovery.ZKEmoServiceDiscovery.Builder

W

withSubscription(String) - Method in class com.bazaarvoice.emodb.databus.client.discovery.PartitionedDiscovery.Builder

withZookeeperDiscovery(String, String) - Method in class com.bazaarvoice.emodb.databus.client.discovery.PartitionedDiscovery.Builder

withZookeeperDiscovery(String, String) - Method in class com.bazaarvoice.emodb.databus.client.discovery.ZKEmoServiceDiscovery.Builder

Z

ZKEmoServiceDiscovery - Class in com.bazaarvoice.emodb.databus.client.discovery

ZKEmoServiceDiscovery(String, String) - Constructor for class com.bazaarvoice.emodb.databus.client.discovery.ZKEmoServiceDiscovery

ZKEmoServiceDiscovery.Builder - Class in com.bazaarvoice.emodb.databus.client.discovery

ZKEmoServiceDiscovery.Host - Class in com.bazaarvoice.emodb.databus.client.discovery

A B C D E F G H I J L M P R S T U V W Z
All Classes All Packages