1.0.49 • Published 2 years ago
iot-messaging v1.0.49
Lynx Iot-messaging
Getting started
Installation
Install this library using npm as follows
npm i iot-messaging@latest
Example
import { ActiveMqMessagingClientFactory, AzureMessagingClientFactory, MessagingClientFactory, MessagingClientSender,MessagingMiddleware } from 'iot-messaging';
Object.assign(global, { WebSocket: require('ws') }); # You might need to run 'npm i ws'
const messagingProvider = MessagingMiddleware.ActiveMQ;
let client: MessagingClientFactory;
if (messagingProvider == MessagingMiddleware.ActiveMQ) {
client = new ActiveMqMessagingClientFactory('endpoint', 'username', 'password');
} else {
client = new AzureMessagingClientFactory('endpoint');
}
let senderClient: MessagingClientSender;
client.createClient((sender => {
senderClient = sender;
//! Create and run TCP server
})
);
Example of Sending Batch Messages
const messages = result.messages.map((message: any) => ({
body: message,
properties: {
Source: source,
Version: config.messaging.version,
},
sessionId: imei,
}));
this.senderClient.sendBatch(config.messaging.queueName, messages);
Example of Subscribing to a queue
if (this.messagingProvider == MessagingMiddleware.ActiveMQ) {
this.subClient = new ActiveMqSubscribingClientFactory(ApplicationConfiguration.activeMq.uri, ApplicationConfiguration.activeMq.username, ApplicationConfiguration.activeMq.password);
}
else {
this.subClient = new AzureSubscribingClientFactory(ApplicationConfiguration.azureServiceBus.connectionString);
}
this.subClient.createClient((receiver => {
this.receiverClient = receiver;
});
);
this.receiverClient.subscribeByQueueNameAndSessionId(ApplicationConfiguration.messaging.queueName, '4', (messages) => { console.log(messages) });
interface SubscribingClientReceiver {
subscribeByTopic(params: SubscribingParams): any;
subscribeByQueueName(queueName: string, processMessage: (message: ServiceBusReceivedMessage | IMessage[]) => void): any;
subscribeByQueueNameAndSessionId: (queueName: string, sessionID: string,
processMessage: (message: ServiceBusReceivedMessage | IMessage[]) => void) => void;
peekMessages: (queueName: string, sessionId: string, maxNumberOfMessages: number) => Promise<ServiceBusReceivedMessage[]>
}
1.0.40
2 years ago
1.0.44
2 years ago
1.0.43
2 years ago
1.0.42
2 years ago
1.0.41
2 years ago
1.0.48
2 years ago
1.0.47
2 years ago
1.0.49
2 years ago
1.0.38
3 years ago
1.0.29
3 years ago
1.0.28
3 years ago
1.0.33
3 years ago
1.0.32
3 years ago
1.0.31
3 years ago
1.0.30
3 years ago
1.0.37
3 years ago
1.0.36
3 years ago
1.0.35
3 years ago
1.0.34
3 years ago
1.0.27
3 years ago
1.0.26
3 years ago
1.0.25
3 years ago
1.0.24
3 years ago
1.0.0
3 years ago
1.0.23
3 years ago
1.0.22
3 years ago
1.0.21
3 years ago
1.0.20
3 years ago
1.0.19
3 years ago
1.0.18
3 years ago
1.0.17
3 years ago
1.0.16
3 years ago
1.0.15
3 years ago
1.0.14
3 years ago
1.0.13
3 years ago
1.0.12
3 years ago
1.0.11
3 years ago
1.0.9
3 years ago
1.0.10
3 years ago
1.0.8
3 years ago
1.0.7
3 years ago
1.0.6
3 years ago
1.0.5
3 years ago
1.0.4
3 years ago
1.0.3
3 years ago
1.0.2
3 years ago
1.0.1
3 years ago