Class MessagingFactory.MessagingFactoryBuilder
- java.lang.Object
-
- com.microsoft.azure.eventhubs.impl.MessagingFactory.MessagingFactoryBuilder
-
- Enclosing class:
- MessagingFactory
public static class MessagingFactory.MessagingFactoryBuilder extends Object
-
-
Constructor Summary
Constructors Constructor Description MessagingFactoryBuilder(String hostname, ITokenProvider tokenProvider, ScheduledExecutorService executor)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description CompletableFuture<MessagingFactory>
build()
MessagingFactory.MessagingFactoryBuilder
setOperationTimeout(Duration operationTimeout)
MessagingFactory.MessagingFactoryBuilder
setProxyConfiguration(ProxyConfiguration proxyConfiguration)
MessagingFactory.MessagingFactoryBuilder
setReactorFactory(MessagingFactory.ReactorFactory reactorFactory)
MessagingFactory.MessagingFactoryBuilder
setRetryPolicy(RetryPolicy retryPolicy)
MessagingFactory.MessagingFactoryBuilder
setTransportType(TransportType transportType)
MessagingFactory.MessagingFactoryBuilder
setWatchdogTriggerTime(Duration watchdogTriggerTime)
-
-
-
Constructor Detail
-
MessagingFactoryBuilder
public MessagingFactoryBuilder(String hostname, ITokenProvider tokenProvider, ScheduledExecutorService executor)
-
-
Method Detail
-
setOperationTimeout
public MessagingFactory.MessagingFactoryBuilder setOperationTimeout(Duration operationTimeout)
-
setTransportType
public MessagingFactory.MessagingFactoryBuilder setTransportType(TransportType transportType)
-
setRetryPolicy
public MessagingFactory.MessagingFactoryBuilder setRetryPolicy(RetryPolicy retryPolicy)
-
setReactorFactory
public MessagingFactory.MessagingFactoryBuilder setReactorFactory(MessagingFactory.ReactorFactory reactorFactory)
-
setProxyConfiguration
public MessagingFactory.MessagingFactoryBuilder setProxyConfiguration(ProxyConfiguration proxyConfiguration)
-
setWatchdogTriggerTime
public MessagingFactory.MessagingFactoryBuilder setWatchdogTriggerTime(Duration watchdogTriggerTime)
-
build
public CompletableFuture<MessagingFactory> build() throws IOException
- Throws:
IOException
-
-