Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
throw new Error("'skip' is a required parameter and must be of type 'number'.");
}
if (typeof top !== "number") {
throw new Error("'top' is a required parameter and must be of type 'number'.");
}
if (lastUpdatedTime && !(lastUpdatedTime instanceof Date)) {
throw new Error("'lastUpdatedTime' must be of type 'Date'.");
}
if (!lastUpdatedTime) {
lastUpdatedTime = new Date(Date.now() - defaultLastUpdatedTimeForListingSessions);
}
try {
const messageBody: any = {};
messageBody["last-updated-time"] = lastUpdatedTime;
messageBody["skip"] = types.wrap_int(skip);
messageBody["top"] = types.wrap_int(top);
const request: AmqpMessage = {
body: messageBody,
reply_to: this.replyTo,
application_properties: {
operation: Constants.operations.enumerateSessions
}
};
request.application_properties![Constants.trackingId] = generate_uuid();
log.mgmt(
"[%s] List sessions request body: %O.",
this._context.namespace.connectionId,
request.body
);
log.mgmt(
"[%s] Acquiring lock to get the management req res link.",
this._context.namespace.connectionId
if (typeof skip !== "number") {
throw new Error("'skip' is a required parameter and must be of type 'number'.");
}
if (typeof top !== "number") {
throw new Error("'top' is a required parameter and must be of type 'number'.");
}
if (lastUpdatedTime && !(lastUpdatedTime instanceof Date)) {
throw new Error("'lastUpdatedTime' must be of type 'Date'.");
}
if (!lastUpdatedTime) {
lastUpdatedTime = new Date(Date.now() - defaultLastUpdatedTimeForListingSessions);
}
try {
const messageBody: any = {};
messageBody["last-updated-time"] = lastUpdatedTime;
messageBody["skip"] = types.wrap_int(skip);
messageBody["top"] = types.wrap_int(top);
const request: AmqpMessage = {
body: messageBody,
reply_to: this.replyTo,
application_properties: {
operation: Constants.operations.enumerateSessions
}
};
request.application_properties![Constants.trackingId] = generate_uuid();
log.mgmt(
"[%s] List sessions request body: %O.",
this._context.namespace.connectionId,
request.body
);
log.mgmt(
"[%s] Acquiring lock to get the management req res link.",
async getRules(): Promise {
throwErrorIfConnectionClosed(this._context.namespace);
try {
const request: AmqpMessage = {
body: {
top: types.wrap_int(max32BitNumber),
skip: types.wrap_int(0)
},
reply_to: this.replyTo,
application_properties: {
operation: Constants.operations.enumerateRules
}
};
request.application_properties![Constants.trackingId] = generate_uuid();
log.mgmt(
"[%s] Get rules request body: %O.",
this._context.namespace.connectionId,
request.body
);
log.mgmt(
"[%s] Acquiring lock to get the management req res link.",
this._context.namespace.connectionId
if (maxMessageCount !== undefined) {
throwTypeErrorIfParameterTypeMismatch(connId, "maxMessageCount", maxMessageCount, "number");
if (maxMessageCount <= 0) {
return [];
}
} else {
maxMessageCount = 1;
}
const messageList: ReceivedMessageInfo[] = [];
try {
const messageBody: any = {};
messageBody[Constants.fromSequenceNumber] = types.wrap_long(
Buffer.from(fromSequenceNumber.toBytesBE())
);
messageBody[Constants.messageCount] = types.wrap_int(maxMessageCount);
if (sessionId != undefined) {
messageBody[Constants.sessionIdMapKey] = sessionId;
}
const request: AmqpMessage = {
body: messageBody,
message_id: generate_uuid(),
reply_to: this.replyTo,
application_properties: {
operation: Constants.operations.peekMessage
}
};
const associatedLinkName = this._getAssociatedReceiverName(this._context, sessionId);
if (associatedLinkName) {
request.application_properties![Constants.associatedLinkName] = associatedLinkName;
}
request.application_properties![Constants.trackingId] = generate_uuid();
async getRules(): Promise {
throwErrorIfConnectionClosed(this._context.namespace);
try {
const request: AmqpMessage = {
body: {
top: types.wrap_int(max32BitNumber),
skip: types.wrap_int(0)
},
reply_to: this.replyTo,
application_properties: {
operation: Constants.operations.enumerateRules
}
};
request.application_properties![Constants.trackingId] = generate_uuid();
log.mgmt(
"[%s] Get rules request body: %O.",
this._context.namespace.connectionId,
request.body
);
log.mgmt(
"[%s] Acquiring lock to get the management req res link.",