BaseCloudEventMetadata (SmallRye Reactive Messaging 3.3.2 API)

java.lang.Object
- io.smallrye.reactive.messaging.ce.impl.BaseCloudEventMetadata<T>

Type Parameters:

T - the type of data

All Implemented Interfaces:

CloudEventMetadata<T>

Direct Known Subclasses:

DefaultIncomingCloudEventMetadata, DefaultOutgoingCloudEventMetadata
```
public class BaseCloudEventMetadata<T>
extends Object
implements CloudEventMetadata<T>
```
Default implementation of the CloudEventMetadata interface

Field Summary

Fields
Modifier and Type	Field and Description
`protected T`	`data`
`protected String`	`dataContentType`
`protected URI`	`dataSchema`
`protected Map<String,Object>`	`extensions`
`protected String`	`id`
`protected URI`	`source`
`protected String`	`specVersion`
`protected String`	`subject`
`protected ZonedDateTime`	`timestamp`
`protected String`	`type`

Fields inherited from interface io.smallrye.reactive.messaging.ce.CloudEventMetadata
CE_ATTRIBUTE_DATA_CONTENT_TYPE, CE_ATTRIBUTE_DATA_SCHEMA, CE_ATTRIBUTE_ID, CE_ATTRIBUTE_SOURCE, CE_ATTRIBUTE_SPEC_VERSION, CE_ATTRIBUTE_SUBJECT, CE_ATTRIBUTE_TIME, CE_ATTRIBUTE_TYPE, CE_VERSION_1_0

Constructor Summary

Constructors
Constructor and Description
`BaseCloudEventMetadata(String specVersion, String id, URI source, String type, String dataContentType, URI dataSchema, String subject, ZonedDateTime timestamp, Map<String,Object> extensions, T data)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`T`	`getData()` The event payload.
`Optional<String>`	`getDataContentType()` Content type of data value.
`Optional<URI>`	`getDataSchema()` Identifies the schema that data adheres to.
`<A> Optional<A>`	`getExtension(String name)` A CloudEvent may include any number of additional context attributes with distinct names, known as "extension attributes".
`Map<String,Object>`	`getExtensions()` A CloudEvent may include any number of additional context attributes with distinct names, known as "extension attributes".
`String`	`getId()` Identifies the event.
`URI`	`getSource()` Identifies the context in which an event happened.
`String`	`getSpecVersion()` The version of the CloudEvents specification which the event uses.
`Optional<String>`	`getSubject()` This describes the subject of the event in the context of the event producer (identified by source).
`Optional<ZonedDateTime>`	`getTimeStamp()` Timestamp of when the occurrence happened.
`String`	`getType()` This attribute contains a value describing the type of event related to the originating occurrence.
`void`	`validate()`

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

- Field Detail
  - id
```
protected final String id
```
  - specVersion
```
protected final String specVersion
```
  - source
```
protected final URI source
```
  - type
```
protected final String type
```
  - dataContentType
```
protected final String dataContentType
```
  - dataSchema
```
protected final URI dataSchema
```
  - subject
```
protected final String subject
```
  - timestamp
```
protected final ZonedDateTime timestamp
```
  - extensions
```
protected final Map<String,Object> extensions
```
  - data
```
protected final T data
```
- Constructor Detail
  - BaseCloudEventMetadata
```
public BaseCloudEventMetadata(String specVersion,
                              String id,
                              URI source,
                              String type,
                              String dataContentType,
                              URI dataSchema,
                              String subject,
                              ZonedDateTime timestamp,
                              Map<String,Object> extensions,
                              T data)
```
- Method Detail
  - validate
```
public void validate()
```
  - getId
```
public String getId()
```
    Description copied from interface: CloudEventMetadata
    
    Identifies the event. Mandatory attribute.
    
    Specified by:
    
    getId in interface CloudEventMetadata<T>
    
    Returns:
    
    the id, cannot be null
  - getSource
```
public URI getSource()
```
    Description copied from interface: CloudEventMetadata
    
    Identifies the context in which an event happened. Mandatory attribute.
    
    Specified by:
    
    getSource in interface CloudEventMetadata<T>
    
    Returns:
    
    the source, cannot be null
  - getSpecVersion
```
public String getSpecVersion()
```
    Description copied from interface: CloudEventMetadata
    
    The version of the CloudEvents specification which the event uses. Mandatory attribute.
    
    Specified by:
    
    getSpecVersion in interface CloudEventMetadata<T>
    
    Returns:
    
    the specification version
  - getType
```
public String getType()
```
    Description copied from interface: CloudEventMetadata
    
    This attribute contains a value describing the type of event related to the originating occurrence. Mandatory attribute.
    
    Specified by:
    
    getType in interface CloudEventMetadata<T>
    
    Returns:
    
    the type
  - getDataContentType
```
public Optional<String> getDataContentType()
```
    Description copied from interface: CloudEventMetadata
    
    Content type of data value.
    
    Specified by:
    
    getDataContentType in interface CloudEventMetadata<T>
    
    Returns:
    
    the content type if any, empty if none.
  - getDataSchema
```
public Optional<URI> getDataSchema()
```
    Description copied from interface: CloudEventMetadata
    
    Identifies the schema that data adheres to.
    
    Specified by:
    
    getDataSchema in interface CloudEventMetadata<T>
    
    Returns:
    
    the schema URI if any, empty if none.
  - getSubject
```
public Optional<String> getSubject()
```
    Description copied from interface: CloudEventMetadata
    
    This describes the subject of the event in the context of the event producer (identified by source).
    
    Specified by:
    
    getSubject in interface CloudEventMetadata<T>
    
    Returns:
    
    the subject if any, empty if none
  - getTimeStamp
```
public Optional<ZonedDateTime> getTimeStamp()
```
    Description copied from interface: CloudEventMetadata
    
    Timestamp of when the occurrence happened.
    
    Specified by:
    
    getTimeStamp in interface CloudEventMetadata<T>
    
    Returns:
    
    the timestamp if any, empty if none
  - getExtension
```
public <A> Optional<A> getExtension(String name)
```
    Description copied from interface: CloudEventMetadata
    
    A CloudEvent may include any number of additional context attributes with distinct names, known as "extension attributes". This method allows retrieving these attributes.
    
    Specified by:
    
    getExtension in interface CloudEventMetadata<T>
    
    Parameters:
    
    name - the name of the attribute, must not be null
    
    Returns:
    
    the value of the attribute, empty if not present.
  - getExtensions
```
public Map<String,Object> getExtensions()
```
    Description copied from interface: CloudEventMetadata
    
    A CloudEvent may include any number of additional context attributes with distinct names, known as "extension attributes". This method allows retrieving these attributes.
    
    Specified by:
    
    getExtensions in interface CloudEventMetadata<T>
    
    Returns:
    
    the map of extension attributes, potentially empty.
  - getData
```
public T getData()
```
    Description copied from interface: CloudEventMetadata
    
    The event payload. It is the owner message payload.
    
    Specified by:
    
    getData in interface CloudEventMetadata<T>
    
    Returns:
    
    the payload, can be null

Class BaseCloudEventMetadata<T>

Field Summary

Fields inherited from interface io.smallrye.reactive.messaging.ce.CloudEventMetadata

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

id

specVersion

source

type

dataContentType

dataSchema

subject

timestamp

extensions

data

Constructor Detail

BaseCloudEventMetadata

Method Detail

validate

getId

getSource

getSpecVersion

getType

getDataContentType

getDataSchema

getSubject

getTimeStamp

getExtension

getExtensions

getData