imp(messaging): expose AmqpConnectionStatus in public API
MODIFY
packages/messaging/src/index.ts
packages/messaging/src/index.ts
export * from './client/messaging.client';
export * from './client/messaging.client.interface';
export * from './transport/transport.interface';
+export { AmqpConnectionStatus } from './transport/strategies/amqp.strategy.interface';
export * from './effects/messaging.effects.interface';
export * from './server/messaging.server';
export * from './server/messaging.server.interface';

MODIFY
packages/messaging/src/transport/strategies/amqp.strategy.interface.ts
packages/messaging/src/transport/strategies/amqp.strategy.interface.ts
@@ -13,3 +13,10 @@ export interface AmqpStrategyOptions {
prefetchCount?: number;
expectAck?: boolean;
}
+
+export enum AmqpConnectionStatus {
+ CONNECTED = 'CONNECTED',
+ CHANNEL_CONNECTED = 'CHANNEL_CONNECTED',
+ CONNECTION_LOST = 'CONNECTION_LOST',
+ CHANNEL_CONNECTION_LOST = 'CHANNEL_CONNECTION_LOST',
+};

MODIFY
packages/messaging/src/transport/strategies/amqp.strategy.ts
packages/messaging/src/transport/strategies/amqp.strategy.ts
@@ -3,14 +3,7 @@ import { map, filter, take, mergeMap, mapTo, first } from 'rxjs/operators';
import { Channel, ConsumeMessage } from 'amqplib';
import { AmqpConnectionManager, ChannelWrapper } from 'amqp-connection-manager';
import { TransportLayer, TransportMessage, TransportLayerConnection } from '../transport.interface';
-import { AmqpStrategyOptions } from './amqp.strategy.interface';
-
-export enum AmqpConnectionStatus {
- CONNECTED = 'CONNECTED',
- CHANNEL_CONNECTED = 'CHANNEL_CONNECTED',
- CONNECTION_LOST = 'CONNECTION_LOST',
- CHANNEL_CONNECTION_LOST = 'CHANNEL_CONNECTION_LOST',
-};
+import { AmqpStrategyOptions, AmqpConnectionStatus } from './amqp.strategy.interface';
class AmqpStrategyConnection implements TransportLayerConnection {
private closeSubject$ = new Subject();

imp(messaging): expose AmqpConnectionStatus in public API