first commit

Author: Emeto

README.md

@@ -0,0 +1,2 @@
+# rabbitmq-messaging
+This is a quick Vue app to test out basic messaging features of RabbitMQ

package-lock.json

@@ -0,0 +1,19 @@
+{
+  "name": "rabbitmq-messaging",
+  "version": "0.1.0",
+  "description": "Quick Vue messaging app to test RabbitMQ basic features",
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "author": "Jérémy Castellano <jeremy.castellano@me.com>",
+  "license": "ISC",
+  "dependencies": {
+    "amqplib": "^0.8.0",
+    "vue": "^2.6.14",
+    "vuex": "^3.6.2"
+  },
+  "devDependencies": {
+    "@types/amqplib": "^0.8.2",
+    "typescript": "^4.3.5"
+  }
+}

package.json

@@ -0,0 +1,37 @@
+import {config} from './app.config';
+import {IConfig} from "./global/interfaces/IConfig";
+import {Channel, connect} from "amqplib";
+import {Connection} from "amqplib";
+
+export class Amqp {
+    public config: IConfig;
+    public currentChannel: Channel;
+
+    constructor() {
+        this.config = config;
+    }
+
+    public connect(): Promise<Connection> {
+        return connect(this.config.url);
+    }
+
+    public createChannel() {
+        this.connect()
+            .then(c => {
+                console.log('Connection to ' + this.config.url + ':' + this.config.port + ' successful');
+                return c.createChannel();
+            })
+            .then(ch => {
+                console.log('Channel created');
+                this.currentChannel = ch;
+            })
+            .catch(console.warn);
+    };
+
+    public closeConnection(): void {
+        this.currentChannel.close()
+            .then(r => {
+                console.log('Connection to channel closed : ' + r);
+            });
+    }
+}

src/amqp.ts

@@ -0,0 +1,7 @@
+import {IConfig} from "./global/interfaces/IConfig";
+
+export const config: IConfig = {
+    url: 'amqp://localhost',
+    port: 5672,
+    queue: 'messaging'
+}

src/app.config.ts

@@ -0,0 +1,20 @@
+<template>
+  <div>
+    <Transcript />
+  </div>
+</template>
+
+<script lang="ts">
+import Vue from 'vue';
+import Transcript from "./Transcript.vue";
+
+export default Vue.extend({
+  name: 'App',
+  components: {
+    Transcript
+  },
+  created() {
+    this.$publisher.sendMessage('Hi there !');
+  }
+});
+</script>

src/components/App.vue

@@ -0,0 +1,16 @@
+<template>
+  <div>
+    Transcript goes here
+  </div>
+</template>
+
+<script lang="ts">
+import Vue from 'vue';
+
+export default Vue.extend({
+  name: 'Transcript',
+  data: () => ({
+    messages: {}
+  })
+});
+</script>

src/components/Transcript.vue

@@ -0,0 +1,22 @@
+import Vue from "vue";
+import {Publisher} from "./publisher";
+import {Subscriber} from "./subscriber";
+import App from "./components/App.vue";
+
+export class Core {
+    public init(): void {
+        new Vue({
+            render: (h) => h(App)
+        }).$mount('#app');
+
+        Core.initEnvironment();
+    }
+
+    private static initEnvironment(): void {
+        Vue.prototype.$publisher = new Publisher();
+        Vue.prototype.$subscriber = new Subscriber();
+
+        Vue.prototype.$publisher.init();
+        Vue.prototype.$subscriber.init();
+    }
+}

src/core.ts

@@ -0,0 +1,5 @@
+export interface IConfig {
+    url: string,
+    port: number,
+    queue: string
+}

src/global/interfaces/IConfig.ts

@@ -0,0 +1,5 @@
+import {Core} from "./core";
+
+const core: Core = new Core();
+
+core.init();

src/main.ts

@@ -0,0 +1,22 @@
+import {Amqp} from "./amqp";
+
+export class Publisher {
+    private amqp: Amqp;
+
+    constructor() {
+        this.amqp = new Amqp();
+    }
+
+    private init(): void {
+        this.amqp.createChannel();
+    }
+
+    public sendMessage(message: string): void {
+        this.amqp.currentChannel
+            .assertQueue(this.amqp.config.queue)
+            .then(r => {
+                return this.amqp.currentChannel
+                    .sendToQueue(this.amqp.config.queue, Buffer.from(message));
+            })
+    }
+}

src/publisher.ts

@@ -0,0 +1,35 @@
+import {Amqp} from "./amqp";
+
+export class Subscriber {
+    private amqp: Amqp;
+    private _message: string;
+
+    constructor() {
+        this.amqp = new Amqp();
+    }
+
+    private init(): void {
+        this.amqp.createChannel();
+    }
+
+    public consumeMessage(): void {
+        this.amqp.currentChannel
+            .assertQueue(this.amqp.config.queue)
+            .then(r => {
+                this.amqp.currentChannel
+                    .consume(this.amqp.config.queue, msg => {
+                        if (msg !== null) {
+                            this._message = msg.content.toString();
+                            this.amqp.currentChannel.ack(msg);
+                        }
+                    })
+                    .then(r => {
+                        console.log(r);
+                    })
+            })
+    }
+
+    get message(): string {
+        return this._message;
+    }
+}

src/subscriber.ts

@@ -0,0 +1,36 @@
+{
+  "compilerOptions": {
+    "noImplicitAny": false,
+    "target": "ES2016",
+    "module": "commonjs",
+    "experimentalDecorators": true,
+    "emitDecoratorMetadata": true,
+    "sourceMap": true,
+    "noEmitHelpers": false,
+    "allowSyntheticDefaultImports": true
+  },
+  "rules": {
+    "object-literal-sort-keys": false,
+    "quotemark": true,
+    "semicolor": true,
+    "array-type": [true, "array"],
+    "arrow-return-shorthand": [true, "multiline"],
+    "switch-final-break": [true, "always"],
+    "class-name": true,
+    "arrow-parens": [true, "ban-single-arg-parens"],
+    "indent": [true, "spaces", 4],
+    "newline-before-return": true,
+    "no-consecutive-blank-lines": true,
+    "variable-name": [true, "check-format", "allow-leading-underscore", "allow-pascal-case"],
+    "radix": false,
+    "ordered-imports": [
+      true,
+      {
+        "import-sources-order": "lowercase-last",
+        "named-imports-order": "lowercase-first"
+      }
+    ],
+    "no-console": false
+  },
+  "include": ["src/**/*"]
+}