UNPKG

hazelcast-client

Version:

Hazelcast - open source In-Memory Data Grid - client for NodeJS

54 lines 2.08 kB
"use strict"; /* * Copyright (c) 2008-2018, Hazelcast, Inc. All Rights Reserved. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with 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. */ Object.defineProperty(exports, "__esModule", { value: true }); exports.RELIABLE_TOPIC_MESSAGE_FACTORY_ID = -18; exports.RELIABLE_TOPIC_CLASS_ID = 2; var RawTopicMessage = /** @class */ (function () { function RawTopicMessage() { } RawTopicMessage.prototype.readData = function (input) { this.publishTime = input.readLong(); this.publisherAddress = input.readObject(); this.payload = input.readData(); }; RawTopicMessage.prototype.writeData = function (output) { output.writeLong(this.publishTime); output.writeObject(this.publisherAddress); output.writeData(this.payload); }; RawTopicMessage.prototype.getFactoryId = function () { return exports.RELIABLE_TOPIC_MESSAGE_FACTORY_ID; }; RawTopicMessage.prototype.getClassId = function () { return exports.RELIABLE_TOPIC_CLASS_ID; }; return RawTopicMessage; }()); exports.RawTopicMessage = RawTopicMessage; var ReliableTopicMessageFactory = /** @class */ (function () { function ReliableTopicMessageFactory() { } ReliableTopicMessageFactory.prototype.create = function (type) { if (type === exports.RELIABLE_TOPIC_CLASS_ID) { return new RawTopicMessage(); } return null; }; return ReliableTopicMessageFactory; }()); exports.ReliableTopicMessageFactory = ReliableTopicMessageFactory; //# sourceMappingURL=RawTopicMessage.js.map