import { Module } from '@nestjs/common';
import { AppService } from './AppService';
import { AMQPModule } from '@nestjs.pro/amqp/dist/AMQPModule';
import { AMQPLogLevel } from '@nestjs.pro/amqp/dist/AMQPLogLevel';

@Module({

    imports: [

        AMQPModule.forRoot({

            //
            // no secrets, log what is actually happening under the hood!
            //
            logLevel: AMQPLogLevel.DEBUG,

            //
            // add multiple connections if required..
            //
            connections: [

                {

                    name: 'one',
                    uri: 'amqp://rabbitmq:rabbitmq@localhost:5672',
                    exchange: {

                        name: 'test-1',
                        type: 'topic',
                        options: {

                            durable: true
                            // all other amqplib options supported..

                        }

                    },
                    queues: [

                        {

                            name: '1',
                            routingKey: '111',
                            createBindings: true,
                            options: {

                                durable: false
                                // all other amqplib options supported..

                            }

                        }

                        // add more queues..

                    ]

                }

                // add more connections to your hearts desire..

            ]

        })

    ],

    providers: [ AppService ]

})
export class AppModule {
}

import { Injectable } from '@nestjs/common';
import { AMQPService } from '@nestjs.pro/amqp/dist/AMQPService';
import { AMQPConnectionStatus } from '@nestjs.pro/amqp/dist/AMQPConnectionStatus';

@Injectable()
export class AppService {

    //
    // Inject in to your service(s)..
    //
    public constructor(private readonly amqpService: AMQPService) {

        //
        // Retrieve the connection named "one" and do some magic..
        //
        amqpService.getConnection('one').subscribe(connection => {

            //
            // Now that we're connected, publish a message..
            //
            connection.queue.publishJSON('test-1', 111, { date: new Date(), rand: Math.random() });

            // ..other fancy work happenin here..

            //
            // Optionally remove the exchange, queue, and routing keys if you want..
            //
            amqpService.tearDown().subscribe(() => {

                console.log('DEMO: Tear down complete, all remaining exchange(s) and queue(s) removed! 🏁');

                //
                // Disconnect gracefully now that we've cleaned things up..
                //
                amqpService.disconnect();

            });

        });

    }

}