ScalaStorm
ScalaStorm copied to clipboard
Can't use value types when emitting to specific stream or message id from StormSpout
The MessageIdEmitter and StreamEmitter emit methods allow only AnyRef parameters, unlike the equivalent StormSpout methods, which allow Any parameters. This prevents me from emitting e.g. Int values when using a specific stream or message id.
Hi there, sorry my github account settings seem to be messed up so I'm not getting notified on issues. I'll look into this sometime soon.