-
Notifications
You must be signed in to change notification settings - Fork 0
/
client.js
49 lines (40 loc) · 970 Bytes
/
client.js
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
const Seneca = require('seneca')
const bench = require('fastbench')
const myIp = require('./localAddress')[0]
const IP = process.env.IP || myIp
const action = process.argv[2] || 'myService'
const seneca = Seneca(/*{transport: {host: IP}}*/)
seneca
// .use('consul-registry', {
// host: '10.10.151.27'
// })
.use('mesh', {
bases: [IP+':40000'],
host: myIp,
discover: {
multicast: {
active: false
}
}
})
.ready( function () {
console.log('Client is Ready')
function call (cb) {
seneca.act(
{
action: action,
name: 'behrad_test',
default$: {name: 'behrad'}
},
function (err, msg) {
if(err) {
console.error(`Error calling action ${err}`)
} else {
// console.log(`Action back to client with ${msg.alert}`)
}
cb()
// this.close()
})
}
bench([call], 1)()
})