diff --git a/src/lib/ActionClientInterface.js b/src/lib/ActionClientInterface.js index 9823205..e89038b 100644 --- a/src/lib/ActionClientInterface.js +++ b/src/lib/ActionClientInterface.js @@ -41,29 +41,29 @@ class ActionClientInterface extends EventEmitter { const nh = options.nh; - const goalOptions = Object.assign({ queueSize: 10, latching: true }, options.goal); + const goalOptions = Object.assign({ queueSize: 50, latching: true }, options.goal); this._goalPub = nh.advertise(this._actionServer + '/goal', this._actionType + 'Goal', goalOptions); - const cancelOptions = Object.assign({ queueSize: 10, latching: true }, options.cancel); + const cancelOptions = Object.assign({ queueSize: 50, latching: true }, options.cancel); this._cancelPub = nh.advertise(this._actionServer + '/cancel', 'actionlib_msgs/GoalID', cancelOptions); - const statusOptions = Object.assign({ queueSize: 25 }, options.status); + const statusOptions = Object.assign({ queueSize: 50 }, options.status); this._statusSub = nh.subscribe(this._actionServer + '/status', 'actionlib_msgs/GoalStatusArray', (msg) => { this._handleStatus(msg); }, statusOptions); - const feedbackOptions = Object.assign({ queueSize: 25 }, options.feedback); + const feedbackOptions = Object.assign({ queueSize: 50 }, options.feedback); this._feedbackSub = nh.subscribe(this._actionServer + '/feedback', this._actionType + 'Feedback', (msg) => { this._handleFeedback(msg); }, feedbackOptions); - const resultOptions = Object.assign({ queueSize: 25 }, options.result); + const resultOptions = Object.assign({ queueSize: 50 }, options.result); this._resultSub = nh.subscribe(this._actionServer + '/result', this._actionType + 'Result', (msg) => { this._handleResult(msg); },