Subscriber.asyncSubscribe(com.google.protobuf.ByteString, com.google.protobuf.ByteString, PubSubProtocol.SubscriptionOptions,Callback,Object)
AbstractConfiguration.getLedgerManagerFactoryClass()
ClientConfiguration.getReadEntryTimeout()
ClientConfiguration.getAddEntryTimeout()
AbstractConfiguration.setLedgerManagerFactoryClass(java.lang.Class<? extends org.apache.bookkeeper.meta.LedgerManagerFactory>)
ClientConfiguration.setReadEntryTimeout(int)
ClientConfiguration.setAddEntryTimeout(int)
Subscriber.subscribe(com.google.protobuf.ByteString, com.google.protobuf.ByteString, PubSubProtocol.SubscriptionOptions)
PubSubProtocol.ProtocolVersion.forNumber(int)
PubSubProtocol.OperationType.forNumber(int)
PubSubProtocol.SubscriptionEvent.forNumber(int)
PubSubProtocol.StatusCode.forNumber(int)
PubSubProtocol.SubscribeRequest.CreateOrAttach.forNumber(int)
Copyright © 2011–2017 The Apache Software Foundation. All rights reserved.