GoogleCloudStorageEventBus (util 3.1.16 API)

java.lang.Object
- com.google.cloud.hadoop.util.GoogleCloudStorageEventBus

public class GoogleCloudStorageEventBus
extends Object

Event Bus class

Constructor Summary

Constructors
Constructor Description

GoogleCloudStorageEventBus()

Method Summary

All Methods Static Methods Concrete Methods
Modifier and Type	Method	Description
`static void`	`onGcsRequest(GcsRequestExecutionEvent event)`	Posting Gcs request execution event i.e.
`static void`	`onGrpcStatus(io.grpc.Status status)`	Posting grpc Status to invoke the corresponding Subscriber method.
`static void`	`postGcsJsonApiEvent(IGcsJsonApiEvent gcsJsonApiEvent)`
`static void`	`postOnException()`	Posting Exception to invoke corresponding Subscriber method.
`static void`	`postWriteChecksumFailure()`
`static void`	`register(Object obj)`	Method to register an obj to event bus
`static void`	`unregister(Object obj)`	Method to unregister an obj to event bus

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - GoogleCloudStorageEventBus
```
public GoogleCloudStorageEventBus()
```
- Method Detail
  - register
```
public static void register(Object obj)
```
    Method to register an obj to event bus
    
    Parameters:
    
    obj - to register to event bus
  - unregister
```
public static void unregister(Object obj)
```
    Method to unregister an obj to event bus
    
    Parameters:
    
    obj - to unregister from event bus
    
    Throws:
    
    IllegalArgumentException - if the object was not previously registered.
  - onGcsRequest
```
public static void onGcsRequest(GcsRequestExecutionEvent event)
```
    Posting Gcs request execution event i.e. request to gcs is being initiated.
    
    Parameters:
    
    event - dummy event to map to request execution type.
  - postOnException
```
public static void postOnException()
```
    Posting Exception to invoke corresponding Subscriber method. Passing a dummy exception as EventBus has @ElementTypesAreNonnullByDefault annotation.
  - onGrpcStatus
```
public static void onGrpcStatus(io.grpc.Status status)
```
    Posting grpc Status to invoke the corresponding Subscriber method.
    
    Parameters:
    
    status - status object of grpc response
  - postGcsJsonApiEvent
```
public static void postGcsJsonApiEvent(IGcsJsonApiEvent gcsJsonApiEvent)
```
  - postWriteChecksumFailure
```
public static void postWriteChecksumFailure()
```