message queue interface for storm spout