Interface EventBridgeV2AsyncClient

All Superinterfaces:
AutoCloseable, AwsClient, SdkAutoCloseable, SdkClient
@Generated("software.amazon.awssdk:codegen") @SdkPublicApi @ThreadSafe public interface EventBridgeV2AsyncClient extends AwsClient
Service client for accessing Amazon EventBridgeV2 asynchronously. This can be created using the static builder() method.The asynchronous client performs non-blocking I/O when configured with any SdkAsyncHttpClient supported in the SDK. However, full non-blocking is not guaranteed as the async client may perform blocking calls in some cases such as credentials retrieval and endpoint discovery as part of the async API call.

Amazon EventBridge event bus API. An event bus receives events published by your applications and AWS services, stores them for a configurable retention period, and delivers them to subscribers. A subscriber filters events, optionally transforms them, and invokes a target such as Lambda, SQS, SNS, Kinesis, Step Functions, or an HTTP endpoint. The API manages event buses, subscribers, event sources, resource policies, and tags, and publishes events through PutEvents and PutRawEvents.

  • Field Details

  • Method Details

    • createEventBus

      default CompletableFuture<CreateEventBusResponse> createEventBus(CreateEventBusRequest createEventBusRequest)

      Creates an event bus. Provisioning is asynchronous: the bus is returned in the CREATING state and transitions to ACTIVE when ready (see the EventBusActive waiter). Retries carrying the same ClientToken are idempotent.

      Parameters:
      createEventBusRequest -
      Returns:
      A Java Future containing the result of the CreateEventBus operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • LimitExceededException The request would exceed a service quota for the account.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • IdempotentParameterMismatchException The request reuses the client token of an earlier request with different parameters. Use a new client token, or resend the earlier request unchanged.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • ResourceAlreadyExistsException A resource with the same name already exists.
      • InternalException The request failed because of an internal service error. Retry the request.
      • ConcurrentModificationException Another change to the resource is already in progress. Retry the request.
      • InvalidStateException The resource is not in a state that allows the operation. For example, an event bus that is still being created cannot accept events.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • createEventBus

      default CompletableFuture<CreateEventBusResponse> createEventBus(Consumer<CreateEventBusRequest.Builder> createEventBusRequest)

      Creates an event bus. Provisioning is asynchronous: the bus is returned in the CREATING state and transitions to ACTIVE when ready (see the EventBusActive waiter). Retries carrying the same ClientToken are idempotent.


      This is a convenience which creates an instance of the CreateEventBusRequest.Builder avoiding the need to create one manually via CreateEventBusRequest.builder()

      Parameters:
      createEventBusRequest - A Consumer that will call methods on CreateEventBusRequest.Builder to create a request.
      Returns:
      A Java Future containing the result of the CreateEventBus operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • LimitExceededException The request would exceed a service quota for the account.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • IdempotentParameterMismatchException The request reuses the client token of an earlier request with different parameters. Use a new client token, or resend the earlier request unchanged.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • ResourceAlreadyExistsException A resource with the same name already exists.
      • InternalException The request failed because of an internal service error. Retry the request.
      • ConcurrentModificationException Another change to the resource is already in progress. Retry the request.
      • InvalidStateException The resource is not in a state that allows the operation. For example, an event bus that is still being created cannot accept events.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • createEventSource

      default CompletableFuture<CreateEventSourceResponse> createEventSource(CreateEventSourceRequest createEventSourceRequest)

      Creates an EventSource, which forwards events from an origin (an AWS service or another account) onto an event bus. The bus must be ACTIVE. Retries carrying the same ClientToken are idempotent.

      Parameters:
      createEventSourceRequest -
      Returns:
      A Java Future containing the result of the CreateEventSource operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • LimitExceededException The request would exceed a service quota for the account.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • IdempotentParameterMismatchException The request reuses the client token of an earlier request with different parameters. Use a new client token, or resend the earlier request unchanged.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • ResourceAlreadyExistsException A resource with the same name already exists.
      • InternalException The request failed because of an internal service error. Retry the request.
      • ConcurrentModificationException Another change to the resource is already in progress. Retry the request.
      • InvalidStateException The resource is not in a state that allows the operation. For example, an event bus that is still being created cannot accept events.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • createEventSource

      default CompletableFuture<CreateEventSourceResponse> createEventSource(Consumer<CreateEventSourceRequest.Builder> createEventSourceRequest)

      Creates an EventSource, which forwards events from an origin (an AWS service or another account) onto an event bus. The bus must be ACTIVE. Retries carrying the same ClientToken are idempotent.


      This is a convenience which creates an instance of the CreateEventSourceRequest.Builder avoiding the need to create one manually via CreateEventSourceRequest.builder()

      Parameters:
      createEventSourceRequest - A Consumer that will call methods on CreateEventSourceRequest.Builder to create a request.
      Returns:
      A Java Future containing the result of the CreateEventSource operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • LimitExceededException The request would exceed a service quota for the account.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • IdempotentParameterMismatchException The request reuses the client token of an earlier request with different parameters. Use a new client token, or resend the earlier request unchanged.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • ResourceAlreadyExistsException A resource with the same name already exists.
      • InternalException The request failed because of an internal service error. Retry the request.
      • ConcurrentModificationException Another change to the resource is already in progress. Retry the request.
      • InvalidStateException The resource is not in a state that allows the operation. For example, an event bus that is still being created cannot accept events.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • createSubscriber

      default CompletableFuture<CreateSubscriberResponse> createSubscriber(CreateSubscriberRequest createSubscriberRequest)

      Creates a subscriber on an event bus, which delivers matching events to the configured target. The bus must be ACTIVE. Retries carrying the same ClientToken are idempotent.

      Parameters:
      createSubscriberRequest -
      Returns:
      A Java Future containing the result of the CreateSubscriber operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • LimitExceededException The request would exceed a service quota for the account.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • IdempotentParameterMismatchException The request reuses the client token of an earlier request with different parameters. Use a new client token, or resend the earlier request unchanged.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • ResourceAlreadyExistsException A resource with the same name already exists.
      • InternalException The request failed because of an internal service error. Retry the request.
      • ConcurrentModificationException Another change to the resource is already in progress. Retry the request.
      • InvalidStateException The resource is not in a state that allows the operation. For example, an event bus that is still being created cannot accept events.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • createSubscriber

      default CompletableFuture<CreateSubscriberResponse> createSubscriber(Consumer<CreateSubscriberRequest.Builder> createSubscriberRequest)

      Creates a subscriber on an event bus, which delivers matching events to the configured target. The bus must be ACTIVE. Retries carrying the same ClientToken are idempotent.


      This is a convenience which creates an instance of the CreateSubscriberRequest.Builder avoiding the need to create one manually via CreateSubscriberRequest.builder()

      Parameters:
      createSubscriberRequest - A Consumer that will call methods on CreateSubscriberRequest.Builder to create a request.
      Returns:
      A Java Future containing the result of the CreateSubscriber operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • LimitExceededException The request would exceed a service quota for the account.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • IdempotentParameterMismatchException The request reuses the client token of an earlier request with different parameters. Use a new client token, or resend the earlier request unchanged.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • ResourceAlreadyExistsException A resource with the same name already exists.
      • InternalException The request failed because of an internal service error. Retry the request.
      • ConcurrentModificationException Another change to the resource is already in progress. Retry the request.
      • InvalidStateException The resource is not in a state that allows the operation. For example, an event bus that is still being created cannot accept events.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • deleteEventBus

      default CompletableFuture<DeleteEventBusResponse> deleteEventBus(DeleteEventBusRequest deleteEventBusRequest)

      Deletes an event bus. Deletion is asynchronous: the bus moves to DELETING and disappears when complete (see the EventBusDeleted waiter). A bus with subscribers or event sources cannot be deleted.

      Parameters:
      deleteEventBusRequest -
      Returns:
      A Java Future containing the result of the DeleteEventBus operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • ConcurrentModificationException Another change to the resource is already in progress. Retry the request.
      • InvalidStateException The resource is not in a state that allows the operation. For example, an event bus that is still being created cannot accept events.
      • ResourceInUseException The resource is in use and cannot be deleted. For example, an event bus with subscribers or event sources cannot be deleted until they are deleted.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • deleteEventBus

      default CompletableFuture<DeleteEventBusResponse> deleteEventBus(Consumer<DeleteEventBusRequest.Builder> deleteEventBusRequest)

      Deletes an event bus. Deletion is asynchronous: the bus moves to DELETING and disappears when complete (see the EventBusDeleted waiter). A bus with subscribers or event sources cannot be deleted.


      This is a convenience which creates an instance of the DeleteEventBusRequest.Builder avoiding the need to create one manually via DeleteEventBusRequest.builder()

      Parameters:
      deleteEventBusRequest - A Consumer that will call methods on DeleteEventBusRequest.Builder to create a request.
      Returns:
      A Java Future containing the result of the DeleteEventBus operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • ConcurrentModificationException Another change to the resource is already in progress. Retry the request.
      • InvalidStateException The resource is not in a state that allows the operation. For example, an event bus that is still being created cannot accept events.
      • ResourceInUseException The resource is in use and cannot be deleted. For example, an event bus with subscribers or event sources cannot be deleted until they are deleted.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • deleteEventSource

      default CompletableFuture<DeleteEventSourceResponse> deleteEventSource(DeleteEventSourceRequest deleteEventSourceRequest)

      Deletes an EventSource. Forwarding from its origin stops.

      Parameters:
      deleteEventSourceRequest -
      Returns:
      A Java Future containing the result of the DeleteEventSource operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • ConcurrentModificationException Another change to the resource is already in progress. Retry the request.
      • InvalidStateException The resource is not in a state that allows the operation. For example, an event bus that is still being created cannot accept events.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • deleteEventSource

      default CompletableFuture<DeleteEventSourceResponse> deleteEventSource(Consumer<DeleteEventSourceRequest.Builder> deleteEventSourceRequest)

      Deletes an EventSource. Forwarding from its origin stops.


      This is a convenience which creates an instance of the DeleteEventSourceRequest.Builder avoiding the need to create one manually via DeleteEventSourceRequest.builder()

      Parameters:
      deleteEventSourceRequest - A Consumer that will call methods on DeleteEventSourceRequest.Builder to create a request.
      Returns:
      A Java Future containing the result of the DeleteEventSource operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • ConcurrentModificationException Another change to the resource is already in progress. Retry the request.
      • InvalidStateException The resource is not in a state that allows the operation. For example, an event bus that is still being created cannot accept events.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • deleteResourcePolicy

      default CompletableFuture<DeleteResourcePolicyResponse> deleteResourcePolicy(DeleteResourcePolicyRequest deleteResourcePolicyRequest)

      Deletes the named resource policy attached to an event bus.

      Parameters:
      deleteResourcePolicyRequest -
      Returns:
      A Java Future containing the result of the DeleteResourcePolicy operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • ConflictException A client-supplied precondition (e.g. ExpectedRevisionId on a resource-policy write) did not match the current state of the resource. Retrying the same request will fail again; re-read the resource and re-evaluate before retrying.

        A conditional request is not retry-safe on its own. If an earlier attempt committed but its response never reached the caller, retrying fails with this error, which is indistinguishable from another writer having won. Compare the resource's current contents with what the request intended: a successful attempt stores a revision ID the caller never saw, so the revision alone cannot tell the two apart, but matching contents mean the change took effect.

      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • ConcurrentModificationException Another change to the resource is already in progress. Retry the request.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • deleteResourcePolicy

      default CompletableFuture<DeleteResourcePolicyResponse> deleteResourcePolicy(Consumer<DeleteResourcePolicyRequest.Builder> deleteResourcePolicyRequest)

      Deletes the named resource policy attached to an event bus.


      This is a convenience which creates an instance of the DeleteResourcePolicyRequest.Builder avoiding the need to create one manually via DeleteResourcePolicyRequest.builder()

      Parameters:
      deleteResourcePolicyRequest - A Consumer that will call methods on DeleteResourcePolicyRequest.Builder to create a request.
      Returns:
      A Java Future containing the result of the DeleteResourcePolicy operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • ConflictException A client-supplied precondition (e.g. ExpectedRevisionId on a resource-policy write) did not match the current state of the resource. Retrying the same request will fail again; re-read the resource and re-evaluate before retrying.

        A conditional request is not retry-safe on its own. If an earlier attempt committed but its response never reached the caller, retrying fails with this error, which is indistinguishable from another writer having won. Compare the resource's current contents with what the request intended: a successful attempt stores a revision ID the caller never saw, so the revision alone cannot tell the two apart, but matching contents mean the change took effect.

      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • ConcurrentModificationException Another change to the resource is already in progress. Retry the request.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • deleteSubscriber

      default CompletableFuture<DeleteSubscriberResponse> deleteSubscriber(DeleteSubscriberRequest deleteSubscriberRequest)

      Deletes a subscriber. Events are no longer delivered to its target.

      Parameters:
      deleteSubscriberRequest -
      Returns:
      A Java Future containing the result of the DeleteSubscriber operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • ConcurrentModificationException Another change to the resource is already in progress. Retry the request.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • deleteSubscriber

      default CompletableFuture<DeleteSubscriberResponse> deleteSubscriber(Consumer<DeleteSubscriberRequest.Builder> deleteSubscriberRequest)

      Deletes a subscriber. Events are no longer delivered to its target.


      This is a convenience which creates an instance of the DeleteSubscriberRequest.Builder avoiding the need to create one manually via DeleteSubscriberRequest.builder()

      Parameters:
      deleteSubscriberRequest - A Consumer that will call methods on DeleteSubscriberRequest.Builder to create a request.
      Returns:
      A Java Future containing the result of the DeleteSubscriber operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • ConcurrentModificationException Another change to the resource is already in progress. Retry the request.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • describeEventBus

      default CompletableFuture<DescribeEventBusResponse> describeEventBus(DescribeEventBusRequest describeEventBusRequest)

      Returns the full configuration and lifecycle state of an event bus.

      Parameters:
      describeEventBusRequest -
      Returns:
      A Java Future containing the result of the DescribeEventBus operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • describeEventBus

      default CompletableFuture<DescribeEventBusResponse> describeEventBus(Consumer<DescribeEventBusRequest.Builder> describeEventBusRequest)

      Returns the full configuration and lifecycle state of an event bus.


      This is a convenience which creates an instance of the DescribeEventBusRequest.Builder avoiding the need to create one manually via DescribeEventBusRequest.builder()

      Parameters:
      describeEventBusRequest - A Consumer that will call methods on DescribeEventBusRequest.Builder to create a request.
      Returns:
      A Java Future containing the result of the DescribeEventBus operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • describeEventSource

      default CompletableFuture<DescribeEventSourceResponse> describeEventSource(DescribeEventSourceRequest describeEventSourceRequest)

      Returns the full configuration and lifecycle state of an EventSource.

      Parameters:
      describeEventSourceRequest -
      Returns:
      A Java Future containing the result of the DescribeEventSource operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • describeEventSource

      default CompletableFuture<DescribeEventSourceResponse> describeEventSource(Consumer<DescribeEventSourceRequest.Builder> describeEventSourceRequest)

      Returns the full configuration and lifecycle state of an EventSource.


      This is a convenience which creates an instance of the DescribeEventSourceRequest.Builder avoiding the need to create one manually via DescribeEventSourceRequest.builder()

      Parameters:
      describeEventSourceRequest - A Consumer that will call methods on DescribeEventSourceRequest.Builder to create a request.
      Returns:
      A Java Future containing the result of the DescribeEventSource operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • describeSubscriber

      default CompletableFuture<DescribeSubscriberResponse> describeSubscriber(DescribeSubscriberRequest describeSubscriberRequest)

      Returns the full configuration and state of a subscriber.

      Parameters:
      describeSubscriberRequest -
      Returns:
      A Java Future containing the result of the DescribeSubscriber operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • describeSubscriber

      default CompletableFuture<DescribeSubscriberResponse> describeSubscriber(Consumer<DescribeSubscriberRequest.Builder> describeSubscriberRequest)

      Returns the full configuration and state of a subscriber.


      This is a convenience which creates an instance of the DescribeSubscriberRequest.Builder avoiding the need to create one manually via DescribeSubscriberRequest.builder()

      Parameters:
      describeSubscriberRequest - A Consumer that will call methods on DescribeSubscriberRequest.Builder to create a request.
      Returns:
      A Java Future containing the result of the DescribeSubscriber operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • getResourcePolicy

      default CompletableFuture<GetResourcePolicyResponse> getResourcePolicy(GetResourcePolicyRequest getResourcePolicyRequest)

      Returns the named resource policy attached to an event bus. Fails with ResourceNotFoundException when the event bus or the named policy does not exist.

      Parameters:
      getResourcePolicyRequest -
      Returns:
      A Java Future containing the result of the GetResourcePolicy operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • getResourcePolicy

      default CompletableFuture<GetResourcePolicyResponse> getResourcePolicy(Consumer<GetResourcePolicyRequest.Builder> getResourcePolicyRequest)

      Returns the named resource policy attached to an event bus. Fails with ResourceNotFoundException when the event bus or the named policy does not exist.


      This is a convenience which creates an instance of the GetResourcePolicyRequest.Builder avoiding the need to create one manually via GetResourcePolicyRequest.builder()

      Parameters:
      getResourcePolicyRequest - A Consumer that will call methods on GetResourcePolicyRequest.Builder to create a request.
      Returns:
      A Java Future containing the result of the GetResourcePolicy operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • listEventBuses

      default CompletableFuture<ListEventBusesResponse> listEventBuses(ListEventBusesRequest listEventBusesRequest)

      Lists the event buses visible to the caller: buses the account owns and buses shared with it through AWS RAM. Shared entries carry identity fields only (Name, EventBusArn, EventBusAccountId); owned entries carry every summary field. Set EventBusAccountId to scope the list to one owner account.

      Parameters:
      listEventBusesRequest -
      Returns:
      A Java Future containing the result of the ListEventBuses operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • listEventBuses

      default CompletableFuture<ListEventBusesResponse> listEventBuses(Consumer<ListEventBusesRequest.Builder> listEventBusesRequest)

      Lists the event buses visible to the caller: buses the account owns and buses shared with it through AWS RAM. Shared entries carry identity fields only (Name, EventBusArn, EventBusAccountId); owned entries carry every summary field. Set EventBusAccountId to scope the list to one owner account.


      This is a convenience which creates an instance of the ListEventBusesRequest.Builder avoiding the need to create one manually via ListEventBusesRequest.builder()

      Parameters:
      listEventBusesRequest - A Consumer that will call methods on ListEventBusesRequest.Builder to create a request.
      Returns:
      A Java Future containing the result of the ListEventBuses operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • listEventBusesPaginator

      default ListEventBusesPublisher listEventBusesPaginator(ListEventBusesRequest listEventBusesRequest)

      This is a variant of listEventBuses(software.amazon.awssdk.services.eventbridgev2.model.ListEventBusesRequest) operation. The return type is a custom publisher that can be subscribed to request a stream of response pages. SDK will internally handle making service calls for you.

      When the operation is called, an instance of this class is returned. At this point, no service calls are made yet and so there is no guarantee that the request is valid. If there are errors in your request, you will see the failures only after you start streaming the data. The subscribe method should be called as a request to start streaming data. For more info, see Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe method will result in a new Subscription i.e., a new contract to stream data from the starting request.

      The following are few ways to use the response class:

      1) Using the subscribe helper method 
       
 software.amazon.awssdk.services.eventbridgev2.paginators.ListEventBusesPublisher publisher = client.listEventBusesPaginator(request);
 CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
 future.get();
      2) Using a custom subscriber 
       
 software.amazon.awssdk.services.eventbridgev2.paginators.ListEventBusesPublisher publisher = client.listEventBusesPaginator(request);
 publisher.subscribe(new Subscriber<software.amazon.awssdk.services.eventbridgev2.model.ListEventBusesResponse>() {
 
 public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
 
 
 public void onNext(software.amazon.awssdk.services.eventbridgev2.model.ListEventBusesResponse response) { //... };
 });
      As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.

      Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.

      Note: If you prefer to have control on service calls, use the listEventBuses(software.amazon.awssdk.services.eventbridgev2.model.ListEventBusesRequest) operation.

      Parameters:
      listEventBusesRequest -
      Returns:
      A custom publisher that can be subscribed to request a stream of response pages.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • listEventBusesPaginator

      default ListEventBusesPublisher listEventBusesPaginator(Consumer<ListEventBusesRequest.Builder> listEventBusesRequest)

      This is a variant of listEventBuses(software.amazon.awssdk.services.eventbridgev2.model.ListEventBusesRequest) operation. The return type is a custom publisher that can be subscribed to request a stream of response pages. SDK will internally handle making service calls for you.

      When the operation is called, an instance of this class is returned. At this point, no service calls are made yet and so there is no guarantee that the request is valid. If there are errors in your request, you will see the failures only after you start streaming the data. The subscribe method should be called as a request to start streaming data. For more info, see Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe method will result in a new Subscription i.e., a new contract to stream data from the starting request.

      The following are few ways to use the response class:

      1) Using the subscribe helper method 
       
 software.amazon.awssdk.services.eventbridgev2.paginators.ListEventBusesPublisher publisher = client.listEventBusesPaginator(request);
 CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
 future.get();
      2) Using a custom subscriber 
       
 software.amazon.awssdk.services.eventbridgev2.paginators.ListEventBusesPublisher publisher = client.listEventBusesPaginator(request);
 publisher.subscribe(new Subscriber<software.amazon.awssdk.services.eventbridgev2.model.ListEventBusesResponse>() {
 
 public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
 
 
 public void onNext(software.amazon.awssdk.services.eventbridgev2.model.ListEventBusesResponse response) { //... };
 });
      As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.

      Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.

      Note: If you prefer to have control on service calls, use the listEventBuses(software.amazon.awssdk.services.eventbridgev2.model.ListEventBusesRequest) operation.


      This is a convenience which creates an instance of the ListEventBusesRequest.Builder avoiding the need to create one manually via ListEventBusesRequest.builder()

      Parameters:
      listEventBusesRequest - A Consumer that will call methods on ListEventBusesRequest.Builder to create a request.
      Returns:
      A custom publisher that can be subscribed to request a stream of response pages.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • listEventSources

      default CompletableFuture<ListEventSourcesResponse> listEventSources(ListEventSourcesRequest listEventSourcesRequest)

      Lists EventSources as summaries. By default the list spans the EventSources the caller account owns; set EventBusArn to scope it to one bus. Use DescribeEventSource to retrieve full configuration.

      Parameters:
      listEventSourcesRequest -
      Returns:
      A Java Future containing the result of the ListEventSources operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • listEventSources

      default CompletableFuture<ListEventSourcesResponse> listEventSources(Consumer<ListEventSourcesRequest.Builder> listEventSourcesRequest)

      Lists EventSources as summaries. By default the list spans the EventSources the caller account owns; set EventBusArn to scope it to one bus. Use DescribeEventSource to retrieve full configuration.


      This is a convenience which creates an instance of the ListEventSourcesRequest.Builder avoiding the need to create one manually via ListEventSourcesRequest.builder()

      Parameters:
      listEventSourcesRequest - A Consumer that will call methods on ListEventSourcesRequest.Builder to create a request.
      Returns:
      A Java Future containing the result of the ListEventSources operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • listEventSourcesPaginator

      default ListEventSourcesPublisher listEventSourcesPaginator(ListEventSourcesRequest listEventSourcesRequest)

      This is a variant of listEventSources(software.amazon.awssdk.services.eventbridgev2.model.ListEventSourcesRequest) operation. The return type is a custom publisher that can be subscribed to request a stream of response pages. SDK will internally handle making service calls for you.

      When the operation is called, an instance of this class is returned. At this point, no service calls are made yet and so there is no guarantee that the request is valid. If there are errors in your request, you will see the failures only after you start streaming the data. The subscribe method should be called as a request to start streaming data. For more info, see Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe method will result in a new Subscription i.e., a new contract to stream data from the starting request.

      The following are few ways to use the response class:

      1) Using the subscribe helper method 
       
 software.amazon.awssdk.services.eventbridgev2.paginators.ListEventSourcesPublisher publisher = client.listEventSourcesPaginator(request);
 CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
 future.get();
      2) Using a custom subscriber 
       
 software.amazon.awssdk.services.eventbridgev2.paginators.ListEventSourcesPublisher publisher = client.listEventSourcesPaginator(request);
 publisher.subscribe(new Subscriber<software.amazon.awssdk.services.eventbridgev2.model.ListEventSourcesResponse>() {
 
 public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
 
 
 public void onNext(software.amazon.awssdk.services.eventbridgev2.model.ListEventSourcesResponse response) { //... };
 });
      As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.

      Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.

      Note: If you prefer to have control on service calls, use the listEventSources(software.amazon.awssdk.services.eventbridgev2.model.ListEventSourcesRequest) operation.

      Parameters:
      listEventSourcesRequest -
      Returns:
      A custom publisher that can be subscribed to request a stream of response pages.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • listEventSourcesPaginator

      default ListEventSourcesPublisher listEventSourcesPaginator(Consumer<ListEventSourcesRequest.Builder> listEventSourcesRequest)

      This is a variant of listEventSources(software.amazon.awssdk.services.eventbridgev2.model.ListEventSourcesRequest) operation. The return type is a custom publisher that can be subscribed to request a stream of response pages. SDK will internally handle making service calls for you.

      When the operation is called, an instance of this class is returned. At this point, no service calls are made yet and so there is no guarantee that the request is valid. If there are errors in your request, you will see the failures only after you start streaming the data. The subscribe method should be called as a request to start streaming data. For more info, see Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe method will result in a new Subscription i.e., a new contract to stream data from the starting request.

      The following are few ways to use the response class:

      1) Using the subscribe helper method 
       
 software.amazon.awssdk.services.eventbridgev2.paginators.ListEventSourcesPublisher publisher = client.listEventSourcesPaginator(request);
 CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
 future.get();
      2) Using a custom subscriber 
       
 software.amazon.awssdk.services.eventbridgev2.paginators.ListEventSourcesPublisher publisher = client.listEventSourcesPaginator(request);
 publisher.subscribe(new Subscriber<software.amazon.awssdk.services.eventbridgev2.model.ListEventSourcesResponse>() {
 
 public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
 
 
 public void onNext(software.amazon.awssdk.services.eventbridgev2.model.ListEventSourcesResponse response) { //... };
 });
      As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.

      Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.

      Note: If you prefer to have control on service calls, use the listEventSources(software.amazon.awssdk.services.eventbridgev2.model.ListEventSourcesRequest) operation.


      This is a convenience which creates an instance of the ListEventSourcesRequest.Builder avoiding the need to create one manually via ListEventSourcesRequest.builder()

      Parameters:
      listEventSourcesRequest - A Consumer that will call methods on ListEventSourcesRequest.Builder to create a request.
      Returns:
      A custom publisher that can be subscribed to request a stream of response pages.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • listResourcePolicies

      default CompletableFuture<ListResourcePoliciesResponse> listResourcePolicies(ListResourcePoliciesRequest listResourcePoliciesRequest)

      Lists the resource policies attached to an event bus as summaries (policy name and revision ID). Use GetResourcePolicy to retrieve a policy document.

      Parameters:
      listResourcePoliciesRequest -
      Returns:
      A Java Future containing the result of the ListResourcePolicies operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • listResourcePolicies

      default CompletableFuture<ListResourcePoliciesResponse> listResourcePolicies(Consumer<ListResourcePoliciesRequest.Builder> listResourcePoliciesRequest)

      Lists the resource policies attached to an event bus as summaries (policy name and revision ID). Use GetResourcePolicy to retrieve a policy document.


      This is a convenience which creates an instance of the ListResourcePoliciesRequest.Builder avoiding the need to create one manually via ListResourcePoliciesRequest.builder()

      Parameters:
      listResourcePoliciesRequest - A Consumer that will call methods on ListResourcePoliciesRequest.Builder to create a request.
      Returns:
      A Java Future containing the result of the ListResourcePolicies operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • listResourcePoliciesPaginator

      default ListResourcePoliciesPublisher listResourcePoliciesPaginator(ListResourcePoliciesRequest listResourcePoliciesRequest)

      This is a variant of listResourcePolicies(software.amazon.awssdk.services.eventbridgev2.model.ListResourcePoliciesRequest) operation. The return type is a custom publisher that can be subscribed to request a stream of response pages. SDK will internally handle making service calls for you.

      When the operation is called, an instance of this class is returned. At this point, no service calls are made yet and so there is no guarantee that the request is valid. If there are errors in your request, you will see the failures only after you start streaming the data. The subscribe method should be called as a request to start streaming data. For more info, see Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe method will result in a new Subscription i.e., a new contract to stream data from the starting request.

      The following are few ways to use the response class:

      1) Using the subscribe helper method 
       
 software.amazon.awssdk.services.eventbridgev2.paginators.ListResourcePoliciesPublisher publisher = client.listResourcePoliciesPaginator(request);
 CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
 future.get();
      2) Using a custom subscriber 
       
 software.amazon.awssdk.services.eventbridgev2.paginators.ListResourcePoliciesPublisher publisher = client.listResourcePoliciesPaginator(request);
 publisher.subscribe(new Subscriber<software.amazon.awssdk.services.eventbridgev2.model.ListResourcePoliciesResponse>() {
 
 public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
 
 
 public void onNext(software.amazon.awssdk.services.eventbridgev2.model.ListResourcePoliciesResponse response) { //... };
 });
      As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.

      Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.

      Note: If you prefer to have control on service calls, use the listResourcePolicies(software.amazon.awssdk.services.eventbridgev2.model.ListResourcePoliciesRequest) operation.

      Parameters:
      listResourcePoliciesRequest -
      Returns:
      A custom publisher that can be subscribed to request a stream of response pages.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • listResourcePoliciesPaginator

      default ListResourcePoliciesPublisher listResourcePoliciesPaginator(Consumer<ListResourcePoliciesRequest.Builder> listResourcePoliciesRequest)

      This is a variant of listResourcePolicies(software.amazon.awssdk.services.eventbridgev2.model.ListResourcePoliciesRequest) operation. The return type is a custom publisher that can be subscribed to request a stream of response pages. SDK will internally handle making service calls for you.

      When the operation is called, an instance of this class is returned. At this point, no service calls are made yet and so there is no guarantee that the request is valid. If there are errors in your request, you will see the failures only after you start streaming the data. The subscribe method should be called as a request to start streaming data. For more info, see Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe method will result in a new Subscription i.e., a new contract to stream data from the starting request.

      The following are few ways to use the response class:

      1) Using the subscribe helper method 
       
 software.amazon.awssdk.services.eventbridgev2.paginators.ListResourcePoliciesPublisher publisher = client.listResourcePoliciesPaginator(request);
 CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
 future.get();
      2) Using a custom subscriber 
       
 software.amazon.awssdk.services.eventbridgev2.paginators.ListResourcePoliciesPublisher publisher = client.listResourcePoliciesPaginator(request);
 publisher.subscribe(new Subscriber<software.amazon.awssdk.services.eventbridgev2.model.ListResourcePoliciesResponse>() {
 
 public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
 
 
 public void onNext(software.amazon.awssdk.services.eventbridgev2.model.ListResourcePoliciesResponse response) { //... };
 });
      As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.

      Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.

      Note: If you prefer to have control on service calls, use the listResourcePolicies(software.amazon.awssdk.services.eventbridgev2.model.ListResourcePoliciesRequest) operation.


      This is a convenience which creates an instance of the ListResourcePoliciesRequest.Builder avoiding the need to create one manually via ListResourcePoliciesRequest.builder()

      Parameters:
      listResourcePoliciesRequest - A Consumer that will call methods on ListResourcePoliciesRequest.Builder to create a request.
      Returns:
      A custom publisher that can be subscribed to request a stream of response pages.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • listSubscribers

      default CompletableFuture<ListSubscribersResponse> listSubscribers(ListSubscribersRequest listSubscribersRequest)

      Lists subscribers as summaries. By default the list spans the subscribers the caller account owns across all buses; set EventBusArn to scope it to one bus. Use DescribeSubscriber to retrieve full configuration.

      Parameters:
      listSubscribersRequest -
      Returns:
      A Java Future containing the result of the ListSubscribers operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • listSubscribers

      default CompletableFuture<ListSubscribersResponse> listSubscribers(Consumer<ListSubscribersRequest.Builder> listSubscribersRequest)

      Lists subscribers as summaries. By default the list spans the subscribers the caller account owns across all buses; set EventBusArn to scope it to one bus. Use DescribeSubscriber to retrieve full configuration.


      This is a convenience which creates an instance of the ListSubscribersRequest.Builder avoiding the need to create one manually via ListSubscribersRequest.builder()

      Parameters:
      listSubscribersRequest - A Consumer that will call methods on ListSubscribersRequest.Builder to create a request.
      Returns:
      A Java Future containing the result of the ListSubscribers operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • listSubscribersPaginator

      default ListSubscribersPublisher listSubscribersPaginator(ListSubscribersRequest listSubscribersRequest)

      This is a variant of listSubscribers(software.amazon.awssdk.services.eventbridgev2.model.ListSubscribersRequest) operation. The return type is a custom publisher that can be subscribed to request a stream of response pages. SDK will internally handle making service calls for you.

      When the operation is called, an instance of this class is returned. At this point, no service calls are made yet and so there is no guarantee that the request is valid. If there are errors in your request, you will see the failures only after you start streaming the data. The subscribe method should be called as a request to start streaming data. For more info, see Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe method will result in a new Subscription i.e., a new contract to stream data from the starting request.

      The following are few ways to use the response class:

      1) Using the subscribe helper method 
       
 software.amazon.awssdk.services.eventbridgev2.paginators.ListSubscribersPublisher publisher = client.listSubscribersPaginator(request);
 CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
 future.get();
      2) Using a custom subscriber 
       
 software.amazon.awssdk.services.eventbridgev2.paginators.ListSubscribersPublisher publisher = client.listSubscribersPaginator(request);
 publisher.subscribe(new Subscriber<software.amazon.awssdk.services.eventbridgev2.model.ListSubscribersResponse>() {
 
 public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
 
 
 public void onNext(software.amazon.awssdk.services.eventbridgev2.model.ListSubscribersResponse response) { //... };
 });
      As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.

      Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.

      Note: If you prefer to have control on service calls, use the listSubscribers(software.amazon.awssdk.services.eventbridgev2.model.ListSubscribersRequest) operation.

      Parameters:
      listSubscribersRequest -
      Returns:
      A custom publisher that can be subscribed to request a stream of response pages.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • listSubscribersPaginator

      default ListSubscribersPublisher listSubscribersPaginator(Consumer<ListSubscribersRequest.Builder> listSubscribersRequest)

      This is a variant of listSubscribers(software.amazon.awssdk.services.eventbridgev2.model.ListSubscribersRequest) operation. The return type is a custom publisher that can be subscribed to request a stream of response pages. SDK will internally handle making service calls for you.

      When the operation is called, an instance of this class is returned. At this point, no service calls are made yet and so there is no guarantee that the request is valid. If there are errors in your request, you will see the failures only after you start streaming the data. The subscribe method should be called as a request to start streaming data. For more info, see Publisher.subscribe(org.reactivestreams.Subscriber). Each call to the subscribe method will result in a new Subscription i.e., a new contract to stream data from the starting request.

      The following are few ways to use the response class:

      1) Using the subscribe helper method 
       
 software.amazon.awssdk.services.eventbridgev2.paginators.ListSubscribersPublisher publisher = client.listSubscribersPaginator(request);
 CompletableFuture<Void> future = publisher.subscribe(res -> { // Do something with the response });
 future.get();
      2) Using a custom subscriber 
       
 software.amazon.awssdk.services.eventbridgev2.paginators.ListSubscribersPublisher publisher = client.listSubscribersPaginator(request);
 publisher.subscribe(new Subscriber<software.amazon.awssdk.services.eventbridgev2.model.ListSubscribersResponse>() {
 
 public void onSubscribe(org.reactivestreams.Subscriber subscription) { //... };
 
 
 public void onNext(software.amazon.awssdk.services.eventbridgev2.model.ListSubscribersResponse response) { //... };
 });
      As the response is a publisher, it can work well with third party reactive streams implementations like RxJava2.

      Please notice that the configuration of MaxResults won't limit the number of results you get with the paginator. It only limits the number of results in each page.

      Note: If you prefer to have control on service calls, use the listSubscribers(software.amazon.awssdk.services.eventbridgev2.model.ListSubscribersRequest) operation.


      This is a convenience which creates an instance of the ListSubscribersRequest.Builder avoiding the need to create one manually via ListSubscribersRequest.builder()

      Parameters:
      listSubscribersRequest - A Consumer that will call methods on ListSubscribersRequest.Builder to create a request.
      Returns:
      A custom publisher that can be subscribed to request a stream of response pages.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • listTagsForResource

      default CompletableFuture<ListTagsForResourceResponse> listTagsForResource(ListTagsForResourceRequest listTagsForResourceRequest)

      Lists the tags on an event bus, subscriber, or event source.

      Parameters:
      listTagsForResourceRequest -
      Returns:
      A Java Future containing the result of the ListTagsForResource operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • listTagsForResource

      default CompletableFuture<ListTagsForResourceResponse> listTagsForResource(Consumer<ListTagsForResourceRequest.Builder> listTagsForResourceRequest)

      Lists the tags on an event bus, subscriber, or event source.


      This is a convenience which creates an instance of the ListTagsForResourceRequest.Builder avoiding the need to create one manually via ListTagsForResourceRequest.builder()

      Parameters:
      listTagsForResourceRequest - A Consumer that will call methods on ListTagsForResourceRequest.Builder to create a request.
      Returns:
      A Java Future containing the result of the ListTagsForResource operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • putEvents

      default CompletableFuture<PutEventsResponse> putEvents(PutEventsRequest putEventsRequest)

      Publishes events to an event bus.

      Parameters:
      putEventsRequest -
      Returns:
      A Java Future containing the result of the PutEvents operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • InvalidStateException The resource is not in a state that allows the operation. For example, an event bus that is still being created cannot accept events.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • putEvents

      default CompletableFuture<PutEventsResponse> putEvents(Consumer<PutEventsRequest.Builder> putEventsRequest)

      Publishes events to an event bus.


      This is a convenience which creates an instance of the PutEventsRequest.Builder avoiding the need to create one manually via PutEventsRequest.builder()

      Parameters:
      putEventsRequest - A Consumer that will call methods on PutEventsRequest.Builder to create a request.
      Returns:
      A Java Future containing the result of the PutEvents operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • InvalidStateException The resource is not in a state that allows the operation. For example, an event bus that is still being created cannot accept events.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • putRawEvents

      default CompletableFuture<PutRawEventsResponse> putRawEvents(PutRawEventsRequest putRawEventsRequest)

      Publishes pre-shaped events to an event bus.

      Parameters:
      putRawEventsRequest -
      Returns:
      A Java Future containing the result of the PutRawEvents operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • SchemaRegistryUnavailableException The configured schema registry could not be reached. Retry the request.
      • InternalException The request failed because of an internal service error. Retry the request.
      • InvalidStateException The resource is not in a state that allows the operation. For example, an event bus that is still being created cannot accept events.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • putRawEvents

      default CompletableFuture<PutRawEventsResponse> putRawEvents(Consumer<PutRawEventsRequest.Builder> putRawEventsRequest)

      Publishes pre-shaped events to an event bus.


      This is a convenience which creates an instance of the PutRawEventsRequest.Builder avoiding the need to create one manually via PutRawEventsRequest.builder()

      Parameters:
      putRawEventsRequest - A Consumer that will call methods on PutRawEventsRequest.Builder to create a request.
      Returns:
      A Java Future containing the result of the PutRawEvents operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • SchemaRegistryUnavailableException The configured schema registry could not be reached. Retry the request.
      • InternalException The request failed because of an internal service error. Retry the request.
      • InvalidStateException The resource is not in a state that allows the operation. For example, an event bus that is still being created cannot accept events.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • putResourcePolicy

      default CompletableFuture<PutResourcePolicyResponse> putResourcePolicy(PutResourcePolicyRequest putResourcePolicyRequest)

      Attaches a named resource policy to an event bus — the only resource type that supports policies; other resource ARNs are rejected. Each bus holds two named policies: "default" (customer-managed, full IAM policy language including Deny) and "AWS_RAM" (written exclusively by AWS Resource Access Manager to reflect resource shares). Both policies are evaluated on cross-account authorization; an explicit Deny in either overrides an Allow in the other. Operations that omit PolicyName target "default". A "default" policy that would grant public access is rejected with PublicPolicyException and is not attached; this check is always on and cannot be disabled.

      Parameters:
      putResourcePolicyRequest -
      Returns:
      A Java Future containing the result of the PutResourcePolicy operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • PolicyLengthExceededException The policy document is larger than the account's resource policy size quota, or larger than the service maximum.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • ConflictException A client-supplied precondition (e.g. ExpectedRevisionId on a resource-policy write) did not match the current state of the resource. Retrying the same request will fail again; re-read the resource and re-evaluate before retrying.

        A conditional request is not retry-safe on its own. If an earlier attempt committed but its response never reached the caller, retrying fails with this error, which is indistinguishable from another writer having won. Compare the resource's current contents with what the request intended: a successful attempt stores a revision ID the caller never saw, so the revision alone cannot tell the two apart, but matching contents mean the change took effect.

      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • ConcurrentModificationException Another change to the resource is already in progress. Retry the request.
      • PublicPolicyException The policy was rejected because it would grant public access to the event bus. A statement grants public access when its principal is a wildcard and no condition limits the callers to specific AWS accounts or principals. To fix it, replace the wildcard principal with specific principals, or add a condition that limits the callers to specific AWS accounts. Conditions on event content (events:source, events:detail-type, events:Metadata/*) do not identify the caller and do not make a wildcard principal non-public. Returned only for the "default" policy; the "AWS_RAM" policy is composed by AWS Resource Access Manager and never grants public access.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • putResourcePolicy

      default CompletableFuture<PutResourcePolicyResponse> putResourcePolicy(Consumer<PutResourcePolicyRequest.Builder> putResourcePolicyRequest)

      Attaches a named resource policy to an event bus — the only resource type that supports policies; other resource ARNs are rejected. Each bus holds two named policies: "default" (customer-managed, full IAM policy language including Deny) and "AWS_RAM" (written exclusively by AWS Resource Access Manager to reflect resource shares). Both policies are evaluated on cross-account authorization; an explicit Deny in either overrides an Allow in the other. Operations that omit PolicyName target "default". A "default" policy that would grant public access is rejected with PublicPolicyException and is not attached; this check is always on and cannot be disabled.


      This is a convenience which creates an instance of the PutResourcePolicyRequest.Builder avoiding the need to create one manually via PutResourcePolicyRequest.builder()

      Parameters:
      putResourcePolicyRequest - A Consumer that will call methods on PutResourcePolicyRequest.Builder to create a request.
      Returns:
      A Java Future containing the result of the PutResourcePolicy operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • PolicyLengthExceededException The policy document is larger than the account's resource policy size quota, or larger than the service maximum.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • ConflictException A client-supplied precondition (e.g. ExpectedRevisionId on a resource-policy write) did not match the current state of the resource. Retrying the same request will fail again; re-read the resource and re-evaluate before retrying.

        A conditional request is not retry-safe on its own. If an earlier attempt committed but its response never reached the caller, retrying fails with this error, which is indistinguishable from another writer having won. Compare the resource's current contents with what the request intended: a successful attempt stores a revision ID the caller never saw, so the revision alone cannot tell the two apart, but matching contents mean the change took effect.

      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • ConcurrentModificationException Another change to the resource is already in progress. Retry the request.
      • PublicPolicyException The policy was rejected because it would grant public access to the event bus. A statement grants public access when its principal is a wildcard and no condition limits the callers to specific AWS accounts or principals. To fix it, replace the wildcard principal with specific principals, or add a condition that limits the callers to specific AWS accounts. Conditions on event content (events:source, events:detail-type, events:Metadata/*) do not identify the caller and do not make a wildcard principal non-public. Returned only for the "default" policy; the "AWS_RAM" policy is composed by AWS Resource Access Manager and never grants public access.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • revokeResource

      default CompletableFuture<RevokeResourceResponse> revokeResource(RevokeResourceRequest revokeResourceRequest)

      Revokes a subscriber or an EventSource. The bus owner calls this to withdraw a misbehaving resource attached to their bus. Revocation is terminal: there is no operation that clears it. A revoked resource refuses mutating operations with InvalidStateException; delete stays available for cleanup.

      Parameters:
      revokeResourceRequest -
      Returns:
      A Java Future containing the result of the RevokeResource operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • ConcurrentModificationException Another change to the resource is already in progress. Retry the request.
      • InvalidStateException The resource is not in a state that allows the operation. For example, an event bus that is still being created cannot accept events.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • revokeResource

      default CompletableFuture<RevokeResourceResponse> revokeResource(Consumer<RevokeResourceRequest.Builder> revokeResourceRequest)

      Revokes a subscriber or an EventSource. The bus owner calls this to withdraw a misbehaving resource attached to their bus. Revocation is terminal: there is no operation that clears it. A revoked resource refuses mutating operations with InvalidStateException; delete stays available for cleanup.


      This is a convenience which creates an instance of the RevokeResourceRequest.Builder avoiding the need to create one manually via RevokeResourceRequest.builder()

      Parameters:
      revokeResourceRequest - A Consumer that will call methods on RevokeResourceRequest.Builder to create a request.
      Returns:
      A Java Future containing the result of the RevokeResource operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • ConcurrentModificationException Another change to the resource is already in progress. Retry the request.
      • InvalidStateException The resource is not in a state that allows the operation. For example, an event bus that is still being created cannot accept events.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • tagResource

      default CompletableFuture<TagResourceResponse> tagResource(TagResourceRequest tagResourceRequest)

      Adds or replaces tags on an event bus, subscriber, or event source.

      Parameters:
      tagResourceRequest -
      Returns:
      A Java Future containing the result of the TagResource operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • LimitExceededException The request would exceed a service quota for the account.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • ConcurrentModificationException Another change to the resource is already in progress. Retry the request.
      • InvalidStateException The resource is not in a state that allows the operation. For example, an event bus that is still being created cannot accept events.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • tagResource

      default CompletableFuture<TagResourceResponse> tagResource(Consumer<TagResourceRequest.Builder> tagResourceRequest)

      Adds or replaces tags on an event bus, subscriber, or event source.


      This is a convenience which creates an instance of the TagResourceRequest.Builder avoiding the need to create one manually via TagResourceRequest.builder()

      Parameters:
      tagResourceRequest - A Consumer that will call methods on TagResourceRequest.Builder to create a request.
      Returns:
      A Java Future containing the result of the TagResource operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • LimitExceededException The request would exceed a service quota for the account.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • ConcurrentModificationException Another change to the resource is already in progress. Retry the request.
      • InvalidStateException The resource is not in a state that allows the operation. For example, an event bus that is still being created cannot accept events.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • untagResource

      default CompletableFuture<UntagResourceResponse> untagResource(UntagResourceRequest untagResourceRequest)

      Removes tags from an event bus, subscriber, or event source.

      Parameters:
      untagResourceRequest -
      Returns:
      A Java Future containing the result of the UntagResource operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • ConcurrentModificationException Another change to the resource is already in progress. Retry the request.
      • InvalidStateException The resource is not in a state that allows the operation. For example, an event bus that is still being created cannot accept events.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • untagResource

      default CompletableFuture<UntagResourceResponse> untagResource(Consumer<UntagResourceRequest.Builder> untagResourceRequest)

      Removes tags from an event bus, subscriber, or event source.


      This is a convenience which creates an instance of the UntagResourceRequest.Builder avoiding the need to create one manually via UntagResourceRequest.builder()

      Parameters:
      untagResourceRequest - A Consumer that will call methods on UntagResourceRequest.Builder to create a request.
      Returns:
      A Java Future containing the result of the UntagResource operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • ConcurrentModificationException Another change to the resource is already in progress. Retry the request.
      • InvalidStateException The resource is not in a state that allows the operation. For example, an event bus that is still being created cannot accept events.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • updateEventBus

      default CompletableFuture<UpdateEventBusResponse> updateEventBus(UpdateEventBusRequest updateEventBusRequest)

      Updates an event bus. The update is asynchronous: the bus moves to UPDATING and returns to ACTIVE when the change is applied. Fields omitted from the request are left unchanged.

      Parameters:
      updateEventBusRequest -
      Returns:
      A Java Future containing the result of the UpdateEventBus operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • ConcurrentModificationException Another change to the resource is already in progress. Retry the request.
      • InvalidStateException The resource is not in a state that allows the operation. For example, an event bus that is still being created cannot accept events.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • updateEventBus

      default CompletableFuture<UpdateEventBusResponse> updateEventBus(Consumer<UpdateEventBusRequest.Builder> updateEventBusRequest)

      Updates an event bus. The update is asynchronous: the bus moves to UPDATING and returns to ACTIVE when the change is applied. Fields omitted from the request are left unchanged.


      This is a convenience which creates an instance of the UpdateEventBusRequest.Builder avoiding the need to create one manually via UpdateEventBusRequest.builder()

      Parameters:
      updateEventBusRequest - A Consumer that will call methods on UpdateEventBusRequest.Builder to create a request.
      Returns:
      A Java Future containing the result of the UpdateEventBus operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • ConcurrentModificationException Another change to the resource is already in progress. Retry the request.
      • InvalidStateException The resource is not in a state that allows the operation. For example, an event bus that is still being created cannot accept events.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • updateEventSource

      default CompletableFuture<UpdateEventSourceResponse> updateEventSource(UpdateEventSourceRequest updateEventSourceRequest)

      Updates an EventSource. Fields omitted from the request are left unchanged.

      Parameters:
      updateEventSourceRequest -
      Returns:
      A Java Future containing the result of the UpdateEventSource operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • ConcurrentModificationException Another change to the resource is already in progress. Retry the request.
      • InvalidStateException The resource is not in a state that allows the operation. For example, an event bus that is still being created cannot accept events.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • updateEventSource

      default CompletableFuture<UpdateEventSourceResponse> updateEventSource(Consumer<UpdateEventSourceRequest.Builder> updateEventSourceRequest)

      Updates an EventSource. Fields omitted from the request are left unchanged.


      This is a convenience which creates an instance of the UpdateEventSourceRequest.Builder avoiding the need to create one manually via UpdateEventSourceRequest.builder()

      Parameters:
      updateEventSourceRequest - A Consumer that will call methods on UpdateEventSourceRequest.Builder to create a request.
      Returns:
      A Java Future containing the result of the UpdateEventSource operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • ConcurrentModificationException Another change to the resource is already in progress. Retry the request.
      • InvalidStateException The resource is not in a state that allows the operation. For example, an event bus that is still being created cannot accept events.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • updateSubscriber

      default CompletableFuture<UpdateSubscriberResponse> updateSubscriber(UpdateSubscriberRequest updateSubscriberRequest)

      Updates a subscriber. Fields omitted from the request are left unchanged.

      Parameters:
      updateSubscriberRequest -
      Returns:
      A Java Future containing the result of the UpdateSubscriber operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • LimitExceededException The request would exceed a service quota for the account.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • ConcurrentModificationException Another change to the resource is already in progress. Retry the request.
      • InvalidStateException The resource is not in a state that allows the operation. For example, an event bus that is still being created cannot accept events.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • updateSubscriber

      default CompletableFuture<UpdateSubscriberResponse> updateSubscriber(Consumer<UpdateSubscriberRequest.Builder> updateSubscriberRequest)

      Updates a subscriber. Fields omitted from the request are left unchanged.


      This is a convenience which creates an instance of the UpdateSubscriberRequest.Builder avoiding the need to create one manually via UpdateSubscriberRequest.builder()

      Parameters:
      updateSubscriberRequest - A Consumer that will call methods on UpdateSubscriberRequest.Builder to create a request.
      Returns:
      A Java Future containing the result of the UpdateSubscriber operation returned by the service.
      The CompletableFuture returned by this method can be completed exceptionally with the following exceptions. The exception returned is wrapped with CompletionException, so you need to invoke Throwable.getCause() to retrieve the underlying exception.
      • LimitExceededException The request would exceed a service quota for the account.
      • AccessDeniedException The caller does not have the permissions required to perform the operation. This error is also returned when the operation cannot use the AWS KMS key for the event bus.
      • ResourceNotFoundException The resource does not exist.
      • ThrottlingException The request was throttled because it exceeds a request rate limit. Retry the request with backoff.
      • InvalidInputException A request parameter is missing or not valid.
      • InternalException The request failed because of an internal service error. Retry the request.
      • ConcurrentModificationException Another change to the resource is already in progress. Retry the request.
      • InvalidStateException The resource is not in a state that allows the operation. For example, an event bus that is still being created cannot accept events.
      • SdkException Base class for all exceptions that can be thrown by the SDK (both service and client). Can be used for catch all scenarios.
      • SdkClientException If any client side error occurs such as an IO related failure, failure to get credentials, etc.
      • EventBridgeV2Exception Base class for all service exceptions. Unknown exceptions will be thrown as an instance of this type.
      See Also:

    • waiter

      default EventBridgeV2AsyncWaiter waiter()
      Create an instance of EventBridgeV2AsyncWaiter using this client.

      Waiters created via this method are managed by the SDK and resources will be released when the service client is closed.

      Returns:
      an instance of EventBridgeV2AsyncWaiter

    • serviceClientConfiguration

      default EventBridgeV2ServiceClientConfiguration serviceClientConfiguration()
      Description copied from interface: SdkClient
      The SDK service client configuration exposes client settings to the user, e.g., ClientOverrideConfiguration
      Specified by:
      serviceClientConfiguration in interface AwsClient
      Specified by:
      serviceClientConfiguration in interface SdkClient
      Returns:
      SdkServiceClientConfiguration

    • create

      static EventBridgeV2AsyncClient create()
      Create a EventBridgeV2AsyncClient with the region loaded from the DefaultAwsRegionProviderChain and credentials loaded from the DefaultCredentialsProvider.

    • builder

      static EventBridgeV2AsyncClientBuilder builder()
      Create a builder that can be used to configure and create a EventBridgeV2AsyncClient.