Stop draining the queue in QueuedSink on exception

- droppedMessages Counter is added when the queue is full
- stop draining the queue when msgList is full
- msgList.clear() is called in QueuedSink
- unit test fixed accordingly