async queue(batch: MessageBatch<any>, env: Env): Promise<void> {
try {
let messages = JSON.stringify(batch.messages);
console.log(`consumed from our queue: ${messages}`);
if(serverSocket !== undefined){
console.log('ServerSocket=>', serverSocket) ;
serverSocket.send(messages);
}else{
console.log('ServerSocket Undefined=>', serverSocket) ;
console.log('Sending from Running Sock=>', serverSocket) ;
env.runningSock.send(messages);
}
} catch (error) {
console.log('Error=>',error);
}
},
async queue(batch: MessageBatch<any>, env: Env): Promise<void> {
try {
let messages = JSON.stringify(batch.messages);
console.log(`consumed from our queue: ${messages}`);
if(serverSocket !== undefined){
console.log('ServerSocket=>', serverSocket) ;
serverSocket.send(messages);
}else{
console.log('ServerSocket Undefined=>', serverSocket) ;
console.log('Sending from Running Sock=>', serverSocket) ;
env.runningSock.send(messages);
}
} catch (error) {
console.log('Error=>',error);
}
},