1. A publisher-subscriber system, comprising: a broker configured to receive and distribute at least one data stream from publishers to subscribers in accordance with subscriptions; and a classifier configured to extend a data stream with an additional stream-level attribute creating an annotated data stream wherein the annotated data stream applies the stream-level attribute to all messages therein such that subscribers can subscribe to the annotated data stream created by the classifier.