@@ -158,17 +158,20 @@ var QueueConsumer = function (queueName) {
158
158
consumer . messageConsumer = consumer . session . createMessageConsumer ( {
159
159
// solace.MessageConsumerProperties
160
160
queueDescriptor : { name : consumer . queueName , type : solace . QueueType . QUEUE } ,
161
- acknowledgeMode : solace . MessageConsumerAcknowledgeMode . CLIENT , // Enabling Client ack
162
- replayStartLocation : consumer . replayStartLocation ,
161
+ acknowledgeMode : solace . MessageConsumerAcknowledgeMode . CLIENT ,
162
+ replayStartLocation : consumer . replayStartLocation
163
163
} ) ;
164
164
// Define message consumer event listeners
165
165
consumer . messageConsumer . on ( solace . MessageConsumerEventName . UP , function ( ) {
166
166
consumer . consuming = true ;
167
167
} ) ;
168
- consumer . messageConsumer . on ( solace . MessageConsumerEventName . CONNECT_FAILED_ERROR , function ( ) {
168
+ consumer . messageConsumer . on ( solace . MessageConsumerEventName . CONNECT_FAILED_ERROR , function ( error ) {
169
169
consumer . consuming = false ;
170
- consumer . log ( '=== Error: the message consumer could not bind to queue "' + consumer . queueName +
171
- '" ===\n Ensure this queue exists on the message router vpn' ) ;
170
+ consumer . log ( '\n=== Error: the message consumer could not bind to queue "' + consumer . queueName +
171
+ "' ===\nError message: " + error . message +
172
+ "\nEnsure that:" +
173
+ "\n - The queue exists on the message router vpn" +
174
+ "\n - You have created the replay log." ) ;
172
175
} ) ;
173
176
consumer . messageConsumer . on ( solace . MessageConsumerEventName . DOWN , function ( ) {
174
177
consumer . consuming = false ;
0 commit comments