16. A non-transitory computer-readable storage medium containing instructions that cause one or more processors to: receive, from a publisher, a message associated with a general subject; determine a message type of the message; consume, via one of a plurality of consumer threads, the message from the publisher; dynamically load a selected one of a plurality of introspection routines from a library based on the message type, the selected introspection routine containing logic for handling the message type; determine a set of specific subjects for the message using the selected introspection routine; and publish the message to a set of consumers in accordance with one or more subscriptions based on the specific subjects and the general subject.
16. A non-transitory computer-readable storage medium containing instructions that cause one or more processors to: receive, from a publisher, a message associated with a general subject; determine a message type of the message; consume, via one of a plurality of consumer threads, the message from the publisher; dynamically load a selected one of a plurality of introspection routines from a library based on the message type, the selected introspection routine containing logic for handling the message type; determine a set of specific subjects for the message using the selected introspection routine; and publish the message to a set of consumers in accordance with one or more subscriptions based on the specific subjects and the general subject. 18. The non-transitory computer-readable storage medium of claim 16 , further containing instructions that cause the one or more processors to: receive from the consumers a desired format; and transform the message into the desired format.