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)
Copyright © 2011-2015 The Apache Software Foundation. All Rights Reserved.