File tree Expand file tree Collapse file tree 2 files changed +2
-3
lines changed Expand file tree Collapse file tree 2 files changed +2
-3
lines changed Original file line number Diff line number Diff line change @@ -51,7 +51,7 @@ export const sendToQueue = async (
51
51
category : string ,
52
52
language : string ,
53
53
data : MatchRequestItem
54
- ) => {
54
+ ) : Promise < boolean > => {
55
55
try {
56
56
const queueName = `${ complexity } _${ category } _${ language } ` ;
57
57
const senderChannel = await mrConnection . createChannel ( ) ;
Original file line number Diff line number Diff line change @@ -2,7 +2,7 @@ import http from "http";
2
2
import app , { allowedOrigins } from "./app.ts" ;
3
3
import { handleWebsocketMatchEvents } from "./src/handlers/websocketHandler.ts" ;
4
4
import { Server } from "socket.io" ;
5
- import { connectRabbitMq , connectToRabbitMq } from "./config/rabbitmq.ts" ;
5
+ import { connectToRabbitMq } from "./config/rabbitmq.ts" ;
6
6
7
7
const server = http . createServer ( app ) ;
8
8
export const io = new Server ( server , {
@@ -21,7 +21,6 @@ const PORT = process.env.SERVICE_PORT || 3002;
21
21
22
22
if ( process . env . NODE_ENV !== "test" ) {
23
23
connectToRabbitMq ( )
24
- // connectRabbitMq()
25
24
. then ( ( ) => {
26
25
console . log ( "RabbitMq connected!" ) ;
27
26
You can’t perform that action at this time.
0 commit comments