example-activemq/consumer.js at master · repiatx/example-activemq · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
const stompit = require('stompit')


async function main() {

  const connectionManager = new stompit.ConnectFailover()

  connectionManager.addServer({
    'host': 'localhost',
    'port': 61613,
    'connectHeaders': {
      'host': '/',
      'login': 'admin',
      'passcode': 'admin',
      'heart-beat': '5000,5000'
    }
  })

  // prefect count might not work.
  const channel = new stompit.Channel(connectionManager,{prefetchSize:10})

  const subscribeHeaders = {
    'destination': '/queue/test1',
    'ack': 'client-individual',
  }

  channel.subscribe(subscribeHeaders, function (error, message) {

    if (error) {
      console.log('subscribe error ' + error.message)
      return
    }

    message.readString('utf-8', function (error, body) {

      if (error) {
        console.log('read message error ' + error.message)
        return
      }

      console.log('received message: ' + body)

      channel.ack(message)

      // client.disconnect()
    })
  })


  // const connectOptions = {
  //   'host': 'localhost',
  //   'port': 61613,
  //   alwaysConnected: false,
  //   'connectHeaders': {
  //     'host': '/',
  //     'login': 'admin',
  //     'passcode': 'admin',
  //     'heart-beat': '5000,5000'
  //   }
  // }
  //
  // stompit.connect(connectOptions, function (error, client) {
  //
  //   if (error) {
  //     console.log('connect error ' + error.message)
  //     return
  //   }
  //
  //   // const sendHeaders = {
  //   //   'destination': '/queue/test1',
  //   //   'content-type': 'text/plain'
  //   // }
  //   //
  //   // const frame = client.send(sendHeaders)
  //   // frame.write('hello')
  //   // frame.end()
  //
  //   const subscribeHeaders = {
  //     'destination': '/queue/test1',
  //     'ack': 'client-individual',
  //   }
  //
  //   client.subscribe(subscribeHeaders, function (error, message) {
  //
  //     if (error) {
  //       console.log('subscribe error ' + error.message)
  //       return
  //     }
  //
  //     message.readString('utf-8', function (error, body) {
  //
  //       if (error) {
  //         console.log('read message error ' + error.message)
  //         return
  //       }
  //
  //       console.log('received message: ' + body)
  //
  //       client.ack(message)
  //
  //       // client.disconnect()
  //     })
  //   })
  // })

}

main()