| Package | Description |
|---|---|
| com.oracle.bmc.streaming | |
| com.oracle.bmc.streaming.requests |
| Modifier and Type | Method and Description |
|---|---|
ConsumerHeartbeatResponse |
StreamClient.consumerHeartbeat(ConsumerHeartbeatRequest request) |
ConsumerHeartbeatResponse |
Stream.consumerHeartbeat(ConsumerHeartbeatRequest request)
Allows long-running processes to extend the timeout on partitions reserved by a consumer
instance.
|
Future<ConsumerHeartbeatResponse> |
StreamAsyncClient.consumerHeartbeat(ConsumerHeartbeatRequest request,
AsyncHandler<ConsumerHeartbeatRequest,ConsumerHeartbeatResponse> handler) |
Future<ConsumerHeartbeatResponse> |
StreamAsync.consumerHeartbeat(ConsumerHeartbeatRequest request,
AsyncHandler<ConsumerHeartbeatRequest,ConsumerHeartbeatResponse> handler)
Allows long-running processes to extend the timeout on partitions reserved by a consumer
instance.
|
| Modifier and Type | Method and Description |
|---|---|
Future<ConsumerHeartbeatResponse> |
StreamAsyncClient.consumerHeartbeat(ConsumerHeartbeatRequest request,
AsyncHandler<ConsumerHeartbeatRequest,ConsumerHeartbeatResponse> handler) |
Future<ConsumerHeartbeatResponse> |
StreamAsync.consumerHeartbeat(ConsumerHeartbeatRequest request,
AsyncHandler<ConsumerHeartbeatRequest,ConsumerHeartbeatResponse> handler)
Allows long-running processes to extend the timeout on partitions reserved by a consumer
instance.
|
| Modifier and Type | Method and Description |
|---|---|
ConsumerHeartbeatRequest |
ConsumerHeartbeatRequest.Builder.build()
Build the instance of ConsumerHeartbeatRequest as configured by this builder
|
ConsumerHeartbeatRequest |
ConsumerHeartbeatRequest.Builder.buildWithoutInvocationCallback()
Build the instance of ConsumerHeartbeatRequest as configured by this builder
|
| Modifier and Type | Method and Description |
|---|---|
ConsumerHeartbeatRequest.Builder |
ConsumerHeartbeatRequest.Builder.copy(ConsumerHeartbeatRequest o)
Copy method to populate the builder with values from the given instance.
|
Copyright © 2016–2022. All rights reserved.