1 |
|
2 |
|
3 |
|
4 | class MessagingSystem
|
5 | constructor: (address, options) ->
|
6 |
|
7 |
|
8 | connect: (callback) ->
|
9 | throw new Error 'Not Implemented'
|
10 | disconnect: (callback) ->
|
11 | throw new Error 'Not Implemented'
|
12 |
|
13 |
|
14 |
|
15 |
|
16 |
|
17 | createQueue: (type, queueName, options, callback) ->
|
18 | throw new Error 'Not Implemented'
|
19 | removeQueue: (type, queueName, callback) ->
|
20 | throw new Error 'Not Implemented'
|
21 |
|
22 |
|
23 |
|
24 | sendTo: (type, name, message, callback) ->
|
25 | throw new Error 'Not Implemented'
|
26 |
|
27 |
|
28 | subscribeToQueue: (queueName, handler, callback) ->
|
29 | throw new Error 'Not Implemented'
|
30 |
|
31 |
|
32 | ackMessage: (message) ->
|
33 | throw new Error 'Not Implemented'
|
34 | nackMessage: (message) ->
|
35 | throw new Error 'Not Implemented'
|
36 |
|
37 | class MessagingClient extends MessagingSystem
|
38 |
|
39 |
|
40 | registerParticipant: (part) ->
|
41 | throw new Error 'Not Implemented'
|
42 |
|
43 | exports.MessagingClient = MessagingClient
|
44 |
|
45 | class MessageBroker extends MessagingSystem
|
46 |
|
47 |
|
48 |
|
49 |
|
50 |
|
51 |
|
52 |
|
53 |
|
54 |
|
55 |
|
56 |
|
57 |
|
58 |
|
59 |
|
60 |
|
61 | addBinding: (binding, callback) ->
|
62 | throw new Error 'Not Implemented'
|
63 | removeBinding: (binding, callback) ->
|
64 | throw new Error 'Not Implemented'
|
65 |
|
66 | listBindings: (callback) ->
|
67 | throw new Error 'Not Implemented'
|
68 |
|
69 |
|
70 | subscribeParticipantChange: (handler) ->
|
71 | throw new Error 'Not Implemented'
|
72 |
|
73 | exports.MessageBroker = MessageBroker
|