1.1.11 • Published 3 years ago

sync-response v1.1.11

Weekly downloads
1
License
ISC
Repository
-
Last release
3 years ago
const cfg = require('config');
let request_channel = Date.now().toString() + '_req';
let response_channel = Date.now().toString() + '_resp';
let client = new SyncResponseClient(request_channel,
    response_channel,
    cfg.get('sync_response_client.redis'),
    async (channel, message) => {
        let reqMsg = RequestMessage.fromMessageString(message);
        await client.publish(response_channel, 
            new ResponseMessage(reqMsg.requestId, 
            JSON.stringify({code: 0, message: Date.now().toString(16)})).toMessageString());
    });
client.resp(
    new RequestMessage('861111111000001' + Date.now().toString(),
        JSON.stringify({
            a: 1,
            b: Buffer.from('hello').toString('hex')})), 1000)
    .then((respMsg) => {
        console.log(respMsg);
    });
1.1.11

3 years ago

1.1.10

4 years ago

1.1.9

4 years ago

1.1.8

4 years ago

1.1.7

4 years ago

1.0.6

4 years ago

1.0.5

4 years ago

1.0.4

4 years ago

1.0.3

4 years ago

1.0.2

4 years ago

1.0.1

4 years ago

1.0.0

4 years ago