Skip to content

Instantly share code, notes, and snippets.

@soheilhy

soheilhy/queue.go

Created July 16, 2015 17:00
Show Gist options
  • Save soheilhy/c58f1c54dd277f398d13 to your computer and use it in GitHub Desktop.
Save soheilhy/c58f1c54dd277f398d13 to your computer and use it in GitHub Desktop.
Download ZIP
EnQHandler.Map
Raw
queue.go
func (h EnQHandler) Map(msg beehive.Msg, ctx beehive.MapContext) beehive.MappedCells {
// Send the Enque message to the bee that owns
// the Queue's entry in the active dictionary.
q := string(msg.Data().(Enque).Queue)
return beehive.MappedCells{{active, q}}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment