File name
Commit message
Commit date
File name
Commit message
Commit date
File name
Commit message
Commit date
File name
Commit message
Commit date
// Copyright (c) 2019, 2022, Oracle and/or its affiliates.
//-----------------------------------------------------------------------------
//
// You may not use the identified files except in compliance with the Apache
// License, Version 2.0 (the "License.")
//
// You may obtain a copy of the License at
// http://www.apache.org/licenses/LICENSE-2.0.
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
// WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
//
// See the License for the specific language governing permissions and
// limitations under the License.
//
//-----------------------------------------------------------------------------
'use strict';
const nodbUtil = require('./util.js');
//-----------------------------------------------------------------------------
// deqOne()
// Returns a single message from the queue, if one is available.
//-----------------------------------------------------------------------------
async function deqOne() {
nodbUtil.checkArgCount(arguments, 0, 0);
return await this._deqOne();
}
//-----------------------------------------------------------------------------
// deqMany()
// Returns an array of messages from the queue, up to the maximum specified,
// if any are available.
//----------------------------------------------------------------------------
async function deqMany(maxMessages) {
nodbUtil.checkArgCount(arguments, 1, 1);
nodbUtil.assert(typeof maxMessages === 'number', 'NJS-005', 1);
return await this._deqMany(maxMessages);
}
//-----------------------------------------------------------------------------
// enqOne()
// Enqueues a single message into the queue.
//-----------------------------------------------------------------------------
async function enqOne(message) {
nodbUtil.checkArgCount(arguments, 1, 1);
nodbUtil.assert(typeof message === 'object' || typeof message === 'string',
'NJS-005', 1);
return await this._enqOne(message);
}
//-----------------------------------------------------------------------------
// enqMany()
// Enqueues multiple messages into the queue at the same time, avoiding
// multiple round-trips.
//----------------------------------------------------------------------------
async function enqMany(messages) {
nodbUtil.checkArgCount(arguments, 1, 1);
nodbUtil.assert(Array.isArray(messages), 'NJS-005', 1);
return await this._enqMany(messages);
}
class AqQueue {
_extend() {
this.deqOne = nodbUtil.callbackify(nodbUtil.serialize(deqOne));
this.deqMany = nodbUtil.callbackify(nodbUtil.serialize(deqMany));
this.enqOne = nodbUtil.callbackify(nodbUtil.serialize(enqOne));
this.enqMany = nodbUtil.callbackify(nodbUtil.serialize(enqMany));
}
_getConnection() {
return this._connection;
}
}
module.exports = AqQueue;