[@rxap/nest-amqp](../wiki/globals) / AmqpService

# Class: AmqpService

Defined in: [packages/nest/amqp/src/lib/amqp.service.ts:35](https://gitlab.com/rxap/libraries/cqrs/-/blob/b3efc64bb3a298aa043affe1613958c91a6aac2f/packages/nest/amqp/src/lib/amqp.service.ts#L35)

## Implements

- `OnApplicationBootstrap`

## Constructors

### new AmqpService()

> **new AmqpService**(): [`AmqpService`](../wiki/Class.AmqpService)

#### Returns

[`AmqpService`](../wiki/Class.AmqpService)

## Properties

### initialized

> `readonly` **initialized**: `ReplaySubject`\<`boolean`\>

Defined in: [packages/nest/amqp/src/lib/amqp.service.ts:36](https://gitlab.com/rxap/libraries/cqrs/-/blob/b3efc64bb3a298aa043affe1613958c91a6aac2f/packages/nest/amqp/src/lib/amqp.service.ts#L36)

***

### isReady

> `readonly` **isReady**: `Promise`\<`true`\>

Defined in: [packages/nest/amqp/src/lib/amqp.service.ts:37](https://gitlab.com/rxap/libraries/cqrs/-/blob/b3efc64bb3a298aa043affe1613958c91a6aac2f/packages/nest/amqp/src/lib/amqp.service.ts#L37)

## Methods

### ack()

> **ack**(`message`, `allToUp`?): `void`

Defined in: [packages/nest/amqp/src/lib/amqp.service.ts:106](https://gitlab.com/rxap/libraries/cqrs/-/blob/b3efc64bb3a298aa043affe1613958c91a6aac2f/packages/nest/amqp/src/lib/amqp.service.ts#L106)

#### Parameters

##### message

`Message`

##### allToUp?

`boolean`

#### Returns

`void`

***

### addHandler()

> **addHandler**(`routingKey`, `handler`): `Promise`\<`void`\>

Defined in: [packages/nest/amqp/src/lib/amqp.service.ts:114](https://gitlab.com/rxap/libraries/cqrs/-/blob/b3efc64bb3a298aa043affe1613958c91a6aac2f/packages/nest/amqp/src/lib/amqp.service.ts#L114)

#### Parameters

##### routingKey

`string`

##### handler

[`MessageHandler`](../wiki/TypeAlias.MessageHandler)

#### Returns

`Promise`\<`void`\>

***

### bind()

> **bind**(`pattern`): `Promise`\<`void`\>

Defined in: [packages/nest/amqp/src/lib/amqp.service.ts:121](https://gitlab.com/rxap/libraries/cqrs/-/blob/b3efc64bb3a298aa043affe1613958c91a6aac2f/packages/nest/amqp/src/lib/amqp.service.ts#L121)

#### Parameters

##### pattern

`string`

#### Returns

`Promise`\<`void`\>

***

### emit()

> **emit**(`routingKey`, `data`, `options`): `Promise`\<`void`\>

Defined in: [packages/nest/amqp/src/lib/amqp.service.ts:178](https://gitlab.com/rxap/libraries/cqrs/-/blob/b3efc64bb3a298aa043affe1613958c91a6aac2f/packages/nest/amqp/src/lib/amqp.service.ts#L178)

#### Parameters

##### routingKey

`string`

##### data

`any`

##### options

`PublishOptions` = `{}`

#### Returns

`Promise`\<`void`\>

***

### init()

> **init**(): `Promise`\<`void`\>

Defined in: [packages/nest/amqp/src/lib/amqp.service.ts:70](https://gitlab.com/rxap/libraries/cqrs/-/blob/b3efc64bb3a298aa043affe1613958c91a6aac2f/packages/nest/amqp/src/lib/amqp.service.ts#L70)

#### Returns

`Promise`\<`void`\>

***

### nack()

> **nack**(`message`, `allToUp`?, `requeue`?): `void`

Defined in: [packages/nest/amqp/src/lib/amqp.service.ts:110](https://gitlab.com/rxap/libraries/cqrs/-/blob/b3efc64bb3a298aa043affe1613958c91a6aac2f/packages/nest/amqp/src/lib/amqp.service.ts#L110)

#### Parameters

##### message

`Message`

##### allToUp?

`boolean`

##### requeue?

`boolean`

#### Returns

`void`

***

### onApplicationBootstrap()

> **onApplicationBootstrap**(): `Promise`\<`void`\>

Defined in: [packages/nest/amqp/src/lib/amqp.service.ts:66](https://gitlab.com/rxap/libraries/cqrs/-/blob/b3efc64bb3a298aa043affe1613958c91a6aac2f/packages/nest/amqp/src/lib/amqp.service.ts#L66)

#### Returns

`Promise`\<`void`\>

#### Implementation of

`OnApplicationBootstrap.onApplicationBootstrap`

***

### replay()

> **replay**(`replayQueue`, `data`, `options`): `Promise`\<`void`\>

Defined in: [packages/nest/amqp/src/lib/amqp.service.ts:204](https://gitlab.com/rxap/libraries/cqrs/-/blob/b3efc64bb3a298aa043affe1613958c91a6aac2f/packages/nest/amqp/src/lib/amqp.service.ts#L204)

#### Parameters

##### replayQueue

`string`

##### data

`any`

##### options

`PublishOptions` = `{}`

#### Returns

`Promise`\<`void`\>

***

### send()

> **send**\<`T`\>(`routingKey`, `data`, `options`): `Promise`\<`T`\>

Defined in: [packages/nest/amqp/src/lib/amqp.service.ts:139](https://gitlab.com/rxap/libraries/cqrs/-/blob/b3efc64bb3a298aa043affe1613958c91a6aac2f/packages/nest/amqp/src/lib/amqp.service.ts#L139)

#### Type Parameters

• **T**

#### Parameters

##### routingKey

`string`

##### data

`any`

##### options

`PublishOptions` = `{}`

#### Returns

`Promise`\<`T`\>

***

### unbind()

> **unbind**(`pattern`): `Promise`\<`void`\>

Defined in: [packages/nest/amqp/src/lib/amqp.service.ts:130](https://gitlab.com/rxap/libraries/cqrs/-/blob/b3efc64bb3a298aa043affe1613958c91a6aac2f/packages/nest/amqp/src/lib/amqp.service.ts#L130)

#### Parameters

##### pattern

`string`

#### Returns

`Promise`\<`void`\>