Class: Message<T>

Type parameters

Name	Type
T	unknown

Constructors

constructor

• new Message<T>()

Type parameters

Name	Type
T	unknown

Properties

data

• data: Buffer

Defined in

src/message/index.ts:6

---

gCloudMessage

• Optional gCloudMessage: Message

Defined in

src/message/index.ts:7

Methods

ack

▸ ack(): void

Returns

void

Defined in

src/message/index.ts:39

---

decompress

▸ decompress(): Buffer

Returns

Buffer

Defined in

src/message/index.ts:57

---

modAck

▸ modAck(deadline): void

Parameters

Name	Type
deadline	number

Returns

void

Defined in

src/message/index.ts:45

---

nack

▸ nack(): void

Returns

void

Defined in

src/message/index.ts:51

---

toJSON

▸ toJSON(): T

Returns

T

Defined in

src/message/index.ts:31

---

from

▸ Static from<M>(message): Message<M>

Builds a new message object in the synchronous driver. Used by the eventBus.

Type parameters

Name
M

Parameters

Name	Type	Description
message	M	any message that can be buffered

Returns

Message<M>

Defined in

src/message/index.ts:14

---

fromGCloud

▸ Static fromGCloud(message): Message<unknown>

Builds a message for Google Cloud Driver

Parameters

Name	Type	Description
message	Message	A valid Google Cloud message

Returns

Message<unknown>

Defined in

src/message/index.ts:24