1: function azureQueueTest(request, response)
2: {
3:
4: var test= url.parse(request.url).path;
5:
6: console.log(test);
7:
8: var queuename= 'myqueue';
9:
10:
11: if(test='CREATE')
12: {
13: createQueueTest(queuename);
14: console.log("queue created...");
15:
16: }
17:
18: if(test= 'SEND')
19: {
20:
21: sendMessageTest(queuename);
22: console.log('enqueing message...');
23: }
24:
25: if(test= 'RECEIVE')
26: {
27: receiveMessageTest(queuename);
28: }
29:
30: response.end();
31: }
32:
33: function createQueueTest(queuename)
34: {
35: serviceBusService.createQueueIfNotExists(queuename, function(error){
36: if(!error){
37: console.log('queue created...');
38:
39: }
40: })
41:
42: }
43:
44:
45: function sendMessageTest(queue)
46: {
47: var message = {
48: body: 'Test message',
49: customProperties: {
50: testproperty: 'TestValue'
51: }}
52:
53: serviceBusService.sendQueueMessage(queue, message, function(error){
54: if(!error){
55: console.log('Message sent....');
56: }})
57: }
58:
59: function receiveMessageTest(queue)
60: {
61: serviceBusService.receiveQueueMessage(queue, function(error, receivedMessage){
62: if(!error){
63: console.log(receivedMessage);
64: }
65: });
66: }
67:
68: process.env.AZURE_SERVICEBUS_NAMESPACE= "MY NAMESPACE...";
69: process.env.AZURE_SERVICEBUS_ACCESS_KEY= "MY ACCESS KEY...";
70:
71: //var test= "RECEIVE";
72: var url = require('url');
73: var sb= require('azure');
74: var serviceBusService = sb.createServiceBusService();
75:
76: var http= require('http');
77: var server= http.createServer(azureQueueTest);
78: console.log('service listening at localhost:1111...');
79: server.listen(1111);