code: func (n *NetworkServerAPI) EnqueueMulticastQueueItem(ctx context.Context, req *ns.EnqueueMulticastQueueItemRequest) (*empty.Empty, error) {
  	if req.MulticastQueueItem == nil {
  		return nil, grpc.Errorf(codes.InvalidArgument, "multicast_queue_item must not be nil")
  	}
  
  	var mgID uuid.UUID
  	copy(mgID[:], req.MulticastQueueItem.MulticastGroupId)
  
  	qi := storage.MulticastQueueItem{
  		MulticastGroupID: mgID,
  		FCnt:             req.MulticastQueueItem.FCnt,
  		FPort:            uint8(req.MulticastQueueItem.FPort),
  		FRMPayload:       req.MulticastQueueItem.FrmPayload,
  	}
  
  	err := storage.Transaction(func(tx sqlx.Ext) error {
  		return multicast.EnqueueQueueItem(storage.RedisPool(), tx, qi)
  	})
  	if err != nil {
  		return nil, errToRPCError(err)
  	}
  
  	return &empty.Empty{}, nil
  }
docs: // EnqueueMulticastQueueItem creates the given multicast queue-item.